state

Documentation

Index

• Variables
• func GetModifiedStateKey(key, storeName, appID string) (string, error)
• func GetOriginalStateKey(modifiedStateKey string) string
• func NewGRPCStateStore(l logger.Logger, socket string) *grpcStateStore
• func PerformBulkStoreOperation[T stateRequestConstraint](ctx context.Context, reqs []T, policyDef *resiliency.PolicyDefinition, ...) error
• func SaveStateConfiguration(storeName string, metadata map[string]string) error
• type Registry
  • func NewRegistry() *Registry
  • func (s *Registry) Create(name, version, logName string) (state.Store, error)
  • func (s *Registry) RegisterComponent(componentFactory func(logger.Logger) state.Store, names ...string)
  • func (s *Registry) RegisterComponentWithVersions(name string, versions components.Versioning)
• type StoreConfiguration

Variables

var (
	ErrNilSetValue                   = errors.New("an attempt to set a nil value was received, try to use Delete instead")
	ErrRespNil                       = errors.New("the response for GetRequest is nil")
	ErrTransactOperationNotSupported = errors.New("transact operation not supported")
)

var (
	GRPCCodeETagMismatch          = codes.FailedPrecondition
	GRPCCodeETagInvalid           = codes.InvalidArgument
	GRPCCodeBulkDeleteRowMismatch = codes.Internal
)

errors code

Functions

func GetModifiedStateKey

func GetModifiedStateKey(key, storeName, appID string) (string, error)

func GetOriginalStateKey

func GetOriginalStateKey(modifiedStateKey string) string

func NewGRPCStateStore

func NewGRPCStateStore(l logger.Logger, socket string) *grpcStateStore

NewGRPCStateStore creates a new grpc state store using the given socket factory.

func PerformBulkStoreOperation

func PerformBulkStoreOperation[T stateRequestConstraint](
	ctx context.Context, reqs []T, policyDef *resiliency.PolicyDefinition, opts state.BulkStoreOpts,
	execSingle func(ctx context.Context, req *T) error,
	execMulti func(ctx context.Context, reqs []T, opts state.BulkStoreOpts) error,
) error

PerformBulkStoreOperation performs a bulk set or delete using resiliency, retrying operations that fail only when they can be retried.

func SaveStateConfiguration

func SaveStateConfiguration(storeName string, metadata map[string]string) error

Types

type Registry

type Registry struct {
	Logger logger.Logger
	// contains filtered or unexported fields
}

Registry is an interface for a component that returns registered state store implementations.

var DefaultRegistry *Registry = NewRegistry()

DefaultRegistry is the singleton with the registry.

func NewRegistry

func NewRegistry() *Registry

NewRegistry is used to create state store registry.

func (*Registry) Create

func (s *Registry) Create(name, version, logName string) (state.Store, error)

func (*Registry) RegisterComponent

func (s *Registry) RegisterComponent(componentFactory func(logger.Logger) state.Store, names ...string)

RegisterComponent adds a new state store to the registry.

func (*Registry) RegisterComponentWithVersions

func (s *Registry) RegisterComponentWithVersions(name string, versions components.Versioning)

RegisterComponent adds a new state store to the registry.

type StoreConfiguration

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