consumer

README

ddbstreams-consumer

Usage

import (
	consumer "github.com/atsushi-ishibashi/ddbstreams-consumer"
)

func main() {
	c, err := consumer.New("<AppName>", "<DynamoDBStreams ARN>", "<DynamoDB TableName>")
	if err != nil {
		log.Fatalln(err)
	}

	queue := c.GetChannel()
	for v := range queue {
		// do something
	}
}

Documentation

Index

• Variables
• type Consumer
  • func New(appName, streamName, tableName string) (Consumer, error)

Variables

var (
	ErrInvalidMaxWait    = errors.New("invalid max wait")
	ErrInvalidChannelCap = errors.New("invalid channel cap")
)

Types

type Consumer

type Consumer interface {
	SetMaxWait(i int) error
	SetChannelCap(i int) error
	GetChannel() <-chan *dynamodbstreams.Record
}

func New

func New(appName, streamName, tableName string) (Consumer, error)