manipulate

Jan 21, 2023

Changes in this version

+ func NewFiltersFromQueryParameters(parameters elemental.Parameters) (*elemental.Filter, error)

+ func NewNamespaceFilter(namespace string, recursive bool) *elemental.Filter

+ func NewNamespaceFilterWithCustomProperty(propertyName string, namespace string, recursive bool) *elemental.Filter

+ func NewPropagationFilter(namespace string) *elemental.Filter

+ func NewPropagationFilterWithCustomProperty(propagationPropName string, namespacePropName string, namespace string, ...) *elemental.Filter

type Context

+ Propagated func() bool

type ContextOption

+ func ContextOptionPropagated(p bool) ContextOption

+ type SelfTokenManager interface

+ SetManipulator func(Manipulator)

Jun 30, 2021

Changes in this version

+ type ErrInvalidQuery struct

+ DueToFilter bool

+ Err error

+ func (err ErrInvalidQuery) Error() string

+ func (err ErrInvalidQuery) Unwrap() error

Apr 6, 2021

Changes in this version

type ErrCannotBuildQuery

+ Err error

+ func (e ErrCannotBuildQuery) Unwrap() error

type ErrCannotCommit

+ Err error

+ func (e ErrCannotCommit) Unwrap() error

type ErrCannotCommunicate

+ Err error

+ func (e ErrCannotCommunicate) Unwrap() error

type ErrCannotExecuteQuery

+ Err error

+ func (e ErrCannotExecuteQuery) Unwrap() error

type ErrCannotMarshal

+ Err error

+ func (e ErrCannotMarshal) Unwrap() error

type ErrCannotUnmarshal

+ Err error

+ func (e ErrCannotUnmarshal) Unwrap() error

type ErrConstraintViolation

+ Err error

+ func (e ErrConstraintViolation) Unwrap() error

type ErrDisconnected

+ Err error

+ func (e ErrDisconnected) Unwrap() error

type ErrLocked

+ Err error

+ func (e ErrLocked) Unwrap() error

type ErrMultipleObjectsFound

+ Err error

+ func (e ErrMultipleObjectsFound) Unwrap() error

type ErrNotImplemented

+ Err error

+ func (e ErrNotImplemented) Unwrap() error

type ErrObjectNotFound

+ Err error

+ func (e ErrObjectNotFound) Unwrap() error

type ErrTLS

+ Err error

+ func (e ErrTLS) Unwrap() error

type ErrTooManyRequests

+ Err error

+ func (e ErrTooManyRequests) Unwrap() error

type ErrTransactionNotFound

+ Err error

+ func (e ErrTransactionNotFound) Unwrap() error

Mar 23, 2021

Changes in this version

type ReadConsistency

+ const ReadConsistencyWeakest

Jun 25, 2020

Changes in this version

type ContextOption

+ func ContextOptionOpaque(o map[string]interface{}) ContextOption

Oct 3, 2019

Changes in this version

type ContextOption

+ func ContextOptionIdempotencyKey(key string) ContextOption

Sep 25, 2019

Changes in this version

type Context

+ After func() string

+ Limit func() int

+ Next func() string

+ SetNext func(string)

type ContextOption

+ func ContextOptionAfter(from string, limit int) ContextOption

Jun 10, 2019

Changes in this version

type ContextOption

+ func ContextOptionTransactionID(tid TransactionID) ContextOption

Jun 6, 2019

Changes in this version

+ func IterUntilFunc(ctx context.Context, manipulator Manipulator, ...) error

May 31, 2019

Changes in this version

type Context

+ RetryFunc func() RetryFunc

+ RetryRatio func() int64

type ContextOption

+ func ContextOptionRetryFunc(f RetryFunc) ContextOption

+ func ContextOptionRetryRatio(r int64) ContextOption

+ type RetryFunc func(RetryInfo) error

+ type RetryInfo interface

+ Context func() Context

