testkitmodule

Sep 16, 2026

Changes in this version

+ var File_internal_tool_testing_flowtest_testkitmodule_params_proto protoreflect.FileDescriptor

+ func New(validator protovalidate.Validator, store LedgerStore) pkg_autoflow.Module

+ type CounterParams struct

+ Key *string

+ func (*CounterParams) Descriptor() ([]byte, []int)

+ func (*CounterParams) ProtoMessage()

+ func (x *CounterParams) GetKey() string

+ func (x *CounterParams) ProtoReflect() protoreflect.Message

+ func (x *CounterParams) Reset()

+ func (x *CounterParams) String() string

+ type DelayParams struct

+ Ms *int64

+ func (*DelayParams) Descriptor() ([]byte, []int)

+ func (*DelayParams) ProtoMessage()

+ func (x *DelayParams) GetMs() int64

+ func (x *DelayParams) ProtoReflect() protoreflect.Message

+ func (x *DelayParams) Reset()

+ func (x *DelayParams) String() string

+ type EchoParams struct

+ Value *v19.Value

+ func (*EchoParams) Descriptor() ([]byte, []int)

+ func (*EchoParams) ProtoMessage()

+ func (x *EchoParams) GetValue() *v19.Value

+ func (x *EchoParams) ProtoReflect() protoreflect.Message

+ func (x *EchoParams) Reset()

+ func (x *EchoParams) String() string

+ type LedgerStore interface

+ IncrementCounter func(ctx context.Context, key string) (int64, error)

+ RecordToken func(ctx context.Context, sessionID uuid.UUID, token string) error

+ type RecordParams struct

+ Token *string

+ func (*RecordParams) Descriptor() ([]byte, []int)

+ func (*RecordParams) ProtoMessage()

+ func (x *RecordParams) GetToken() string

+ func (x *RecordParams) ProtoReflect() protoreflect.Message

+ func (x *RecordParams) Reset()

+ func (x *RecordParams) String() string