store

May 14, 2021

Changes in this version

+ type Driver string

+ var DriverPostgreSQL Driver = "postgres"

Mar 29, 2021

Changes in this version

type Event

+ ParentEventID *string

Feb 17, 2021

Changes in this version

type Options

+ PurgePolicies []*PurgePolicy

+ type PurgePolicy struct

+ Interval string

+ WhereEvents *WhereEvents

type Store

+ Purge func(*Toolkit, *WhereEvents) error

type WhereEvents

+ ReceivedAfter *time.Time

+ ReceivedBefore *time.Time

Nov 15, 2020

Changes in this version

type WhereEvents

+ VersionsIn []string

+ VersionsNotIn []string

type WhereJobs

+ VersionsIn []string

+ VersionsNotIn []string

Oct 13, 2020

Changes in this version

type Event

+ Version string

type Job

+ Version string

Sep 1, 2020

Changes in this version

+ var StatusUnknown = "unknown"

type Event

+ Trigger string

type Job

+ Action string

+ type Meta struct

+ Count uint16

+ Pagination *Pagination

+ Where *WhereEvents

+ type Pagination struct

+ Current uint16

+ First uint16

+ Last uint16

+ Next *uint16

+ Previous *uint16

type Store

+ AddEvents func(*Toolkit, []*Event) error

+ FindEvent func(*Toolkit, string) (*Event, error)

+ FindEvents func(*Toolkit, *WhereEvents) ([]*Event, *Meta, error)

+ FindJob func(*Toolkit, string) (*Job, error)

+ FindJobs func(*Toolkit, *WhereEvents) ([]*Job, *Meta, error)

+ FindTransition func(*Toolkit, string) (*Transition, error)

+ FindTransitions func(*Toolkit, *WhereEvents) ([]*Transition, *Meta, error)

+ type WhereEvents struct

+ AndWhereJobs *WhereJobs

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ Limit uint16

+ Offset uint16

+ SourcesIn []string

+ SourcesNotIn []string

+ TriggersIn []string

+ TriggersNotIn []string

+ type WhereJobs struct

+ ActionsIn []string

+ ActionsNotIn []string

+ AndWhereTransitions *WhereTransitions

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ DestinationsIn []string

+ DestinationsNotIn []string

+ EventID string

+ type WhereTransitions struct

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ JobID string

+ MaxAttempts uint16

+ MinAttempts uint16

+ StatusIn []string

+ StatusNotIn []string

May 25, 2020

Changes in this version

+ var AvailableAdapters = map[string]bool

+ var Defaults = &Options

+ var InterfaceStore = "store"

+ var StatusAcknowledged = "acknowledged"

+ var StatusAwaiting = "awaiting"

+ var StatusDiscarded = "discarded"

+ var StatusExecuting = "executing"

+ var StatusFailed = "failed"

+ var StatusSucceeded = "succeeded"

+ type Event struct

+ Context []byte

+ Data []byte

+ ID string

+ IngestedAt *time.Time

+ Jobs []*Job

+ Name string

+ ReceivedAt time.Time

+ SentAt *time.Time

+ Source string

+ type Job struct

+ Context []byte

+ CreatedAt time.Time

+ Data []byte

+ Destination string

+ Event string

+ EventID string

+ ID string

+ ParentJobID *string

+ Transitions [1]*Transition

+ type Options struct

+ Connection string

+ Context context.Context

+ From string

+ Load Store

+ func (opts *Options) ValidateAndLoad() (Store, error)

+ type Queue struct

+ Events []*Event

+ type Store interface

+ AddJobs func(*Toolkit, []*Job) error

+ AddTransitions func(*Toolkit, []*Transition) error

+ Delete func(*Toolkit, []*Event) error

+ Find func(*Toolkit, *WhereJob) ([]*Event, error)

+ InsertQueue func(*Toolkit, *Queue) error

+ Migrate func(*wanderer.Toolkit, *wanderer.Migration) error

+ Migrations func() ([]*wanderer.Migration, error)

+ Options func() *Options

+ String func() string

+ type Toolkit struct

+ Logger *logrus.Logger

+ type Transition struct

+ Attempt uint16

+ CreatedAt time.Time

+ Error error

+ EventID string

+ ID string

+ JobID string

+ StateAfter string

+ StateBefore *string

+ type WhereJob struct

+ DestinationsIn []string

+ EventsIn []string

+ MaxAttempts uint16

+ StatusIn []string

+ StatusNotIn []string