+ Err func() error

+ Try func() int

May 17, 2019

Changes in this version

type Context

+ ClientIP func() string

+ Credentials func() (string, string)

type ContextOption

+ func ContextOptionClientIP(clientIP string) ContextOption

+ func ContextOptionCredentials(username, password string) ContextOption

+ func ContextOptionToken(token string) ContextOption

May 1, 2019

Changes in this version

+ func IsCannotBuildQueryError(err error) bool

+ func IsCannotCommitError(err error) bool

+ func IsCannotCommunicateError(err error) bool

+ func IsCannotExecuteQueryError(err error) bool

+ func IsCannotMarshalError(err error) bool

+ func IsCannotUnmarshalError(err error) bool

+ func IsConstraintViolationError(err error) bool

+ func IsDisconnectedError(err error) bool

+ func IsLockedError(err error) bool

+ func IsMultipleObjectsFoundError(err error) bool

+ func IsNotImplementedError(err error) bool

+ func IsObjectNotFoundError(err error) bool

+ func IsTLSError(err error) bool

+ func IsTooManyRequestsError(err error) bool

+ func IsTransactionNotFoundError(err error) bool

+ func Iter(ctx context.Context, m Manipulator, mctx Context, ...) (elemental.Identifiables, error)

+ func IterFunc(ctx context.Context, manipulator Manipulator, ...) error

+ func Retry(ctx context.Context, manipulateFunc func() error, ...) error

+ type BufferedManipulator interface

+ type Context interface

+ Context func() context.Context

+ Count func() int

+ Derive func(...ContextOption) Context

+ ExternalTrackingID func() string

+ ExternalTrackingType func() string

+ Fields func() []string

+ Filter func() *Filter

+ Finalizer func() FinalizerFunc

+ Messages func() []string

+ Namespace func() string

+ Order func() []string

+ Override func() bool

+ Page func() int

+ PageSize func() int

+ Parameters func() url.Values

+ Parent func() elemental.Identifiable

+ ReadConsistency func() ReadConsistency

+ Recursive func() bool

+ SetCount func(count int)

+ SetMessages func([]string)

+ TransactionID func() TransactionID

+ Version func() int

+ WriteConsistency func() WriteConsistency

+ func NewContext(ctx context.Context, options ...ContextOption) Context

+ type ContextOption func(*mcontext)

+ func ContextOptionFields(fields []string) ContextOption

+ func ContextOptionFilter(f *Filter) ContextOption

+ func ContextOptionFinalizer(f FinalizerFunc) ContextOption

+ func ContextOptionNamespace(n string) ContextOption

+ func ContextOptionOrder(orders ...string) ContextOption

+ func ContextOptionOverride(o bool) ContextOption

+ func ContextOptionPage(n, size int) ContextOption

+ func ContextOptionParameters(p url.Values) ContextOption

+ func ContextOptionParent(i elemental.Identifiable) ContextOption

+ func ContextOptionReadConsistency(consistency ReadConsistency) ContextOption

+ func ContextOptionRecursive(r bool) ContextOption

+ func ContextOptionTracking(identifier, typ string) ContextOption

+ func ContextOptionTransationID(tid TransactionID) ContextOption

+ func ContextOptionVersion(v int) ContextOption

+ func ContextOptionWriteConsistency(consistency WriteConsistency) ContextOption

+ type ErrCannotBuildQuery struct

+ func NewErrCannotBuildQuery(message string) ErrCannotBuildQuery

+ func (e ErrCannotBuildQuery) Error() string

+ type ErrCannotCommit struct

+ func NewErrCannotCommit(message string) ErrCannotCommit

+ func (e ErrCannotCommit) Error() string

+ type ErrCannotCommunicate struct

+ func NewErrCannotCommunicate(message string) ErrCannotCommunicate

+ func (e ErrCannotCommunicate) Error() string

