core

Oct 31, 2021

Changes in this version

+ type Publisher interface

+ Send func(message proto.Message) error

+ func NewPublisher(conf config.Config, logger log.Logger) Publisher

+ type SqsPublisher struct

+ func (publisher *SqsPublisher) Send(message proto.Message) error

Oct 25, 2021

Changes in this version

type Collector

+ func NewContinuousCollector(datasource Collector, logger log.Logger) Collector

+ type ContinuousCollector struct

+ func (collector *ContinuousCollector) Run(ctx context.Context) error

Oct 13, 2021

Changes in this version

+ type EventHandlerS3 struct

+ func (handler *EventHandlerS3) Handle(ctx context.Context, event awsevents.S3Event) error

+ type S3EventHandler interface

+ Handle func(ctx context.Context, event awsevents.S3Event) error

+ func NewS3EventHandler(queue string, processor S3EventProcessor, conf config.Config, ...) S3EventHandler

+ type S3EventProcessor interface

+ ProcessEvent func(entity awsevents.S3Entity, content []byte) (proto.Message, error)

Sep 18, 2021

Changes in this version

+ type SqsEventProcessor interface

+ Handle func(ctx context.Context, sqsEvent events.SQSEvent) error

Sep 9, 2021

Changes in this version

+ const ORIGIN_QUEUE

+ type Collector interface

+ Run func() error

+ func NewScheduledCollector(queue string, datasource DataSource, conf config.Config, logger log.Logger) Collector

+ type ScheduledCollector struct

+ func (collector *ScheduledCollector) Run() error

Sep 1, 2021

Changes in this version

+ type DataSource interface

+ Fetch func() (interface{}, error)