state

Feb 21, 2024

Changes in this version

+ var ErrPingNotImplemented = errors.New("ping is not implemented by this state store")

+ type DeleteWithPrefix interface

+ DeleteWithPrefix func(ctx context.Context, req DeleteWithPrefixRequest) (DeleteWithPrefixResponse, error)

+ type DeleteWithPrefixRequest struct

+ Prefix string

+ func (r *DeleteWithPrefixRequest) Validate() error

+ type DeleteWithPrefixResponse struct

+ Count int64

type Feature

+ const FeatureDeleteWithPrefix

+ const FeaturePartitionKey

Oct 9, 2023

Changes in this version

+ const GetRespMetaKeyTTLExpireTime

type Feature

+ const FeatureTTL

+ type TransactionalStoreMultiMaxSize interface

+ MultiMaxSize func() int

Jun 6, 2023

Changes in this version

+ func DoBulkSetDelete(ctx context.Context, req []T, method func(ctx context.Context, req *T) error, ...) error

+ type BaseStore interface

+ Delete func(ctx context.Context, req *DeleteRequest) error

+ Features func() []Feature

+ Get func(ctx context.Context, req *GetRequest) (*GetResponse, error)

+ GetComponentMetadata func() map[string]string

+ Init func(ctx context.Context, metadata Metadata) error

+ Set func(ctx context.Context, req *SetRequest) error

+ type BulkGetOpts struct

+ Parallelism int

type BulkGetResponse

+ func DoBulkGet(ctx context.Context, req []GetRequest, opts BulkGetOpts, ...) ([]BulkGetResponse, error)

+ type BulkStoreError struct

+ func NewBulkStoreError(key string, err error) BulkStoreError

+ func (e BulkStoreError) ETagError() *ETagError

+ func (e BulkStoreError) Error() string

+ func (e BulkStoreError) Key() string

+ func (e BulkStoreError) Unwrap() error

+ type BulkStoreOpts struct

+ Parallelism int

type DeleteRequest

+ func (r DeleteRequest) HasETag() bool

+ func (r DeleteRequest) Operation() OperationType

type ETagError

+ func (e *ETagError) Unwrap() error

type GetRequest

+ func (r GetRequest) GetKey() string

+ func (r GetRequest) GetMetadata() map[string]string

type OperationType

+ const OperationDelete

+ const OperationUpsert

type SetRequest

+ func (r SetRequest) HasETag() bool

+ func (r SetRequest) Operation() OperationType

+ type StateRequest interface

+ GetKey func() string

+ GetMetadata func() map[string]string

Mar 8, 2023

Changes in this version

type Store

+ GetComponentMetadata func() map[string]string

Jul 5, 2022

Changes in this version

+ func Ping(store Store) error

type Feature

+ const FeatureQueryAPI

Apr 8, 2022

Changes in this version

+ type BulkDeleteRowMismatchError struct

+ func NewBulkDeleteRowMismatchError(expected, affected uint64) *BulkDeleteRowMismatchError

+ func (e *BulkDeleteRowMismatchError) Error() string

type BulkGetResponse

+ ContentType *string

type GetResponse

+ ContentType *string

type QueryItem

+ ContentType *string

type SetRequest

+ ContentType *string

Nov 11, 2021

Changes in this version

+ type Querier interface

+ Query func(req *QueryRequest) (*QueryResponse, error)

+ type QueryItem struct

+ Data []byte

+ ETag *string

+ Error string

+ Key string

+ type QueryRequest struct

+ Metadata map[string]string

+ Query query.Query

+ type QueryResponse struct

+ Metadata map[string]string

+ Results []QueryItem

+ Token string

Nov 29, 2021

Changes in this version

type Store

+ Ping func() error

Apr 14, 2021

Changes in this version

type DefaultBulkStore

+ func (b *DefaultBulkStore) Features() []Feature

+ type Feature string

+ const FeatureETag

+ const FeatureTransactional

+ func (f Feature) IsPresent(features []Feature) bool

