stateful_batch_state

Documentation

Index

• Variables
• func New(next stateful.SingleFunction, ...) stateless.BatchFunction

Variables

var (
	ErrBatchReadWrite = errors.New("batch read write")
	ErrPersistenceId  = errors.New("persistence id")
	ErrStateGet       = errors.New("state get")
)

Functions

func New

func New(
	next stateful.SingleFunction,
	keyfn stateful.PersistenceIdFunction[structure.Bytes, structure.Bytes],
	repo stateful.Repository,
) stateless.BatchFunction