Skip to content

fathom

import "github.com/KrakenNet/fathom-go"

Package fathom provides a Go client for the Fathom policy engine REST API.

Index

type AssertFactRequest

AssertFactRequest is the payload for POST /v1/facts.

type AssertFactRequest struct {
    SessionID string         `json:"session_id"`
    Template  string         `json:"template"`
    Data      map[string]any `json:"data"`
}

type AssertFactResponse

AssertFactResponse is the response from POST /v1/facts.

type AssertFactResponse struct {
    Success bool `json:"success"`
}

type Client

Client communicates with the Fathom REST API.

type Client struct {
    // contains filtered or unexported fields
}

func NewClient

func NewClient(baseURL string, opts ...ClientOption) *Client

NewClient creates a new Fathom client pointing at the given base URL. Example:

client := NewClient("http://localhost:8000", WithBearerToken("secret"))

func (*Client) AssertFact

func (c *Client) AssertFact(ctx context.Context, req *AssertFactRequest) (*AssertFactResponse, error)

AssertFact asserts a single fact into the session's working memory.

func (*Client) Evaluate

func (c *Client) Evaluate(ctx context.Context, req *EvaluateRequest) (*EvaluateResponse, error)

Evaluate sends facts to the engine and returns the policy decision.

func (*Client) Query

func (c *Client) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error)

Query retrieves facts from the session's working memory.

func (*Client) Retract

func (c *Client) Retract(ctx context.Context, req *RetractRequest) (*RetractResponse, error)

Retract removes facts matching the request's template + optional filter from the session's working memory and returns the number of retractions.

type ClientOption

ClientOption mutates a Client during construction.

type ClientOption func(*Client)

func WithBearerToken

func WithBearerToken(tok string) ClientOption

WithBearerToken configures the client to send "Authorization: Bearer \<tok>" on every request.

func WithHTTPClient

func WithHTTPClient(hc *http.Client) ClientOption

WithHTTPClient overrides the underlying *http.Client (useful for tests or custom transports).

type EvaluateRequest

EvaluateRequest is the payload for POST /v1/evaluate.

type EvaluateRequest struct {
    Facts     []FactInput `json:"facts"`
    Ruleset   string      `json:"ruleset"`
    SessionID string      `json:"session_id,omitempty"`
}

type EvaluateResponse

EvaluateResponse is the response from POST /v1/evaluate.

type EvaluateResponse struct {
    Decision         string   `json:"decision"`
    Reason           string   `json:"reason"`
    RuleTrace        []string `json:"rule_trace"`
    ModuleTrace      []string `json:"module_trace"`
    DurationUS       int64    `json:"duration_us"`
    AttestationToken string   `json:"attestation_token,omitempty"`
}

type FactInput

FactInput is a single fact assertion used inside EvaluateRequest.

type FactInput struct {
    Template string         `json:"template"`
    Data     map[string]any `json:"data"`
}

type QueryRequest

QueryRequest is the payload for POST /v1/query.

type QueryRequest struct {
    SessionID string         `json:"session_id"`
    Template  string         `json:"template"`
    Filter    map[string]any `json:"filter,omitempty"`
}

type QueryResponse

QueryResponse is the response from POST /v1/query.

type QueryResponse struct {
    Facts []map[string]any `json:"facts"`
}

type RetractRequest

RetractRequest is the payload for DELETE /v1/facts.

type RetractRequest struct {
    SessionID string         `json:"session_id"`
    Template  string         `json:"template"`
    Filter    map[string]any `json:"filter,omitempty"`
}

type RetractResponse

RetractResponse is the response from DELETE /v1/facts.

type RetractResponse struct {
    RetractedCount int `json:"retracted_count"`
}

fathomv1

import "github.com/KrakenNet/fathom-go/proto"

Index

Constants

const (
    FathomService_Evaluate_FullMethodName         = "/fathom.v1.FathomService/Evaluate"
    FathomService_AssertFact_FullMethodName       = "/fathom.v1.FathomService/AssertFact"
    FathomService_Query_FullMethodName            = "/fathom.v1.FathomService/Query"
    FathomService_Retract_FullMethodName          = "/fathom.v1.FathomService/Retract"
    FathomService_SubscribeChanges_FullMethodName = "/fathom.v1.FathomService/SubscribeChanges"
    FathomService_Reload_FullMethodName           = "/fathom.v1.FathomService/Reload"
)

