statestore

Documentation

Index

• type ActorMetadata
• type ActorReminderReference
• type ActorRemindersMetadata
• type Options
• type Statestore
  • func New(opts Options) *Statestore
  • func (r *Statestore) Close() error
  • func (r *Statestore) Create(ctx context.Context, req *api.CreateReminderRequest) error
  • func (r *Statestore) Delete(ctx context.Context, req *api.DeleteReminderRequest) error
  • func (r *Statestore) DrainRebalancedReminders()
  • func (r *Statestore) Get(ctx context.Context, req *api.GetReminderRequest) (*api.Reminder, error)
  • func (r *Statestore) List(ctx context.Context, req *api.ListRemindersRequest) ([]*api.Reminder, error)
  • func (r *Statestore) OnPlacementTablesUpdated(ctx context.Context, fn func(context.Context, *api.LookupActorRequest) bool)
  • func (r *Statestore) SetEngine(engine engine.Interface)
  • func (r *Statestore) SetEntityConfigsRemindersStoragePartitions(entityConfigs map[string]api.EntityConfig, remindersStoragePartitions int)

Types

type ActorMetadata

type ActorMetadata struct {
	ID                string                 `json:"id"`
	RemindersMetadata ActorRemindersMetadata `json:"actorRemindersMetadata"`
	Etag              *string                `json:"-"`
}

ActorMetadata represents information about the actor type.

type ActorReminderReference

type ActorReminderReference struct {
	ActorMetadataID           string
	ActorRemindersPartitionID uint32
	Reminder                  api.Reminder
}

type ActorRemindersMetadata

type ActorRemindersMetadata struct {
	PartitionCount int                `json:"partitionCount"`
	PartitionsEtag map[uint32]*string `json:"-"`
}

ActorRemindersMetadata represents information about actor's reminders.

type Options

type Options struct {
	StateStore actorstate.Backend
	Resiliency resiliency.Provider
	Table      table.Interface
	StoreName  string
	APILevel   *apilevel.APILevel
}

type Statestore

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

func New

func New(opts Options) *Statestore

New returns a reminders provider.

func (*Statestore) Close

func (r *Statestore) Close() error

func (*Statestore) Create

func (r *Statestore) Create(ctx context.Context, req *api.CreateReminderRequest) error

func (*Statestore) Delete

func (r *Statestore) Delete(ctx context.Context, req *api.DeleteReminderRequest) error

func (*Statestore) DrainRebalancedReminders

func (r *Statestore) DrainRebalancedReminders()

func (*Statestore) Get

func (r *Statestore) Get(ctx context.Context, req *api.GetReminderRequest) (*api.Reminder, error)

func (*Statestore) List

func (r *Statestore) List(ctx context.Context, req *api.ListRemindersRequest) ([]*api.Reminder, error)

func (*Statestore) OnPlacementTablesUpdated

func (r *Statestore) OnPlacementTablesUpdated(ctx context.Context, fn func(context.Context, *api.LookupActorRequest) bool)

OnPlacementTablesUpdated is invoked when the actors runtime received an updated placement tables.

func (*Statestore) SetEngine

func (r *Statestore) SetEngine(engine engine.Interface)

TODO: :( Statestore option will be removed completely in v1.16

func (*Statestore) SetEntityConfigsRemindersStoragePartitions

func (r *Statestore) SetEntityConfigsRemindersStoragePartitions(entityConfigs map[string]api.EntityConfig, remindersStoragePartitions int)

TODO: :( Statestore option will be removed completely in v1.16