state

package

v1.13.2 Latest Latest Go to latest Published: Apr 3, 2024 License: Apache-2.0 Imports: 27 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Open Source Insights

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
type StoreConfiguration

Constants ¶

This section is empty.

Variables ¶

View Source

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")
)

View Source

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

errors code

Functions ¶

func GetModifiedStateKey ¶ added in v1.0.0

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

func GetOriginalStateKey ¶ added in v1.0.0

func GetOriginalStateKey(modifiedStateKey string) string

func NewGRPCStateStore ¶ added in v1.9.0

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

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

func PerformBulkStoreOperation ¶ added in v1.11.0

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 ¶ added in v1.0.0

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 ¶ added in v0.4.0

func NewRegistry() *Registry

NewRegistry is used to create state store registry.

func (*Registry) Create ¶ added in v1.0.0

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

func (*Registry) RegisterComponent ¶ added in v1.9.0

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

RegisterComponent adds a new state store to the registry.

func (*Registry) RegisterComponentWithVersions ¶ added in v1.12.0

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

RegisterComponent adds a new state store to the registry.

type StoreConfiguration ¶ added in v1.0.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL