store

Documentation

Index

• func InitConversationStoreHandlers(api huma.API, conversationStoreAPI *ConversationCollection)
• func NewFTSListner(e *ftsengine.Engine) mapstore.FileListener
• type ConversationCollection
  • func NewConversationCollection(baseDir string, opts ...Option) (*ConversationCollection, error)
  • func (cc *ConversationCollection) Close() (err error)
  • func (cc *ConversationCollection) DeleteConversation(ctx context.Context, req *spec.DeleteConversationRequest) (*spec.DeleteConversationResponse, error)
  • func (cc *ConversationCollection) GetConversation(ctx context.Context, req *spec.GetConversationRequest) (*spec.GetConversationResponse, error)
  • func (cc *ConversationCollection) ListConversations(ctx context.Context, req *spec.ListConversationsRequest) (*spec.ListConversationsResponse, error)
  • func (cc *ConversationCollection) PutConversation(ctx context.Context, req *spec.PutConversationRequest) (*spec.PutConversationResponse, error)
  • func (cc *ConversationCollection) PutMessagesToConversation(ctx context.Context, req *spec.PutMessagesToConversationRequest) (*spec.PutMessagesToConversationResponse, error)
  • func (cc *ConversationCollection) SearchConversations(ctx context.Context, req *spec.SearchConversationsRequest) (*spec.SearchConversationsResponse, error)
• type Option
  • func WithFTS(enabled bool) Option
  • func WithPartitionProvider(pp mapstore.PartitionProvider) Option

Functions

func InitConversationStoreHandlers

func InitConversationStoreHandlers(api huma.API, conversationStoreAPI *ConversationCollection)

func NewFTSListner

func NewFTSListner(e *ftsengine.Engine) mapstore.FileListener

Types

type ConversationCollection

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

func NewConversationCollection

func NewConversationCollection(baseDir string, opts ...Option) (*ConversationCollection, error)

NewConversationCollection creates a collection with sensible defaults (UUID-v7 file names under yyyyMM partitions). Callers may override either strategy via the Option functions above.

baseDir is the root directory for the map-directory store.

func (*ConversationCollection) Close

func (cc *ConversationCollection) Close() (err error)

Close releases resources.

func (*ConversationCollection) DeleteConversation

func (cc *ConversationCollection) DeleteConversation(
	ctx context.Context,
	req *spec.DeleteConversationRequest,
) (*spec.DeleteConversationResponse, error)

func (*ConversationCollection) GetConversation

func (cc *ConversationCollection) GetConversation(
	ctx context.Context,
	req *spec.GetConversationRequest,
) (*spec.GetConversationResponse, error)

func (*ConversationCollection) ListConversations

func (cc *ConversationCollection) ListConversations(
	ctx context.Context,
	req *spec.ListConversationsRequest,
) (*spec.ListConversationsResponse, error)

func (*ConversationCollection) PutConversation

func (cc *ConversationCollection) PutConversation(
	ctx context.Context,
	req *spec.PutConversationRequest,
) (*spec.PutConversationResponse, error)

func (*ConversationCollection) PutMessagesToConversation

func (cc *ConversationCollection) PutMessagesToConversation(
	ctx context.Context,
	req *spec.PutMessagesToConversationRequest,
) (*spec.PutMessagesToConversationResponse, error)

func (*ConversationCollection) SearchConversations

func (cc *ConversationCollection) SearchConversations(
	ctx context.Context,
	req *spec.SearchConversationsRequest,
) (*spec.SearchConversationsResponse, error)

type Option

type Option func(*ConversationCollection) error

func WithFTS

func WithFTS(enabled bool) Option

func WithPartitionProvider

func WithPartitionProvider(pp mapstore.PartitionProvider) Option