inputdynamodb

Documentation

Index

• func DecodeItem(item map[string]types.AttributeValue) ([]byte, error)
• type InputDynamoDbClient
  • func NewInputDynamoDbClient(conf InputDynamoDbClientConfig) (InputDynamoDbClient, error)
  • func (client InputDynamoDbClient) Connect(ctx context.Context, writer gallon.WriteCloser) error
• type InputDynamoDbClientConfig

Functions

func DecodeItem

func DecodeItem(item map[string]types.AttributeValue) ([]byte, error)

Types

type InputDynamoDbClient

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

func NewInputDynamoDbClient

func NewInputDynamoDbClient(conf InputDynamoDbClientConfig) (InputDynamoDbClient, error)

func (InputDynamoDbClient) Connect

func (client InputDynamoDbClient) Connect(
	ctx context.Context,
	writer gallon.WriteCloser,
) error

type InputDynamoDbClientConfig

type InputDynamoDbClientConfig struct {
	TableName string
	Region    string
	PageLimit *int
	PageSize  *int32
	Decoder   func(item map[string]types.AttributeValue) (gallon.Record, error)
}