state

package

v1.3.1 Latest Latest Go to latest Published: Jan 25, 2022 License: Apache-2.0 Imports: 8 Imported by: 1

Details

View Source

const (
	None   = ChangeKind("")
	Add    = ChangeKind("upsert")
	Update = ChangeKind("upsert")
	Remove = ChangeKind("delete")
)

This section is empty.

func NewActorStateManager(actorTypeName string, actorID string, provider *DaprStateAsyncProvider) actor.StateManager

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

func NewActorStateChange(stateName string, value interface{}, changeKind ChangeKind) *ActorStateChange

type ActorStateManager struct {
	ActorTypeName string
	ActorID       string
	// contains filtered or unexported fields
}

func (a *ActorStateManager) Add(stateName string, value interface{}) error

func (a *ActorStateManager) Contains(stateName string) (bool, error)

func (a *ActorStateManager) Flush()

func (a *ActorStateManager) Get(stateName string, reply interface{}) error

func (a *ActorStateManager) Remove(stateName string) error

func (a *ActorStateManager) Save() error

func (a *ActorStateManager) Set(stateName string, value interface{}) error

type ChangeKind string

type ChangeMetadata struct {
	Kind  ChangeKind
	Value interface{}
}

func NewChangeMetadata(kind ChangeKind, value interface{}) *ChangeMetadata

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

func NewDaprStateAsyncProvider(daprClient client.Client) *DaprStateAsyncProvider

TODO(@laurence) the daprClient may be nil.

func (d *DaprStateAsyncProvider) Apply(actorType, actorID string, changes []*ActorStateChange) error

func (d *DaprStateAsyncProvider) Contains(actorType string, actorID string, stateName string) (bool, error)

func (d *DaprStateAsyncProvider) Load(actorType, actorID, stateName string, reply interface{}) error