utils

Documentation

Index

• Variables
• func GetLastStreamArn(ctx context.Context, db dynamodbiface.DynamoDBAPI, table string) (*string, error)
• func GetShardId(ctx context.Context, dbStreams dynamodbstreamsiface.DynamoDBStreamsAPI, ...) (*string, error)

Variables

var (
	// ErrNoStreamArn is returned when no stream ARN is found
	ErrNoStreamArn = errors.New("no stream ARN found")
)

Functions

func GetLastStreamArn

func GetLastStreamArn(ctx context.Context, db dynamodbiface.DynamoDBAPI, table string) (*string, error)

func GetShardId

func GetShardId(ctx context.Context, dbStreams dynamodbstreamsiface.DynamoDBStreamsAPI, previousShardId *string, streamArn *string) (*string, error)