state

Oct 26, 2021

Changes in this version

+ func NewDefaultStateStoreFactory() *build.Factory

+ type IStateStore interface

+ Delete func(correlationId string, key string) interface{}

+ Load func(correlationId string, key string) interface{}

+ LoadBulk func(correlationId string, keys []string) []*StateValue

+ Save func(correlationId string, key string, value interface{}) interface{}

+ type MemoryStateStore struct

+ func NewEmptyMemoryStateStore() *MemoryStateStore

+ func (c *MemoryStateStore) Configure(config *cconf.ConfigParams)

+ func (c *MemoryStateStore) Delete(correlationId string, key string) interface{}

+ func (c *MemoryStateStore) Load(correlationId string, key string) interface{}

+ func (c *MemoryStateStore) LoadBulk(correlationId string, keys []string) []*StateValue

+ func (c *MemoryStateStore) Save(correlationId string, key string, value interface{}) interface{}

+ type NullStateStore struct

+ func NewEmptyNullStateStore() *NullStateStore

+ func (c *NullStateStore) Delete(correlationId string, key string) interface{}

+ func (c *NullStateStore) Load(correlationId string, key string) interface{}

+ func (c *NullStateStore) LoadBulk(correlationId string, keys []string) []*StateValue

+ func (c *NullStateStore) Save(correlationId string, key string, value interface{}) interface{}

+ type StateEntry struct

+ func NewStateEntry(key string, value interface{}) *StateEntry

+ func (c *StateEntry) GetKey() string

+ func (c *StateEntry) GetLastUpdateTime() int64

+ func (c *StateEntry) GetValue() interface{}

+ func (c *StateEntry) SetValue(value interface{})

+ type StateValue struct

+ Key string

+ Value interface{}