store

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2026 License: MPL-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.0.79 

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

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.