+ type ErrCannotExecuteQuery struct

+ func NewErrCannotExecuteQuery(message string) ErrCannotExecuteQuery

+ func (e ErrCannotExecuteQuery) Error() string

+ type ErrCannotMarshal struct

+ func NewErrCannotMarshal(message string) ErrCannotMarshal

+ func (e ErrCannotMarshal) Error() string

+ type ErrCannotUnmarshal struct

+ func NewErrCannotUnmarshal(message string) ErrCannotUnmarshal

+ func (e ErrCannotUnmarshal) Error() string

+ type ErrConstraintViolation struct

+ func NewErrConstraintViolation(message string) ErrConstraintViolation

+ func (e ErrConstraintViolation) Error() string

+ type ErrDisconnected struct

+ func NewErrDisconnected(message string) ErrDisconnected

+ func (e ErrDisconnected) Error() string

+ type ErrLocked struct

+ func NewErrLocked(message string) ErrLocked

+ func (e ErrLocked) Error() string

+ type ErrMultipleObjectsFound struct

+ func NewErrMultipleObjectsFound(message string) ErrMultipleObjectsFound

+ func (e ErrMultipleObjectsFound) Error() string

+ type ErrNotImplemented struct

+ func NewErrNotImplemented(message string) ErrNotImplemented

+ func (e ErrNotImplemented) Error() string

+ type ErrObjectNotFound struct

+ func NewErrObjectNotFound(message string) ErrObjectNotFound

+ func (e ErrObjectNotFound) Error() string

+ type ErrTLS struct

+ func NewErrTLS(message string) ErrTLS

+ func (e ErrTLS) Error() string

+ type ErrTooManyRequests struct

+ func NewErrTooManyRequests(message string) ErrTooManyRequests

+ func (e ErrTooManyRequests) Error() string

+ type ErrTransactionNotFound struct

+ func NewErrTransactionNotFound(message string) ErrTransactionNotFound

+ func (e ErrTransactionNotFound) Error() string

+ type Filter struct

+ func NewFilter() *Filter

+ func NewFilterFromString(filter string) (*Filter, error)

+ func (f *Filter) And(filters ...*Filter) FilterKeyComposer

+ func (f *Filter) AndFilters() SubFilters

+ func (f *Filter) Comparators() FilterComparators

+ func (f *Filter) Contains(values ...interface{}) FilterKeyComposer

+ func (f *Filter) Done() *Filter

+ func (f *Filter) Equals(value interface{}) FilterKeyComposer

+ func (f *Filter) Exists() FilterKeyComposer

+ func (f *Filter) GreaterOrEqualThan(value interface{}) FilterKeyComposer

+ func (f *Filter) GreaterThan(value interface{}) FilterKeyComposer

+ func (f *Filter) In(values ...interface{}) FilterKeyComposer

+ func (f *Filter) Keys() FilterKeys

+ func (f *Filter) LesserOrEqualThan(value interface{}) FilterKeyComposer

+ func (f *Filter) LesserThan(value interface{}) FilterKeyComposer

+ func (f *Filter) Matches(values ...interface{}) FilterKeyComposer

+ func (f *Filter) NotContains(values ...interface{}) FilterKeyComposer

+ func (f *Filter) NotEquals(value interface{}) FilterKeyComposer

+ func (f *Filter) NotExists() FilterKeyComposer

+ func (f *Filter) NotIn(values ...interface{}) FilterKeyComposer

+ func (f *Filter) Operators() FilterOperators

+ func (f *Filter) Or(filters ...*Filter) FilterKeyComposer

+ func (f *Filter) OrFilters() SubFilters

+ func (f *Filter) String() string

+ func (f *Filter) Values() FilterValues

+ func (f *Filter) WithKey(key string) FilterValueComposer

+ type FilterComparator int

+ const ContainComparator

+ const EqualComparator

+ const ExistsComparator

+ const GreaterComparator

