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 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)
• 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 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.

type StoreConfiguration

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