impl

package
v0.16.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 8, 2022 License: MIT Imports: 15 Imported by: 3

Documentation

Index

Constants

View Source 
const AwsContext = "AwsContext"
View Source 
const RecordSizeLimit = 960

Variables

This section is empty.

Functions

func GetContent added in v0.9.0 

func GetContent(
	ctx context.Context,
	contentLocation string,
	contentEncoding string,
	content []byte) []byte

func GetEventContent added in v0.9.0 

func GetEventContent(
	ctx context.Context,
	contentLocation string,
	contentEncoding string,
	contentType string,
	content []byte) *model.AwsEventRecord

func NewEntity added in v0.9.0 

func NewEntity(ctx context.Context,
	stateRecord *model.AwsStateRecord,
	eventRecord *model.AwsEventRecord) core.Entity

func NewEntityPage added in v0.9.0 

func NewEntityPage(ctx context.Context, record *model.AwsStateRecordPage) core.EntityPage

func NewEvent 

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

func NewEventFactory 

func NewEventFactory() core.EventFactory

func NewEventPage added in v0.9.0 

func NewEventPage(ctx context.Context, record *model.AwsEventRecordPage) core.EventPage

func NewEventStore 

func NewEventStore(eventStore model.AwsEventStore) core.EventStore

func NewStateStore 

func NewStateStore(eventStore model.AwsEventStore, stateStore model.AwsStateStore) core.StateStore

func NewVersion added in v0.9.0 

func NewVersion(record *model.AwsEventHeaderRecord) core.Version

func NewVersionPage added in v0.9.0 

func NewVersionPage(record *model.AwsEventHeaderRecordPage) core.VersionPage

Types

type Context added in v0.4.0 

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

type EntityImpl added in v0.4.0 

type EntityImpl struct {
	Context     context.Context
	EventRecord *model.AwsEventRecord
	StateRecord *model.AwsStateRecord
}

func (EntityImpl) CreatedAt added in v0.4.0 

func (e EntityImpl) CreatedAt() time.Time

func (EntityImpl) CreatedBy added in v0.4.0 

func (e EntityImpl) CreatedBy() string

func (EntityImpl) ID added in v0.4.0 

func (e EntityImpl) ID() string

func (EntityImpl) IsDeleted added in v0.16.0 

func (e EntityImpl) IsDeleted() bool

func (*EntityImpl) State added in v0.4.0 

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

func (EntityImpl) Type added in v0.4.0 

func (e EntityImpl) Type() string

func (EntityImpl) UpdatedAt added in v0.4.0 

func (e EntityImpl) UpdatedAt() time.Time

func (EntityImpl) UpdatedBy added in v0.4.0 

func (e EntityImpl) UpdatedBy() string

func (EntityImpl) Version added in v0.4.0 

func (e EntityImpl) Version() uint64

type EntityPageImpl added in v0.9.0 

type EntityPageImpl struct {
	Ctx    context.Context
	Record *model.AwsStateRecordPage
}

func (EntityPageImpl) Items added in v0.9.0 

func (e EntityPageImpl) Items() []core.Entity

func (EntityPageImpl) NextToken added in v0.9.0 

func (e EntityPageImpl) NextToken() string

type EventImpl added in v0.4.0 

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

func (EventImpl) Author added in v0.4.0 

func (e EventImpl) Author() string

func (EventImpl) Class added in v0.4.0 

func (e EventImpl) Class() core.EventClass

func (*EventImpl) Data added in v0.4.0 

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

func (EventImpl) Entity added in v0.4.0 

func (e EventImpl) Entity() core.Entity

func (EventImpl) ID added in v0.4.0 

func (e EventImpl) ID() string

func (EventImpl) Source added in v0.4.0 

func (e EventImpl) Source() string

func (EventImpl) Time added in v0.4.0 

func (e EventImpl) Time() time.Time

func (EventImpl) Transaction added in v0.4.0 

func (e EventImpl) Transaction() string

func (EventImpl) Trigger added in v0.4.0 

func (e EventImpl) Trigger() core.Event

func (EventImpl) Type added in v0.4.0 

func (e EventImpl) Type() string

type EventPageImpl added in v0.9.0 

type EventPageImpl struct {
	Ctx    context.Context
	Record *model.AwsEventRecordPage
}

func (EventPageImpl) Items added in v0.9.0 

func (e EventPageImpl) Items() []core.Event

func (EventPageImpl) NextToken added in v0.9.0 

func (e EventPageImpl) NextToken() string

type VersionImpl added in v0.9.0 

type VersionImpl struct {
	Record *model.AwsEventHeaderRecord
}

func (VersionImpl) Author added in v0.15.0 

func (v VersionImpl) Author() string

func (VersionImpl) ID added in v0.9.0 

func (v VersionImpl) ID() uint64

func (VersionImpl) Time added in v0.9.0 

func (v VersionImpl) Time() time.Time

type VersionPageImpl added in v0.9.0 

type VersionPageImpl struct {
	Record *model.AwsEventHeaderRecordPage
}

func (VersionPageImpl) Items added in v0.9.0 

func (e VersionPageImpl) Items() []core.Version

func (VersionPageImpl) NextToken added in v0.9.0 

func (e VersionPageImpl) NextToken() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.