consumer

Documentation

Index

• type Config
• type Consumer
  • func NewConsumer(cfg Config, l *zap.Logger) (*Consumer, error)
  • func (c *Consumer) Listen()
• type ShardIterator

Types

type Config

type Config struct {
	StreamName      *string
	Region          *string
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
}

type Consumer

type Consumer struct {
	ShardIterator []*ShardIterator
	ChData        chan string
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(cfg Config, l *zap.Logger) (*Consumer, error)

func (*Consumer) Listen

func (c *Consumer) Listen()

type ShardIterator

type ShardIterator struct {
	ID       string
	Iterator *kinesis.GetShardIteratorOutput
	Position *string
}