grpc

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 22, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminCheckpointServer 

type AdminCheckpointServer struct {
	pb.UnimplementedAdminCheckpointServiceServer
	Store registrystore.MemoryStore
}

func (*AdminCheckpointServer) GetCheckpoint 

func (s *AdminCheckpointServer) GetCheckpoint(ctx context.Context, req *pb.GetCheckpointRequest) (*pb.AdminCheckpoint, error)

func (*AdminCheckpointServer) PutCheckpoint 

func (s *AdminCheckpointServer) PutCheckpoint(ctx context.Context, req *pb.PutCheckpointRequest) (*pb.AdminCheckpoint, error)

type AdminConversationsServer 

type AdminConversationsServer struct {
	pb.UnimplementedAdminConversationsServiceServer
	Store  registrystore.MemoryStore
	Config *config.Config
}

func (*AdminConversationsServer) GetConversation 

func (s *AdminConversationsServer) GetConversation(ctx context.Context, req *pb.AdminGetConversationRequest) (*pb.AdminConversation, error)

func (*AdminConversationsServer) ListChildConversations 

func (s *AdminConversationsServer) ListChildConversations(ctx context.Context, req *pb.AdminListChildConversationsRequest) (*pb.AdminListChildConversationsResponse, error)

func (*AdminConversationsServer) ListConversations 

func (s *AdminConversationsServer) ListConversations(ctx context.Context, req *pb.AdminListConversationsRequest) (*pb.AdminListConversationsResponse, error)

func (*AdminConversationsServer) ListForks 

func (s *AdminConversationsServer) ListForks(ctx context.Context, req *pb.AdminListForksRequest) (*pb.AdminListForksResponse, error)

func (*AdminConversationsServer) ListMemberships 

func (s *AdminConversationsServer) ListMemberships(ctx context.Context, req *pb.AdminListMembershipsRequest) (*pb.ListMembershipsResponse, error)

func (*AdminConversationsServer) UpdateConversation 

func (s *AdminConversationsServer) UpdateConversation(ctx context.Context, req *pb.AdminUpdateConversationRequest) (*pb.AdminConversation, error)

type AdminEntriesServer 

type AdminEntriesServer struct {
	pb.UnimplementedAdminEntriesServiceServer
	Store registrystore.MemoryStore
}

func (*AdminEntriesServer) GetEntry 

func (s *AdminEntriesServer) GetEntry(ctx context.Context, req *pb.AdminGetEntryRequest) (*pb.Entry, error)

func (*AdminEntriesServer) ListEntries 

func (s *AdminEntriesServer) ListEntries(ctx context.Context, req *pb.AdminListEntriesRequest) (*pb.ListEntriesResponse, error)

type AdminMemoriesServer 

type AdminMemoriesServer struct {
	pb.UnimplementedAdminMemoriesServiceServer
	Store    registryepisodic.EpisodicStore
	Policy   *episodic.PolicyEngine
	Config   *config.Config
	Embedder registryembed.Embedder
}

func (*AdminMemoriesServer) DeleteMemory 

func (s *AdminMemoriesServer) DeleteMemory(ctx context.Context, req *pb.AdminDeleteMemoryRequest) (*emptypb.Empty, error)

func (*AdminMemoriesServer) GetMemory 

func (s *AdminMemoriesServer) GetMemory(ctx context.Context, req *pb.AdminGetMemoryRequest) (*pb.AdminMemoryItem, error)

func (*AdminMemoriesServer) GetMemoryIndexStatus 

func (s *AdminMemoriesServer) GetMemoryIndexStatus(ctx context.Context, req *pb.AdminGetMemoryIndexStatusRequest) (*pb.MemoryIndexStatusResponse, error)

func (*AdminMemoriesServer) GetMemoryUsage 

func (s *AdminMemoriesServer) GetMemoryUsage(ctx context.Context, req *pb.AdminGetMemoryUsageRequest) (*pb.MemoryUsage, error)

func (*AdminMemoriesServer) ListMemories 

func (s *AdminMemoriesServer) ListMemories(ctx context.Context, req *pb.AdminListMemoriesRequest) (*pb.AdminListMemoriesResponse, error)

func (*AdminMemoriesServer) ListNamespaces 

func (s *AdminMemoriesServer) ListNamespaces(ctx context.Context, req *pb.AdminListMemoryNamespacesRequest) (*pb.AdminListMemoryNamespacesResponse, error)

func (*AdminMemoriesServer) ListTopMemoryUsage 

func (s *AdminMemoriesServer) ListTopMemoryUsage(ctx context.Context, req *pb.AdminListTopMemoryUsageRequest) (*pb.ListTopMemoryUsageResponse, error)

func (*AdminMemoriesServer) SearchMemories 

