fake

Documentation

Index

• type FakeRemindersProvider
  • func NewRemindersProvider() *FakeRemindersProvider
  • func (f *FakeRemindersProvider) Close() error
  • func (f *FakeRemindersProvider) CreateReminder(ctx context.Context, req *internal.CreateReminderRequest) error
  • func (f *FakeRemindersProvider) DeleteReminder(ctx context.Context, req internal.DeleteReminderRequest) error
  • func (f *FakeRemindersProvider) DrainRebalancedReminders(actorType string, actorID string)
  • func (f *FakeRemindersProvider) GetReminder(ctx context.Context, req *internal.GetReminderRequest) (*internal.Reminder, error)
  • func (f *FakeRemindersProvider) Init(ctx context.Context) error
  • func (f *FakeRemindersProvider) ListReminders(ctx context.Context, req internal.ListRemindersRequest) ([]*internal.Reminder, error)
  • func (f *FakeRemindersProvider) OnPlacementTablesUpdated(ctx context.Context)
  • func (f *FakeRemindersProvider) SetExecuteReminderFn(fn internal.ExecuteReminderFn)
  • func (f *FakeRemindersProvider) SetLookupActorFn(fn internal.LookupActorFn)
  • func (f *FakeRemindersProvider) SetStateStoreProviderFn(fn internal.StateStoreProviderFn)
  • func (f *FakeRemindersProvider) WithCreateReminder(fn func(ctx context.Context, req *internal.CreateReminderRequest) error) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithDeleteReminder(fn func(ctx context.Context, req internal.DeleteReminderRequest) error) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithDrainRebalancedReminders(fn func(actorType string, actorID string)) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithGetReminder(...) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithInit(fn func(ctx context.Context) error) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithListReminders(...) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithOnPlacementTablesUpdated(fn func(ctx context.Context)) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithSetExecuteReminder(fn func(fn internal.ExecuteReminderFn)) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithSetLookupActor(fn func(fn internal.LookupActorFn)) *FakeRemindersProvider
  • func (f *FakeRemindersProvider) WithSetStateStoreProvider(fn func(fn internal.StateStoreProviderFn)) *FakeRemindersProvider

Types

type FakeRemindersProvider

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

func NewRemindersProvider

func NewRemindersProvider() *FakeRemindersProvider

func (*FakeRemindersProvider) Close

func (f *FakeRemindersProvider) Close() error

func (*FakeRemindersProvider) CreateReminder

func (f *FakeRemindersProvider) CreateReminder(ctx context.Context, req *internal.CreateReminderRequest) error

func (*FakeRemindersProvider) DeleteReminder

func (f *FakeRemindersProvider) DeleteReminder(ctx context.Context, req internal.DeleteReminderRequest) error

func (*FakeRemindersProvider) DrainRebalancedReminders

func (f *FakeRemindersProvider) DrainRebalancedReminders(actorType string, actorID string)

func (*FakeRemindersProvider) GetReminder

func (f *FakeRemindersProvider) GetReminder(ctx context.Context, req *internal.GetReminderRequest) (*internal.Reminder, error)

func (*FakeRemindersProvider) Init

func (f *FakeRemindersProvider) Init(ctx context.Context) error

func (*FakeRemindersProvider) ListReminders

func (f *FakeRemindersProvider) ListReminders(ctx context.Context, req internal.ListRemindersRequest) ([]*internal.Reminder, error)

func (*FakeRemindersProvider) OnPlacementTablesUpdated

func (f *FakeRemindersProvider) OnPlacementTablesUpdated(ctx context.Context)

func (*FakeRemindersProvider) SetExecuteReminderFn

func (f *FakeRemindersProvider) SetExecuteReminderFn(fn internal.ExecuteReminderFn)

func (*FakeRemindersProvider) SetLookupActorFn

func (f *FakeRemindersProvider) SetLookupActorFn(fn internal.LookupActorFn)

func (*FakeRemindersProvider) SetStateStoreProviderFn

func (f *FakeRemindersProvider) SetStateStoreProviderFn(fn internal.StateStoreProviderFn)

func (*FakeRemindersProvider) WithCreateReminder

func (f *FakeRemindersProvider) WithCreateReminder(fn func(ctx context.Context, req *internal.CreateReminderRequest) error) *FakeRemindersProvider

func (*FakeRemindersProvider) WithDeleteReminder

func (f *FakeRemindersProvider) WithDeleteReminder(fn func(ctx context.Context, req internal.DeleteReminderRequest) error) *FakeRemindersProvider

func (*FakeRemindersProvider) WithDrainRebalancedReminders

func (f *FakeRemindersProvider) WithDrainRebalancedReminders(fn func(actorType string, actorID string)) *FakeRemindersProvider

func (*FakeRemindersProvider) WithGetReminder

func (f *FakeRemindersProvider) WithGetReminder(fn func(ctx context.Context, req *internal.GetReminderRequest) (*internal.Reminder, error)) *FakeRemindersProvider

func (*FakeRemindersProvider) WithInit

func (f *FakeRemindersProvider) WithInit(fn func(ctx context.Context) error) *FakeRemindersProvider

func (*FakeRemindersProvider) WithListReminders

func (f *FakeRemindersProvider) WithListReminders(fn func(ctx context.Context, req internal.ListRemindersRequest) ([]*internal.Reminder, error)) *FakeRemindersProvider

func (*FakeRemindersProvider) WithOnPlacementTablesUpdated

func (f *FakeRemindersProvider) WithOnPlacementTablesUpdated(fn func(ctx context.Context)) *FakeRemindersProvider

func (*FakeRemindersProvider) WithSetExecuteReminder

func (f *FakeRemindersProvider) WithSetExecuteReminder(fn func(fn internal.ExecuteReminderFn)) *FakeRemindersProvider

func (*FakeRemindersProvider) WithSetLookupActor

func (f *FakeRemindersProvider) WithSetLookupActor(fn func(fn internal.LookupActorFn)) *FakeRemindersProvider

func (*FakeRemindersProvider) WithSetStateStoreProvider

func (f *FakeRemindersProvider) WithSetStateStoreProvider(fn func(fn internal.StateStoreProviderFn)) *FakeRemindersProvider