chatmessagehistory

Documentation

Index

• type DynamoDB
  • func NewDynamoDB(client DynamoDBClient, tableName, sessionID string) *DynamoDB
  • func (mh *DynamoDB) AddAIMessage(text string) error
  • func (mh *DynamoDB) AddMessage(message schema.ChatMessage) error
  • func (mh *DynamoDB) AddUserMessage(text string) error
  • func (mh *DynamoDB) Clear() error
  • func (mh *DynamoDB) Messages() (schema.ChatMessages, error)
• type DynamoDBClient
• type InMemory
  • func NewInMemory() *InMemory
  • func NewInMemoryWithMessages(messages schema.ChatMessages) *InMemory
  • func (mh *InMemory) AddAIMessage(text string) error
  • func (mh *InMemory) AddMessage(message schema.ChatMessage) error
  • func (mh *InMemory) AddUserMessage(text string) error
  • func (mh *InMemory) Clear() error
  • func (mh *InMemory) Messages() (schema.ChatMessages, error)
• type Redis
  • func NewRedis(redisClient RedisClient, sessionID string) *Redis
  • func (mh *Redis) AddAIMessage(text string) error
  • func (mh *Redis) AddMessage(message schema.ChatMessage) error
  • func (mh *Redis) AddUserMessage(text string) error
  • func (mh *Redis) Clear() error
  • func (mh *Redis) Messages() (schema.ChatMessages, error)
• type RedisClient
• type RedisOptions

Types

type DynamoDB

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

func NewDynamoDB

func NewDynamoDB(client DynamoDBClient, tableName, sessionID string) *DynamoDB

func (*DynamoDB) AddAIMessage

func (mh *DynamoDB) AddAIMessage(text string) error

func (*DynamoDB) AddMessage

func (mh *DynamoDB) AddMessage(message schema.ChatMessage) error

func (*DynamoDB) AddUserMessage

func (mh *DynamoDB) AddUserMessage(text string) error

func (*DynamoDB) Clear

func (mh *DynamoDB) Clear() error

func (*DynamoDB) Messages

func (mh *DynamoDB) Messages() (schema.ChatMessages, error)

type DynamoDBClient

type DynamoDBClient interface {
	GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)
	PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
	DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)
}

type InMemory

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

func NewInMemory

func NewInMemory() *InMemory

func NewInMemoryWithMessages

func NewInMemoryWithMessages(messages schema.ChatMessages) *InMemory

func (*InMemory) AddAIMessage

func (mh *InMemory) AddAIMessage(text string) error

func (*InMemory) AddMessage

func (mh *InMemory) AddMessage(message schema.ChatMessage) error

func (*InMemory) AddUserMessage

func (mh *InMemory) AddUserMessage(text string) error

func (*InMemory) Clear

func (mh *InMemory) Clear() error

func (*InMemory) Messages

func (mh *InMemory) Messages() (schema.ChatMessages, error)

type Redis

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

func NewRedis

func NewRedis(redisClient RedisClient, sessionID string) *Redis

func (*Redis) AddAIMessage

func (mh *Redis) AddAIMessage(text string) error

func (*Redis) AddMessage

func (mh *Redis) AddMessage(message schema.ChatMessage) error

func (*Redis) AddUserMessage

func (mh *Redis) AddUserMessage(text string) error

func (*Redis) Clear

func (mh *Redis) Clear() error

func (*Redis) Messages

func (mh *Redis) Messages() (schema.ChatMessages, error)

type RedisClient

type RedisClient interface {
	LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd
	LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd
	Del(ctx context.Context, keys ...string) *redis.IntCmd
	Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
}

type RedisOptions

type RedisOptions struct {
	KeyPrefix string
	TTL       *time.Duration
}