Variables

Enum value maps for ChangeType.

var (
    ChangeType_name = map[int32]string{
        0:  "CHANGE_TYPE_UNSPECIFIED",
        1:  "ASSERT",
        2:  "RETRACT",
    }
    ChangeType_value = map[string]int32{
        "CHANGE_TYPE_UNSPECIFIED": 0,
        "ASSERT":                  1,
        "RETRACT":                 2,
    }
)

FathomService_ServiceDesc is the grpc.ServiceDesc for FathomService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var FathomService_ServiceDesc = grpc.ServiceDesc{
    ServiceName: "fathom.v1.FathomService",
    HandlerType: (*FathomServiceServer)(nil),
    Methods: []grpc.MethodDesc{
        {
            MethodName: "Evaluate",
            Handler:    _FathomService_Evaluate_Handler,
        },
        {
            MethodName: "AssertFact",
            Handler:    _FathomService_AssertFact_Handler,
        },
        {
            MethodName: "Query",
            Handler:    _FathomService_Query_Handler,
        },
        {
            MethodName: "Retract",
            Handler:    _FathomService_Retract_Handler,
        },
        {
            MethodName: "Reload",
            Handler:    _FathomService_Reload_Handler,
        },
    },
    Streams: []grpc.StreamDesc{
        {
            StreamName:    "SubscribeChanges",
            Handler:       _FathomService_SubscribeChanges_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "fathom.proto",
}


var File_fathom_proto protoreflect.FileDescriptor

func RegisterFathomServiceServer

func RegisterFathomServiceServer(s grpc.ServiceRegistrar, srv FathomServiceServer)

type AssertFactRequest

type AssertFactRequest struct {
    SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    Template  string `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
    // JSON-encoded slot data.
    DataJson string `protobuf:"bytes,3,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
    // contains filtered or unexported fields
}

func (*AssertFactRequest) Descriptor

func (*AssertFactRequest) Descriptor() ([]byte, []int)

Deprecated: Use AssertFactRequest.ProtoReflect.Descriptor instead.

func (*AssertFactRequest) GetDataJson

func (x *AssertFactRequest) GetDataJson() string

func (*AssertFactRequest) GetSessionId

func (x *AssertFactRequest) GetSessionId() string

func (*AssertFactRequest) GetTemplate

func (x *AssertFactRequest) GetTemplate() string

func (*AssertFactRequest) ProtoMessage

func (*AssertFactRequest) ProtoMessage()

func (*AssertFactRequest) ProtoReflect

func (x *AssertFactRequest) ProtoReflect() protoreflect.Message

func (*AssertFactRequest) Reset

func (x *AssertFactRequest) Reset()

func (*AssertFactRequest) String

func (x *AssertFactRequest) String() string

type AssertFactResponse

type AssertFactResponse struct {
    Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
    // contains filtered or unexported fields
}

func (*AssertFactResponse) Descriptor

func (*AssertFactResponse) Descriptor() ([]byte, []int)

Deprecated: Use AssertFactResponse.ProtoReflect.Descriptor instead.

func (*AssertFactResponse) GetSuccess

func (x *AssertFactResponse) GetSuccess() bool

func (*AssertFactResponse) ProtoMessage

func (*AssertFactResponse) ProtoMessage()

func (*AssertFactResponse) ProtoReflect

func (x *AssertFactResponse) ProtoReflect() protoreflect.Message

func (*AssertFactResponse) Reset

func (x *AssertFactResponse) Reset()

func (*AssertFactResponse) String

func (x *AssertFactResponse) String() string

type ChangeType

type ChangeType int32


const (
    ChangeType_CHANGE_TYPE_UNSPECIFIED ChangeType = 0
    ChangeType_ASSERT                  ChangeType = 1
    ChangeType_RETRACT                 ChangeType = 2
)

func (ChangeType) Descriptor

func (ChangeType) Descriptor() protoreflect.EnumDescriptor

func (ChangeType) Enum

func (x ChangeType) Enum() *ChangeType

func (ChangeType) EnumDescriptor

func (ChangeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChangeType.Descriptor instead.

func (ChangeType) Number

func (x ChangeType) Number() protoreflect.EnumNumber

func (ChangeType) String

func (x ChangeType) String() string

func (ChangeType) Type

func (ChangeType) Type() protoreflect.EnumType

type EvaluateRequest

type EvaluateRequest struct {
    SessionId string       `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    Ruleset   string       `protobuf:"bytes,2,opt,name=ruleset,proto3" json:"ruleset,omitempty"`
    Facts     []*FactInput `protobuf:"bytes,3,rep,name=facts,proto3" json:"facts,omitempty"`
    // contains filtered or unexported fields
}

func (*EvaluateRequest) Descriptor

func (*EvaluateRequest) Descriptor() ([]byte, []int)

Deprecated: Use EvaluateRequest.ProtoReflect.Descriptor instead.

func (*EvaluateRequest) GetFacts

func (x *EvaluateRequest) GetFacts() []*FactInput

func (*EvaluateRequest) GetRuleset

func (x *EvaluateRequest) GetRuleset() string

func (*EvaluateRequest) GetSessionId

func (x *EvaluateRequest) GetSessionId() string

func (*EvaluateRequest) ProtoMessage

func (*EvaluateRequest) ProtoMessage()

func (*EvaluateRequest) ProtoReflect

func (x *EvaluateRequest) ProtoReflect() protoreflect.Message

func (*EvaluateRequest) Reset

func (x *EvaluateRequest) Reset()

func (*EvaluateRequest) String

func (x *EvaluateRequest) String() string

type EvaluateResponse

type EvaluateResponse struct {
    Decision    string   `protobuf:"bytes,1,opt,name=decision,proto3" json:"decision,omitempty"`
    Reason      string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
    RuleTrace   []string `protobuf:"bytes,3,rep,name=rule_trace,json=ruleTrace,proto3" json:"rule_trace,omitempty"`
    ModuleTrace []string `protobuf:"bytes,4,rep,name=module_trace,json=moduleTrace,proto3" json:"module_trace,omitempty"`
    DurationUs  int64    `protobuf:"varint,5,opt,name=duration_us,json=durationUs,proto3" json:"duration_us,omitempty"`
    // contains filtered or unexported fields
}

func (*EvaluateResponse) Descriptor

func (*EvaluateResponse) Descriptor() ([]byte, []int)

Deprecated: Use EvaluateResponse.ProtoReflect.Descriptor instead.

func (*EvaluateResponse) GetDecision

func (x *EvaluateResponse) GetDecision() string

func (*EvaluateResponse) GetDurationUs

func (x *EvaluateResponse) GetDurationUs() int64

func (*EvaluateResponse) GetModuleTrace

func (x *EvaluateResponse) GetModuleTrace() []string

func (*EvaluateResponse) GetReason

func (x *EvaluateResponse) GetReason() string

func (*EvaluateResponse) GetRuleTrace

func (x *EvaluateResponse) GetRuleTrace() []string

func (*EvaluateResponse) ProtoMessage

func (*EvaluateResponse) ProtoMessage()

func (*EvaluateResponse) ProtoReflect

func (x *EvaluateResponse) ProtoReflect() protoreflect.Message

func (*EvaluateResponse) Reset

func (x *EvaluateResponse) Reset()

func (*EvaluateResponse) String

func (x *EvaluateResponse) String() string

type FactChange

type FactChange struct {
    ChangeType ChangeType `protobuf:"varint,1,opt,name=change_type,json=changeType,proto3,enum=fathom.v1.ChangeType" json:"change_type,omitempty"`
    Template   string     `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
    // JSON-encoded slot data of the changed fact.
    DataJson string `protobuf:"bytes,3,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
    // contains filtered or unexported fields
}

func (*FactChange) Descriptor

func (*FactChange) Descriptor() ([]byte, []int)

Deprecated: Use FactChange.ProtoReflect.Descriptor instead.

func (*FactChange) GetChangeType

func (x *FactChange) GetChangeType() ChangeType

func (*FactChange) GetDataJson

func (x *FactChange) GetDataJson() string

func (*FactChange) GetTemplate

func (x *FactChange) GetTemplate() string

func (*FactChange) ProtoMessage

func (*FactChange) ProtoMessage()

func (*FactChange) ProtoReflect

func (x *FactChange) ProtoReflect() protoreflect.Message

func (*FactChange) Reset

func (x *FactChange) Reset()

func (*FactChange) String

func (x *FactChange) String() string

type FactInput

type FactInput struct {
    Template string `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
    // JSON-encoded slot data (e.g. {"tool_name": "bash", "agent_id": "a1"}).
    DataJson string `protobuf:"bytes,2,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
    // contains filtered or unexported fields
}

func (*FactInput) Descriptor

func (*FactInput) Descriptor() ([]byte, []int)

Deprecated: Use FactInput.ProtoReflect.Descriptor instead.

func (*FactInput) GetDataJson

func (x *FactInput) GetDataJson() string

func (*FactInput) GetTemplate

func (x *FactInput) GetTemplate() string

func (*FactInput) ProtoMessage

func (*FactInput) ProtoMessage()

func (*FactInput) ProtoReflect

func (x *FactInput) ProtoReflect() protoreflect.Message

func (*FactInput) Reset

func (x *FactInput) Reset()

func (*FactInput) String

func (x *FactInput) String() string

type FathomServiceClient

FathomServiceClient is the client API for FathomService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type FathomServiceClient interface {
    // Evaluate asserted facts against loaded rules and return a decision.
    Evaluate(ctx context.Context, in *EvaluateRequest, opts ...grpc.CallOption) (*EvaluateResponse, error)
    // Assert one or more facts into working memory.
    AssertFact(ctx context.Context, in *AssertFactRequest, opts ...grpc.CallOption) (*AssertFactResponse, error)
    // Query working memory for facts matching a template and optional filter.
    Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
    // Retract facts matching a template and optional filter.
    Retract(ctx context.Context, in *RetractRequest, opts ...grpc.CallOption) (*RetractResponse, error)
    // Stream working-memory changes as they occur during evaluation.
    SubscribeChanges(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[FactChange], error)
    // Hot-reload the ruleset from a path or inline YAML.
    Reload(ctx context.Context, in *ReloadRequest, opts ...grpc.CallOption) (*ReloadResponse, error)
}

func NewFathomServiceClient

func NewFathomServiceClient(cc grpc.ClientConnInterface) FathomServiceClient

type FathomServiceServer

FathomServiceServer is the server API for FathomService service. All implementations must embed UnimplementedFathomServiceServer for forward compatibility.

type FathomServiceServer interface {
    // Evaluate asserted facts against loaded rules and return a decision.
    Evaluate(context.Context, *EvaluateRequest) (*EvaluateResponse, error)
    // Assert one or more facts into working memory.
    AssertFact(context.Context, *AssertFactRequest) (*AssertFactResponse, error)
    // Query working memory for facts matching a template and optional filter.
    Query(context.Context, *QueryRequest) (*QueryResponse, error)
    // Retract facts matching a template and optional filter.
    Retract(context.Context, *RetractRequest) (*RetractResponse, error)
    // Stream working-memory changes as they occur during evaluation.
    SubscribeChanges(*SubscribeRequest, grpc.ServerStreamingServer[FactChange]) error
    // Hot-reload the ruleset from a path or inline YAML.
    Reload(context.Context, *ReloadRequest) (*ReloadResponse, error)
    // contains filtered or unexported methods
}

type FathomService\_SubscribeChangesClient

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FathomService_SubscribeChangesClient = grpc.ServerStreamingClient[FactChange]

type FathomService\_SubscribeChangesServer

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FathomService_SubscribeChangesServer = grpc.ServerStreamingServer[FactChange]

type QueryRequest

type QueryRequest struct {
    SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    Template  string `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
    // Optional JSON-encoded filter (e.g. {"agent_id": "a1"}).
    FilterJson string `protobuf:"bytes,3,opt,name=filter_json,json=filterJson,proto3" json:"filter_json,omitempty"`
    // contains filtered or unexported fields
}

func (*QueryRequest) Descriptor

func (*QueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetFilterJson

func (x *QueryRequest) GetFilterJson() string

func (*QueryRequest) GetSessionId

func (x *QueryRequest) GetSessionId() string

func (*QueryRequest) GetTemplate

func (x *QueryRequest) GetTemplate() string

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset

func (x *QueryRequest) Reset()

func (*QueryRequest) String

func (x *QueryRequest) String() string

type QueryResponse

type QueryResponse struct {

    // Each entry is a JSON-encoded dict representing one fact.
    FactsJson []string `protobuf:"bytes,1,rep,name=facts_json,json=factsJson,proto3" json:"facts_json,omitempty"`
    // contains filtered or unexported fields
}

func (*QueryResponse) Descriptor

func (*QueryResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetFactsJson

func (x *QueryResponse) GetFactsJson() []string

func (*QueryResponse) ProtoMessage

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect

func (x *QueryResponse) ProtoReflect() protoreflect.Message

func (*QueryResponse) Reset

func (x *QueryResponse) Reset()

func (*QueryResponse) String

func (x *QueryResponse) String() string

type ReloadRequest

type ReloadRequest struct {

    // Types that are valid to be assigned to Source:
    //
    //  *ReloadRequest_RulesetPath
    //  *ReloadRequest_RulesetYaml
    Source    isReloadRequest_Source `protobuf_oneof:"source"`
    Signature []byte                 `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
    // contains filtered or unexported fields
}

func (*ReloadRequest) Descriptor

func (*ReloadRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReloadRequest.ProtoReflect.Descriptor instead.

func (*ReloadRequest) GetRulesetPath

func (x *ReloadRequest) GetRulesetPath() string

func (*ReloadRequest) GetRulesetYaml

func (x *ReloadRequest) GetRulesetYaml() string

func (*ReloadRequest) GetSignature

func (x *ReloadRequest) GetSignature() []byte

func (*ReloadRequest) GetSource

func (x *ReloadRequest) GetSource() isReloadRequest_Source

func (*ReloadRequest) ProtoMessage

func (*ReloadRequest) ProtoMessage()

func (*ReloadRequest) ProtoReflect

func (x *ReloadRequest) ProtoReflect() protoreflect.Message

func (*ReloadRequest) Reset

func (x *ReloadRequest) Reset()

func (*ReloadRequest) String

func (x *ReloadRequest) String() string

type ReloadRequest\_RulesetPath

type ReloadRequest_RulesetPath struct {
    RulesetPath string `protobuf:"bytes,1,opt,name=ruleset_path,json=rulesetPath,proto3,oneof"`
}

type ReloadRequest\_RulesetYaml

type ReloadRequest_RulesetYaml struct {
    RulesetYaml string `protobuf:"bytes,2,opt,name=ruleset_yaml,json=rulesetYaml,proto3,oneof"`
}

type ReloadResponse

type ReloadResponse struct {
    RulesetHashBefore string `protobuf:"bytes,1,opt,name=ruleset_hash_before,json=rulesetHashBefore,proto3" json:"ruleset_hash_before,omitempty"`
    RulesetHashAfter  string `protobuf:"bytes,2,opt,name=ruleset_hash_after,json=rulesetHashAfter,proto3" json:"ruleset_hash_after,omitempty"`
    AttestationToken  string `protobuf:"bytes,3,opt,name=attestation_token,json=attestationToken,proto3" json:"attestation_token,omitempty"`
    // contains filtered or unexported fields
}

func (*ReloadResponse) Descriptor

func (*ReloadResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReloadResponse.ProtoReflect.Descriptor instead.

func (*ReloadResponse) GetAttestationToken

func (x *ReloadResponse) GetAttestationToken() string

func (*ReloadResponse) GetRulesetHashAfter

func (x *ReloadResponse) GetRulesetHashAfter() string

func (*ReloadResponse) GetRulesetHashBefore

func (x *ReloadResponse) GetRulesetHashBefore() string

func (*ReloadResponse) ProtoMessage

func (*ReloadResponse) ProtoMessage()

func (*ReloadResponse) ProtoReflect

func (x *ReloadResponse) ProtoReflect() protoreflect.Message

func (*ReloadResponse) Reset

func (x *ReloadResponse) Reset()

func (*ReloadResponse) String

func (x *ReloadResponse) String() string

type RetractRequest

type RetractRequest struct {
    SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    Template  string `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
    // Optional JSON-encoded filter.
    FilterJson string `protobuf:"bytes,3,opt,name=filter_json,json=filterJson,proto3" json:"filter_json,omitempty"`
    // contains filtered or unexported fields
}

func (*RetractRequest) Descriptor

func (*RetractRequest) Descriptor() ([]byte, []int)

Deprecated: Use RetractRequest.ProtoReflect.Descriptor instead.

func (*RetractRequest) GetFilterJson

func (x *RetractRequest) GetFilterJson() string

func (*RetractRequest) GetSessionId

func (x *RetractRequest) GetSessionId() string

func (*RetractRequest) GetTemplate

func (x *RetractRequest) GetTemplate() string

func (*RetractRequest) ProtoMessage

func (*RetractRequest) ProtoMessage()

func (*RetractRequest) ProtoReflect

func (x *RetractRequest) ProtoReflect() protoreflect.Message

func (*RetractRequest) Reset

func (x *RetractRequest) Reset()

func (*RetractRequest) String

func (x *RetractRequest) String() string

type RetractResponse

type RetractResponse struct {
    RetractedCount int32 `protobuf:"varint,1,opt,name=retracted_count,json=retractedCount,proto3" json:"retracted_count,omitempty"`
    // contains filtered or unexported fields
}

func (*RetractResponse) Descriptor

func (*RetractResponse) Descriptor() ([]byte, []int)

Deprecated: Use RetractResponse.ProtoReflect.Descriptor instead.

func (*RetractResponse) GetRetractedCount

func (x *RetractResponse) GetRetractedCount() int32

func (*RetractResponse) ProtoMessage

func (*RetractResponse) ProtoMessage()

func (*RetractResponse) ProtoReflect

func (x *RetractResponse) ProtoReflect() protoreflect.Message

func (*RetractResponse) Reset

func (x *RetractResponse) Reset()

func (*RetractResponse) String

func (x *RetractResponse) String() string

type SubscribeRequest

type SubscribeRequest struct {
    SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    // contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor

func (*SubscribeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetSessionId

func (x *SubscribeRequest) GetSessionId() string

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (x *SubscribeRequest) String() string

type UnimplementedFathomServiceServer

UnimplementedFathomServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

type UnimplementedFathomServiceServer struct{}

func (UnimplementedFathomServiceServer) AssertFact

func (UnimplementedFathomServiceServer) AssertFact(context.Context, *AssertFactRequest) (*AssertFactResponse, error)

func (UnimplementedFathomServiceServer) Evaluate

func (UnimplementedFathomServiceServer) Evaluate(context.Context, *EvaluateRequest) (*EvaluateResponse, error)

func (UnimplementedFathomServiceServer) Query

func (UnimplementedFathomServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedFathomServiceServer) Reload

func (UnimplementedFathomServiceServer) Reload(context.Context, *ReloadRequest) (*ReloadResponse, error)

func (UnimplementedFathomServiceServer) Retract

func (UnimplementedFathomServiceServer) Retract(context.Context, *RetractRequest) (*RetractResponse, error)

func (UnimplementedFathomServiceServer) SubscribeChanges

func (UnimplementedFathomServiceServer) SubscribeChanges(*SubscribeRequest, grpc.ServerStreamingServer[FactChange]) error

type UnsafeFathomServiceServer

UnsafeFathomServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FathomServiceServer will result in compilation errors.

type UnsafeFathomServiceServer interface {
    // contains filtered or unexported methods
}

Generated by gomarkdoc