stateful_bun

Documentation

Index

• Variables
• func NewSingleStateRepository(configurations ...runtime.Configuration[SingleStateRepository]) stateful.SingleStateRepository
• func TableToState(dbState *SingleStateTable) (stateful.SingleState[message.Bytes], error)
• func WithSingleStateRepositoryConnection(connection runtime_bun.BunConnection) runtime.Configuration[SingleStateRepository]
• func WithSingleStateRepositoryPersistenceTableName(persistenceTableName string) runtime.Configuration[SingleStateRepository]
• type SingleStateRepository
  • func (r SingleStateRepository) Get(ctx context.Context, persistenceId string) (stateful.SingleState[message.Bytes], error)
  • func (r SingleStateRepository) Upsert(ctx context.Context, persistenceId string, ...) error
• type SingleStateTable
  • func StateToTable(nextState stateful.SingleState[message.Bytes]) (*SingleStateTable, error)

Variables

var InternalStateProtoFormat = format.Protobuf[*protobuf.State]()

var ResultsStateProtoFormat = format.Protobuf[*protobuf.Results]()

Functions

func NewSingleStateRepository

func NewSingleStateRepository(configurations ...runtime.Configuration[SingleStateRepository]) stateful.SingleStateRepository

constructor

func TableToState

func TableToState(dbState *SingleStateTable) (stateful.SingleState[message.Bytes], error)

func WithSingleStateRepositoryConnection

func WithSingleStateRepositoryConnection(connection runtime_bun.BunConnection) runtime.Configuration[SingleStateRepository]

configuration

func WithSingleStateRepositoryPersistenceTableName

func WithSingleStateRepositoryPersistenceTableName(persistenceTableName string) runtime.Configuration[SingleStateRepository]

Types

type SingleStateRepository

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

implementation

func (SingleStateRepository) Get

func (r SingleStateRepository) Get(ctx context.Context, persistenceId string) (stateful.SingleState[message.Bytes], error)

func (SingleStateRepository) Upsert

func (r SingleStateRepository) Upsert(ctx context.Context, persistenceId string, s stateful.SingleState[message.Bytes]) error

type SingleStateTable

type SingleStateTable struct {
	PersistenceId      string `bun:",pk"`
	Internal           []byte
	Results            []byte
	Content            []byte
	CreatedTimestampMs int64
	UpdatedTimestampMs int64
}

func StateToTable

func StateToTable(nextState stateful.SingleState[message.Bytes]) (*SingleStateTable, error)