MemoryStateStore

Implements: IReconfigurable, IStateStore

Description

Remember: This implementation is not suitable for synchronization of distributed processes.

Configuration parameters

options:

• timeout: default caching timeout in milliseconds (default: disabled)

Instance methods

Configure

Configures component by passing configuration parameters.

(c *MemoryStateStore[T]) Configure(ctx context.Context, config *cconf.ConfigParams)

• config: ConfigParams - configuration parameters to be set.

Delete

Deletes a state from the store by its key.

(c *MemoryStateStore[T]) Delete(ctx context.Context, key string) T

• context: IContext - (optional) a context to trace execution through call chain.
• key: string - a unique value key.
• return: any - removed item

Load

Loads state from the store using its key. If value is missing in the store it returns null.

(c *MemoryStateStore[T]) Load(ctx context.Context, key string) T

• context: IContext - (optional) a context to trace execution through call chain.
• key: string - a unique state key.
• return: any - the state value or null if value wasn’t found.

LoadBulk

Loads an array of states from the store using their keys.

(c *MemoryStateStore[T]) LoadBulk(ctx context.Context, keys []string) []StateValue[T]

• context: IContext - (optional) a context to trace execution through call chain.
• keys: string[] - unique state keys.
• returns: any> - an array with state values and their corresponding keys.

Save

Saves state into the store.

(c *MemoryStateStore[T]) Save(ctx context.Context, key string, value T) T

• context: IContext - (optional) a context to trace execution through call chain.
• key: string - a unique state key.
• value: any - a state value.
• returns: any - execution duration in milliseconds.

Examples

		store := NewMemoryStateStore[MyType]();
		value := store.Load(context.Background(), "123", "key1");
		...
		store.Save(context.Background(), "123", "key1", MyType{});

See also

• ICache