batches

type Batch[T any] struct {
	// contains filtered or unexported fields
}

type BatchProcessor interface {
	Monitor(monitor Monitor) BatchProcessor
	Put(items ...WriteItemFunc) BatchProcessor
	Delete(items ...WriteItemFunc) BatchProcessor
	Run(ctx context.Context, cli WriteClient, opt ...options.Option) error
}

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

type DeleteKeyFunc func(v any) map[string]types.AttributeValue

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

type GetClient interface {
	BatchGetItem(ctx context.Context, params *dynamodb.BatchGetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.BatchGetItemOutput, error)
}

type Monitor func(items map[string][]types.WriteRequest, err error) error

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

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

type WriteClient interface {
	BatchWriteItem(ctx context.Context, params *dynamodb.BatchWriteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.BatchWriteItemOutput, error)
}

type WriteItemFunc func() (table string, item map[string]types.AttributeValue, err error)