func (s *AdminMemoriesServer) SearchMemories(ctx context.Context, req *pb.AdminSearchMemoriesRequest) (*pb.AdminSearchMemoriesResponse, error)

type AttachmentsServer 

type AttachmentsServer struct {
	pb.UnimplementedAttachmentsServiceServer
	Store       registrystore.MemoryStore
	AttachStore registryattach.AttachmentStore
	MaxBodySize int64
	Config      *config.Config
}

func (*AttachmentsServer) DownloadAttachment 

func (s *AttachmentsServer) DownloadAttachment(req *pb.DownloadAttachmentRequest, stream pb.AttachmentsService_DownloadAttachmentServer) error

func (*AttachmentsServer) GetAttachment 

func (s *AttachmentsServer) GetAttachment(ctx context.Context, req *pb.GetAttachmentRequest) (*pb.AttachmentInfo, error)

func (*AttachmentsServer) UploadAttachment 

func (s *AttachmentsServer) UploadAttachment(stream pb.AttachmentsService_UploadAttachmentServer) error

type ConversationsServer 

type ConversationsServer struct {
	pb.UnimplementedConversationsServiceServer
	Store registrystore.MemoryStore
}

func (*ConversationsServer) CreateConversation 

func (s *ConversationsServer) CreateConversation(ctx context.Context, req *pb.CreateConversationRequest) (*pb.Conversation, error)

func (*ConversationsServer) GetConversation 

func (s *ConversationsServer) GetConversation(ctx context.Context, req *pb.GetConversationRequest) (*pb.Conversation, error)

func (*ConversationsServer) ListChildConversations 

func (s *ConversationsServer) ListChildConversations(ctx context.Context, req *pb.ListChildConversationsRequest) (*pb.ListChildConversationsResponse, error)

func (*ConversationsServer) ListConversations 

func (s *ConversationsServer) ListConversations(ctx context.Context, req *pb.ListConversationsRequest) (*pb.ListConversationsResponse, error)

func (*ConversationsServer) ListForks 

func (s *ConversationsServer) ListForks(ctx context.Context, req *pb.ListForksRequest) (*pb.ListForksResponse, error)

func (*ConversationsServer) UpdateConversation 

func (s *ConversationsServer) UpdateConversation(ctx context.Context, req *pb.UpdateConversationRequest) (*pb.Conversation, error)

type EntriesServer 

type EntriesServer struct {
	pb.UnimplementedEntriesServiceServer
	Store    registrystore.MemoryStore
	EventBus registryeventbus.EventBus
}

func (*EntriesServer) AppendEntry 

func (s *EntriesServer) AppendEntry(ctx context.Context, req *pb.AppendEntryRequest) (*pb.Entry, error)

func (*EntriesServer) ListEntries 

func (s *EntriesServer) ListEntries(ctx context.Context, req *pb.ListEntriesRequest) (*pb.ListEntriesResponse, error)

func (*EntriesServer) SyncEntries 

func (s *EntriesServer) SyncEntries(ctx context.Context, req *pb.SyncEntriesRequest) (*pb.SyncEntriesResponse, error)

type EventStreamServer 

type EventStreamServer struct {
	pb.UnimplementedEventStreamServiceServer
	Store    registrystore.MemoryStore
	EventBus registryeventbus.EventBus
	Config   *config.Config
}

func (*EventStreamServer) SubscribeEvents 

func (s *EventStreamServer) SubscribeEvents(req *pb.SubscribeEventsRequest, stream pb.EventStreamService_SubscribeEventsServer) error

type MembershipsServer 

type MembershipsServer struct {
	pb.UnimplementedConversationMembershipsServiceServer
	Store registrystore.MemoryStore
}

func (*MembershipsServer) DeleteMembership 

func (s *MembershipsServer) DeleteMembership(ctx context.Context, req *pb.DeleteMembershipRequest) (*emptypb.Empty, error)

func (*MembershipsServer) ListMemberships 

func (s *MembershipsServer) ListMemberships(ctx context.Context, req *pb.ListMembershipsRequest) (*pb.ListMembershipsResponse, error)

func (*MembershipsServer) ShareConversation 

func (s *MembershipsServer) ShareConversation(ctx context.Context, req *pb.ShareConversationRequest) (*pb.ConversationMembership, error)

func (*MembershipsServer) UpdateMembership 

func (s *MembershipsServer) UpdateMembership(ctx context.Context, req *pb.UpdateMembershipRequest) (*pb.ConversationMembership, error)

type MemoriesServer 

type MemoriesServer struct {
	pb.UnimplementedMemoriesServiceServer
	Store    registryepisodic.EpisodicStore
	Policy   *episodic.PolicyEngine
	Config   *config.Config
	Embedder registryembed.Embedder
}

func (*MemoriesServer) GetMemory 

