impl

Documentation

Index

• Constants
• func NewEvent(ctx context.Context, record *model.AwsEventRecord) core.Event
• func NewEventFactory() core.EventFactory
• func NewEventStore(eventStore model.AwsEventStore, objectStore model.AwsObjectStore) core.EventStore
• func NewStateStore(eventStore core.EventStore) core.StateStore
• type Context
• type EntityImpl
  • func (e EntityImpl) CreatedAt() time.Time
  • func (e EntityImpl) CreatedBy() string
  • func (e EntityImpl) ID() string
  • func (e *EntityImpl) State(v interface{})
  • func (e EntityImpl) Type() string
  • func (e EntityImpl) UpdatedAt() time.Time
  • func (e EntityImpl) UpdatedBy() string
  • func (e EntityImpl) Version() uint64
• type EventImpl
  • func (e EventImpl) Author() string
  • func (e EventImpl) Class() core.EventClass
  • func (e EventImpl) Data(v interface{})
  • func (e EventImpl) Entity() core.Entity
  • func (e EventImpl) ID() string
  • func (e EventImpl) Source() string
  • func (e EventImpl) Time() time.Time
  • func (e EventImpl) Transaction() string
  • func (e EventImpl) Trigger() core.Event
  • func (e EventImpl) Type() string

Constants

const AwsContext = "AwsContext"

Functions

func NewEvent

func NewEvent(ctx context.Context, record *model.AwsEventRecord) core.Event

func NewEventFactory

func NewEventFactory() core.EventFactory

func NewEventStore

func NewEventStore(eventStore model.AwsEventStore, objectStore model.AwsObjectStore) core.EventStore

func NewStateStore

func NewStateStore(eventStore core.EventStore) core.StateStore

Types

type Context

type Context struct {
	AwsHandlerID      string
	AwsHandlerVersion string
	AwsHandlerTimeout uint64
	AwsFactory        factory.AwsFactory
	AwsObjectStore    model.AwsObjectStore
	AwsEventStore     model.AwsEventStore
	AwsEventBus       model.AwsEventBus
	AwsStateStore     model.AwsStateStore
	AwsGraphqlGateway model.AwsGraphqlGateway
}

type EntityImpl

type EntityImpl struct {
	LastEvent *model.AwsEventRecord
}

func (EntityImpl) CreatedAt

func (e EntityImpl) CreatedAt() time.Time

func (EntityImpl) CreatedBy

func (e EntityImpl) CreatedBy() string

func (EntityImpl) ID

func (e EntityImpl) ID() string

func (*EntityImpl) State

func (e *EntityImpl) State(v interface{})

func (EntityImpl) Type

func (e EntityImpl) Type() string

func (EntityImpl) UpdatedAt

func (e EntityImpl) UpdatedAt() time.Time

func (EntityImpl) UpdatedBy

func (e EntityImpl) UpdatedBy() string

func (EntityImpl) Version

func (e EntityImpl) Version() uint64

type EventImpl

type EventImpl struct {
	Ctx    context.Context
	Record *model.AwsEventRecord
}

func (EventImpl) Author

func (e EventImpl) Author() string

func (EventImpl) Class

func (e EventImpl) Class() core.EventClass

func (EventImpl) Data

func (e EventImpl) Data(v interface{})

func (EventImpl) Entity

func (e EventImpl) Entity() core.Entity

func (EventImpl) ID

func (e EventImpl) ID() string

func (EventImpl) Source

func (e EventImpl) Source() string

func (EventImpl) Time

func (e EventImpl) Time() time.Time

func (EventImpl) Transaction

func (e EventImpl) Transaction() string

func (EventImpl) Trigger

func (e EventImpl) Trigger() core.Event

func (EventImpl) Type

func (e EventImpl) Type() string