stateful_mock

Documentation

Index

• Variables
• func MockOneToOne(ctx context.Context, m flow.Message[string, string], ss stateful.State[string]) (*flow.Message[string, string], stateful.State[string], error)
• func Repository() stateful.Repository

Variables

var (
	InputTopic       = flow.GenericTopic("input", format.Gengar(), format.Gengar())
	OutputTopic      = flow.GenericTopic("output", format.Gengar(), format.Gengar())
	EmptyTopic       = flow.GenericTopic("", format.Gengar(), format.Gengar())
	ErrMock          = errors.New("mock")
	ErrRecoverable   = errors.New("recoverable")
	ErrIrrecoverable = errors.New("irrrecoverable")
)

Functions

func MockOneToOne

func MockOneToOne(ctx context.Context, m flow.Message[string, string], ss stateful.State[string]) (*flow.Message[string, string], stateful.State[string], error)

func Repository

func Repository() stateful.Repository