fake

Documentation

Index

• type Fake
  • func New() *Fake
  • func (f *Fake) Engine(ctx context.Context) (engine.Interface, error)
  • func (f *Fake) Init(opts actors.InitOptions) error
  • func (f *Fake) RegisterHosted(cfg hostconfig.Config) error
  • func (f *Fake) Reminders(ctx context.Context) (reminders.Interface, error)
  • func (f *Fake) Run(ctx context.Context) error
  • func (f *Fake) RuntimeStatus() *runtimev1pb.ActorRuntime
  • func (f *Fake) State(ctx context.Context) (state.Interface, error)
  • func (f *Fake) Table(ctx context.Context) (table.Interface, error)
  • func (f *Fake) Timers(ctx context.Context) (timers.Interface, error)
  • func (f *Fake) UnRegisterHosted(ids ...string)
  • func (f *Fake) WaitForRegisteredHosts(ctx context.Context) error
  • func (f *Fake) WithEngine(fn func(context.Context) (engine.Interface, error)) *Fake
  • func (f *Fake) WithInit(fn func(actors.InitOptions) error) *Fake
  • func (f *Fake) WithRegisterHosted(fn func(hostconfig.Config) error) *Fake
  • func (f *Fake) WithReminders(fn func(context.Context) (reminders.Interface, error)) *Fake
  • func (f *Fake) WithRun(fn func(context.Context) error) *Fake
  • func (f *Fake) WithRuntimeStatus(fn func() *runtimev1pb.ActorRuntime) *Fake
  • func (f *Fake) WithState(fn func(context.Context) (state.Interface, error)) *Fake
  • func (f *Fake) WithTable(fn func(context.Context) (table.Interface, error)) *Fake
  • func (f *Fake) WithTimers(fn func(context.Context) (timers.Interface, error)) *Fake
  • func (f *Fake) WithUnRegisterHosted(fn func(...string)) *Fake
  • func (f *Fake) WithWaitForRegisteredHosts(fn func(context.Context) error) *Fake

Types

type Fake

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

func New

func New() *Fake

func (*Fake) Engine

func (f *Fake) Engine(ctx context.Context) (engine.Interface, error)

func (*Fake) Init

func (f *Fake) Init(opts actors.InitOptions) error

func (*Fake) RegisterHosted

func (f *Fake) RegisterHosted(cfg hostconfig.Config) error

func (*Fake) Reminders

func (f *Fake) Reminders(ctx context.Context) (reminders.Interface, error)

func (*Fake) Run

func (f *Fake) Run(ctx context.Context) error

func (*Fake) RuntimeStatus

func (f *Fake) RuntimeStatus() *runtimev1pb.ActorRuntime

func (*Fake) State

func (f *Fake) State(ctx context.Context) (state.Interface, error)

func (*Fake) Table

func (f *Fake) Table(ctx context.Context) (table.Interface, error)

func (*Fake) Timers

func (f *Fake) Timers(ctx context.Context) (timers.Interface, error)

func (*Fake) UnRegisterHosted

func (f *Fake) UnRegisterHosted(ids ...string)

func (*Fake) WaitForRegisteredHosts

func (f *Fake) WaitForRegisteredHosts(ctx context.Context) error

func (*Fake) WithEngine

func (f *Fake) WithEngine(fn func(context.Context) (engine.Interface, error)) *Fake

func (*Fake) WithInit

func (f *Fake) WithInit(fn func(actors.InitOptions) error) *Fake

func (*Fake) WithRegisterHosted

func (f *Fake) WithRegisterHosted(fn func(hostconfig.Config) error) *Fake

func (*Fake) WithReminders

func (f *Fake) WithReminders(fn func(context.Context) (reminders.Interface, error)) *Fake

func (*Fake) WithRun

func (f *Fake) WithRun(fn func(context.Context) error) *Fake

func (*Fake) WithRuntimeStatus

func (f *Fake) WithRuntimeStatus(fn func() *runtimev1pb.ActorRuntime) *Fake

func (*Fake) WithState

func (f *Fake) WithState(fn func(context.Context) (state.Interface, error)) *Fake

func (*Fake) WithTable

func (f *Fake) WithTable(fn func(context.Context) (table.Interface, error)) *Fake

func (*Fake) WithTimers

func (f *Fake) WithTimers(fn func(context.Context) (timers.Interface, error)) *Fake

func (*Fake) WithUnRegisterHosted

func (f *Fake) WithUnRegisterHosted(fn func(...string)) *Fake

func (*Fake) WithWaitForRegisteredHosts

func (f *Fake) WithWaitForRegisteredHosts(fn func(context.Context) error) *Fake