+ const GreaterOrEqualComparator

+ const InComparator

+ const LesserComparator

+ const LesserOrEqualComparator

+ const MatchComparator

+ const NotContainComparator

+ const NotEqualComparator

+ const NotExistsComparator

+ const NotInComparator

+ const NotMatchComparator

+ type FilterComparators []FilterComparator

+ type FilterKeyComposer interface

+ And func(...*Filter) FilterKeyComposer

+ Done func() *Filter

+ Or func(...*Filter) FilterKeyComposer

+ WithKey func(string) FilterValueComposer

+ func NewFilterComposer() FilterKeyComposer

+ type FilterKeys []string

+ type FilterOperator int

+ const AndFilterOperator

+ const AndOperator

+ const OrFilterOperator

+ type FilterOperators []FilterOperator

+ type FilterParser struct

+ func NewFilterParser(input string) *FilterParser

+ func (p *FilterParser) Parse() (*Filter, error)

+ type FilterValue []interface

+ type FilterValueComposer interface

+ Contains func(...interface{}) FilterKeyComposer

+ Equals func(interface{}) FilterKeyComposer

+ Exists func() FilterKeyComposer

+ GreaterOrEqualThan func(interface{}) FilterKeyComposer

+ GreaterThan func(interface{}) FilterKeyComposer

+ In func(...interface{}) FilterKeyComposer

+ LesserOrEqualThan func(interface{}) FilterKeyComposer

+ LesserThan func(interface{}) FilterKeyComposer

+ Matches func(...interface{}) FilterKeyComposer

+ NotContains func(...interface{}) FilterKeyComposer

+ NotEquals func(interface{}) FilterKeyComposer

+ NotExists func() FilterKeyComposer

+ NotIn func(...interface{}) FilterKeyComposer

+ type FilterValues [][]interface

+ type FinalizerFunc func(o elemental.Identifiable) error

+ type FlushableManipulator interface

+ Flush func(ctx context.Context) error

+ type Manipulator interface

+ Count func(mctx Context, identity elemental.Identity) (int, error)

+ Create func(mctx Context, object elemental.Identifiable) error

+ Delete func(mctx Context, object elemental.Identifiable) error

+ DeleteMany func(mctx Context, identity elemental.Identity) error

+ Retrieve func(mctx Context, object elemental.Identifiable) error

+ RetrieveMany func(mctx Context, dest elemental.Identifiables) error

+ Update func(mctx Context, object elemental.Identifiable) error

+ type ReadConsistency string

+ const ReadConsistencyDefault

+ const ReadConsistencyEventual

+ const ReadConsistencyMonotonic

+ const ReadConsistencyNearest

+ const ReadConsistencyStrong

+ type SubFilter []*Filter

+ type SubFilters []SubFilter

+ type Subscriber interface

+ Errors func() chan error

+ Events func() chan *elemental.Event

+ Start func(context.Context, *elemental.PushFilter)

+ Status func() chan SubscriberStatus

+ UpdateFilter func(*elemental.PushFilter)

+ type SubscriberStatus int

+ const SubscriberStatusDisconnection

+ const SubscriberStatusFinalDisconnection

+ const SubscriberStatusInitialConnection

+ const SubscriberStatusInitialConnectionFailure

+ const SubscriberStatusReconnection

+ const SubscriberStatusReconnectionFailure

+ const SubscriberStatusTokenRenewal

+ type TokenManager interface

+ Issue func(context.Context) (string, error)

+ Run func(ctx context.Context, tokenCh chan string)

+ type TransactionID string

+ func NewTransactionID() TransactionID

+ type TransactionalManipulator interface

+ Abort func(id TransactionID) bool

+ Commit func(id TransactionID) error

+ type WriteConsistency string

+ const WriteConsistencyDefault

+ const WriteConsistencyNone

+ const WriteConsistencyStrong

+ const WriteConsistencyStrongest