type Store

+ Features func() []Feature

Feb 12, 2021

Changes in this version

+ type BulkGetResponse struct

+ Data []byte

+ ETag string

+ Error string

+ Key string

+ Metadata map[string]string

+ type BulkStore interface

+ BulkDelete func(req []DeleteRequest) error

+ BulkGet func(req []GetRequest) (bool, []BulkGetResponse, error)

+ BulkSet func(req []SetRequest) error

+ type DefaultBulkStore struct

+ func NewDefaultBulkStore(store Store) DefaultBulkStore

+ func (b *DefaultBulkStore) BulkDelete(req []DeleteRequest) error

+ func (b *DefaultBulkStore) BulkGet(req []GetRequest) (bool, []BulkGetResponse, error)

+ func (b *DefaultBulkStore) BulkSet(req []SetRequest) error

+ type ETagError struct

+ func NewETagError(kind ETagErrorKind, err error) *ETagError

+ func (e *ETagError) Error() string

+ func (e *ETagError) Kind() ETagErrorKind

+ type ETagErrorKind string

+ const ETagInvalid

+ const ETagMismatch

Aug 18, 2020

Changes in this version

+ func CheckRequestOptions(options interface{}) error

+ func DeleteWithOptions(method func(req *DeleteRequest) error, req *DeleteRequest) error

+ func SetWithOptions(method func(req *SetRequest) error, req *SetRequest) error

+ type TransactionalStateOperation struct

+ Operation OperationType

+ Request interface{}

+ type TransactionalStateRequest struct

+ Metadata map[string]string

+ Operations []TransactionalStateOperation

Jul 13, 2020

Changes in this version

type DeleteRequest

+ func (r DeleteRequest) GetKey() string

+ func (r DeleteRequest) GetMetadata() map[string]string

+ type KeyInt interface

+ GetKey func() string

+ GetMetadata func() map[string]string

type SetRequest

+ func (r SetRequest) GetKey() string

+ func (r SetRequest) GetMetadata() map[string]string

May 29, 2020

Changes in this version

+ const Eventual

+ const Exponential

+ const FirstWrite

+ const LastWrite

+ const Linear

+ const Strong

+ func CheckDeleteRequestOptions(req *DeleteRequest) error

+ func CheckSetRequestOptions(req *SetRequest) error

+ func DeleteWithRetries(method func(req *DeleteRequest) error, req *DeleteRequest) error

+ func SetWithRetries(method func(req *SetRequest) error, req *SetRequest) error

+ type DeleteRequest struct

+ ETag string

+ Key string

+ Metadata map[string]string

+ Options DeleteStateOption

+ type DeleteStateOption struct

+ Concurrency string

+ Consistency string

+ RetryPolicy RetryPolicy

+ type GetRequest struct

+ Key string

+ Metadata map[string]string

+ Options GetStateOption

+ type GetResponse struct

+ Data []byte

+ ETag string

+ Metadata map[string]string

+ type GetStateOption struct

+ Consistency string

+ type Metadata struct

+ Properties map[string]string

+ type OperationType string

+ const Delete

+ const Upsert

+ type RetryPolicy struct

+ Interval time.Duration

+ Pattern string

+ Threshold int

+ type SetRequest struct

+ ETag string

+ Key string

+ Metadata map[string]string

+ Options SetStateOption

+ Value interface{}

+ type SetStateOption struct

+ Concurrency string

+ Consistency string

+ RetryPolicy RetryPolicy

+ type Store interface

+ BulkDelete func(req []DeleteRequest) error

+ BulkSet func(req []SetRequest) error

+ Delete func(req *DeleteRequest) error

+ Get func(req *GetRequest) (*GetResponse, error)

+ Init func(metadata Metadata) error

+ Set func(req *SetRequest) error

+ type TransactionalRequest struct

+ Operation OperationType

+ Request interface{}

+ type TransactionalStore interface

+ Init func(metadata Metadata) error

+ Multi func(reqs []TransactionalRequest) error