sdk

Documentation

Index

• func Filter(ctx context.Context, filter filterFunc, appender appendFunc, ...) error
• func IsAppendEventError(err error) bool
• func ThrowAggregaterf(parent error, id, format string, a ...interface{}) error
• func ThrowAppendEventError(parent error, id, message string) error
• type AggregateFunc
• type AppendEventError

Functions

func Filter

func Filter(ctx context.Context, filter filterFunc, appender appendFunc, query *es_models.SearchQuery) error

func IsAppendEventError

func IsAppendEventError(err error) bool

func ThrowAggregaterf

func ThrowAggregaterf(parent error, id, format string, a ...interface{}) error

func ThrowAppendEventError

func ThrowAppendEventError(parent error, id, message string) error

Types

type AggregateFunc

type AggregateFunc func(context.Context) (*es_models.Aggregate, error)

type AppendEventError

type AppendEventError interface {
	error
	IsAppendEventError()
}