func (s *MemoriesServer) GetMemory(ctx context.Context, req *pb.GetMemoryRequest) (*pb.MemoryItem, error)

func (*MemoriesServer) ListMemoryNamespaces 

func (s *MemoriesServer) ListMemoryNamespaces(ctx context.Context, req *pb.ListMemoryNamespacesRequest) (*pb.ListMemoryNamespacesResponse, error)

func (*MemoriesServer) PutMemory 

func (s *MemoriesServer) PutMemory(ctx context.Context, req *pb.PutMemoryRequest) (*pb.MemoryWriteResult, error)

func (*MemoriesServer) SearchMemories 

func (s *MemoriesServer) SearchMemories(ctx context.Context, req *pb.SearchMemoriesRequest) (*pb.SearchMemoriesResponse, error)

func (*MemoriesServer) UpdateMemory 

func (s *MemoriesServer) UpdateMemory(ctx context.Context, req *pb.UpdateMemoryRequest) (*emptypb.Empty, error)

type ResponseRecorderServer 

type ResponseRecorderServer struct {
	pb.UnimplementedResponseRecorderServiceServer
	Resumer  *internalresumer.Store
	Store    registrystore.MemoryStore
	Config   *config.Config
	Enabled  bool
	EventBus registryeventbus.EventBus
}

func (*ResponseRecorderServer) Cancel 

func (s *ResponseRecorderServer) Cancel(ctx context.Context, req *pb.CancelRecordRequest) (*pb.CancelRecordResponse, error)

func (*ResponseRecorderServer) CheckRecordings 

func (s *ResponseRecorderServer) CheckRecordings(ctx context.Context, req *pb.CheckRecordingsRequest) (*pb.CheckRecordingsResponse, error)

func (*ResponseRecorderServer) IsEnabled 

func (s *ResponseRecorderServer) IsEnabled(_ context.Context, _ *emptypb.Empty) (*pb.IsEnabledResponse, error)

func (*ResponseRecorderServer) Record 

func (s *ResponseRecorderServer) Record(stream pb.ResponseRecorderService_RecordServer) (retErr error)

func (*ResponseRecorderServer) Replay 

func (s *ResponseRecorderServer) Replay(req *pb.ReplayRequest, stream pb.ResponseRecorderService_ReplayServer) error

type SearchServer 

type SearchServer struct {
	pb.UnimplementedSearchServiceServer
	Store  registrystore.MemoryStore
	Config *config.Config
}

func (*SearchServer) IndexConversations 

func (s *SearchServer) IndexConversations(ctx context.Context, req *pb.IndexConversationsRequest) (*pb.IndexConversationsResponse, error)

func (*SearchServer) ListUnindexedEntries 

func (s *SearchServer) ListUnindexedEntries(ctx context.Context, req *pb.ListUnindexedEntriesRequest) (*pb.ListUnindexedEntriesResponse, error)

func (*SearchServer) SearchConversations 

func (s *SearchServer) SearchConversations(ctx context.Context, req *pb.SearchEntriesRequest) (*pb.SearchEntriesResponse, error)

type SystemServer 

type SystemServer struct {
	pb.UnimplementedSystemServiceServer
	Config *config.Config
}

func (*SystemServer) GetCapabilities 

func (s *SystemServer) GetCapabilities(ctx context.Context, _ *emptypb.Empty) (*pb.CapabilitiesResponse, error)

func (*SystemServer) GetHealth 

func (s *SystemServer) GetHealth(_ context.Context, _ *emptypb.Empty) (*pb.HealthResponse, error)

type TransfersServer 

type TransfersServer struct {
	pb.UnimplementedOwnershipTransfersServiceServer
	Store registrystore.MemoryStore
}

func (*TransfersServer) AcceptOwnershipTransfer 

func (s *TransfersServer) AcceptOwnershipTransfer(ctx context.Context, req *pb.AcceptOwnershipTransferRequest) (*emptypb.Empty, error)

func (*TransfersServer) CreateOwnershipTransfer 

func (s *TransfersServer) CreateOwnershipTransfer(ctx context.Context, req *pb.CreateOwnershipTransferRequest) (*pb.OwnershipTransfer, error)

func (*TransfersServer) DeleteOwnershipTransfer 

func (s *TransfersServer) DeleteOwnershipTransfer(ctx context.Context, req *pb.DeleteOwnershipTransferRequest) (*emptypb.Empty, error)

func (*TransfersServer) GetOwnershipTransfer 

func (s *TransfersServer) GetOwnershipTransfer(ctx context.Context, req *pb.GetOwnershipTransferRequest) (*pb.OwnershipTransfer, error)

func (*TransfersServer) ListOwnershipTransfers 

func (s *TransfersServer) ListOwnershipTransfers(ctx context.Context, req *pb.ListOwnershipTransfersRequest) (*pb.ListOwnershipTransfersResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.