mysql

Documentation

Index

• type MysqlContextManager
  • func NewMysqlContextManager(host string, port int, username, password, dbname string) (*MysqlContextManager, error)
  • func (m *MysqlContextManager) Append(ctx context.Context, contextUID common.ContextUID, ...) error
  • func (m *MysqlContextManager) CommitFinal(ctx context.Context, contextUID common.ContextUID, ...) error
  • func (m *MysqlContextManager) CommitTurn(ctx context.Context, contextUID common.ContextUID, ...) (*contextmgr.TurnCommitResult, error)
  • func (m *MysqlContextManager) Delete(ctx context.Context, contextUID common.ContextUID) error
  • func (m *MysqlContextManager) EnqueuePendingMessages(ctx context.Context, contextUID common.ContextUID, ...) error
  • func (m *MysqlContextManager) GetAll(ctx context.Context, contextUID common.ContextUID) []*schema.AgenticMessage
  • func (m *MysqlContextManager) InitNew(ctx context.Context) common.ContextUID
  • func (m *MysqlContextManager) Len(ctx context.Context, contextUID common.ContextUID) int
  • func (m *MysqlContextManager) NewContextUID(_ context.Context) common.ContextUID
  • func (m *MysqlContextManager) Reset(ctx context.Context, contextUID common.ContextUID, ...)

Types

type MysqlContextManager

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

MysqlContextManager manages conversation context using MySQL through GORM.

func NewMysqlContextManager

func NewMysqlContextManager(host string, port int, username, password, dbname string) (*MysqlContextManager, error)

NewMysqlContextManager creates a MySQL-backed context manager and migrates its tables.

func (*MysqlContextManager) Append

func (m *MysqlContextManager) Append(ctx context.Context, contextUID common.ContextUID, message *schema.AgenticMessage) error

func (*MysqlContextManager) CommitFinal

func (m *MysqlContextManager) CommitFinal(
	ctx context.Context,
	contextUID common.ContextUID,
	message *schema.AgenticMessage,
) error

func (*MysqlContextManager) CommitTurn

func (m *MysqlContextManager) CommitTurn(
	ctx context.Context,
	contextUID common.ContextUID,
	turnMessages []*schema.AgenticMessage,
) (*contextmgr.TurnCommitResult, error)

func (*MysqlContextManager) Delete

func (m *MysqlContextManager) Delete(ctx context.Context, contextUID common.ContextUID) error

func (*MysqlContextManager) EnqueuePendingMessages

func (m *MysqlContextManager) EnqueuePendingMessages(
	ctx context.Context,
	contextUID common.ContextUID,
	messages []*schema.AgenticMessage,
) error

func (*MysqlContextManager) GetAll

func (m *MysqlContextManager) GetAll(ctx context.Context, contextUID common.ContextUID) []*schema.AgenticMessage

func (*MysqlContextManager) InitNew

func (m *MysqlContextManager) InitNew(ctx context.Context) common.ContextUID

func (*MysqlContextManager) Len

func (m *MysqlContextManager) Len(ctx context.Context, contextUID common.ContextUID) int

func (*MysqlContextManager) NewContextUID

func (m *MysqlContextManager) NewContextUID(_ context.Context) common.ContextUID

func (*MysqlContextManager) Reset

func (m *MysqlContextManager) Reset(ctx context.Context, contextUID common.ContextUID, messages []*schema.AgenticMessage)