core

type Collector interface {

	// Run executes collectors data processing logic.
	Run(context.Context) error
}

type ContinuousCollector struct {
	// contains filtered or unexported fields
}

type DataSource interface {

	// Fetch will retrieve new data and returns it as an event from central event lib.
	// For more details about events see https://github.com/tommzn/hdb-events-go
	Fetch() (proto.Message, error)
}

type EventHandlerS3 struct {
	// contains filtered or unexported fields
}

type Publisher interface {

	// Send will publish passed message to given queues.
	Send(message proto.Message) error
}

type S3EventHandler interface {

	// Handle processes passed S3 event.
	Handle(ctx context.Context, event awsevents.S3Event) error
}

type S3EventProcessor interface {

	// Process is called to process given event for a S3 object.
	// If download option is enable via config it will pass S3 object content as well.
	ProcessEvent(entity awsevents.S3Entity, content []byte) (proto.Message, error)
}

type ScheduledCollector struct {
	// contains filtered or unexported fields
}

type SqsEventProcessor interface {

	// Handle processes given SQS events.
	Handle(ctx context.Context, sqsEvent events.SQSEvent) error
}

type SqsPublisher struct {
	// contains filtered or unexported fields
}