event

Documentation

Index

• type Consumer
  • func NewKinesisConsumer(kinesis kinesisiface.KinesisAPI, processor Processor, streamName string) (Consumer, error)
  • func NewSQSConsumer(sqs sqsiface.SQSAPI, processor Processor, queueName string) (Consumer, error)
• type Processor
  • func NewProcessor(stores store.Stores) Processor

Types

type Consumer

type Consumer interface {
	PollForEvents(ctx context.Context)
}

Consumer defines methods to consume events from a queue

func NewKinesisConsumer

func NewKinesisConsumer(kinesis kinesisiface.KinesisAPI, processor Processor, streamName string) (Consumer, error)

func NewSQSConsumer

func NewSQSConsumer(sqs sqsiface.SQSAPI, processor Processor, queueName string) (Consumer, error)

type Processor

type Processor interface {
	ProcessEvent(event string) error
}

Processor defines methods to process events

func NewProcessor

func NewProcessor(stores store.Stores) Processor