fake

Documentation

Index

• type Fake
  • func New() *Fake
  • func (f *Fake) AddOrUpdateOutbox(stateStore v1alpha1.Component)
  • func (f *Fake) Enabled(stateStore string) bool
  • func (f *Fake) PublishInternal(ctx context.Context, stateStore string, ...) ([]state.TransactionalStateOperation, error)
  • func (f *Fake) SubscribeToInternalTopics(ctx context.Context, appID string) error
  • func (f *Fake) WithAddOrUpdateOutbox(fn func(stateStore v1alpha1.Component)) *Fake
  • func (f *Fake) WithEnabled(fn func(stateStore string) bool) *Fake
  • func (f *Fake) WithPublishInternal(...) *Fake
  • func (f *Fake) WithSubscribeToInternalTopics(fn func(ctx context.Context, appID string) error) *Fake

Types

type Fake

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

func New

func New() *Fake

func (*Fake) AddOrUpdateOutbox

func (f *Fake) AddOrUpdateOutbox(stateStore v1alpha1.Component)

func (*Fake) Enabled

func (f *Fake) Enabled(stateStore string) bool

func (*Fake) PublishInternal

func (f *Fake) PublishInternal(ctx context.Context, stateStore string, states []state.TransactionalStateOperation, source, traceID, traceState string) ([]state.TransactionalStateOperation, error)

func (*Fake) SubscribeToInternalTopics

func (f *Fake) SubscribeToInternalTopics(ctx context.Context, appID string) error

func (*Fake) WithAddOrUpdateOutbox

func (f *Fake) WithAddOrUpdateOutbox(fn func(stateStore v1alpha1.Component)) *Fake

func (*Fake) WithEnabled

func (f *Fake) WithEnabled(fn func(stateStore string) bool) *Fake

func (*Fake) WithPublishInternal

func (f *Fake) WithPublishInternal(fn func(ctx context.Context, stateStore string, states []state.TransactionalStateOperation, source, traceID, traceState string) ([]state.TransactionalStateOperation, error)) *Fake

func (*Fake) WithSubscribeToInternalTopics

func (f *Fake) WithSubscribeToInternalTopics(fn func(ctx context.Context, appID string) error) *Fake