k2v

type BatchInsertItem struct {
	PartitionKey   string  `json:"pk"`
	SortKey        string  `json:"sk"`
	CausalityToken *string `json:"ct"`
	Value          Item    `json:"v"`
}

type BatchSearch struct {
	PartitionKey string `json:"partitionKey"`

	// Prefix restricts listing to partition keys that start with this value.
	Prefix string `json:"prefix,omitempty"`

	// Start is the first partition key to list, in lexicographical order.
	Start string `json:"start,omitempty"`

	// End is the last partition key to list (excluded).
	End string `json:"end,omitempty"`

	// Limit for maximum number of partition keys to list.
	Limit int `json:"limit,omitempty"`

	// Reverse iterates in reverse lexicographical order.
	Reverse bool `json:"reverse,omitempty"`

	// SingleItem determines whether to return only the item with sort key start.
	SingleItem bool `json:"singleItem,omitempty"`

	// ConflictsOnly determines whether to return only items that have several concurrent values.
	ConflictsOnly bool `json:"conflictsOnly,omitempty"`

	// Tombstones determines whether or not to return tombstone lines to indicate the presence of old deleted items.
	Tombstones bool `json:"tombstones,omitempty"`
}

type BatchSearchResult struct {
	PartitionKey  string             `json:"partitionKey"`
	Prefix        *string            `json:"prefix"`
	Start         *string            `json:"start"`
	End           *string            `json:"end"`
	Limit         *int               `json:"limit"`
	Reverse       bool               `json:"reverse"`
	SingleItem    bool               `json:"singleItem"`
	ConflictsOnly bool               `json:"conflictsOnly"`
	Tombstones    bool               `json:"tombstones"`
	Items         []SearchResultItem `json:"items"`
	More          bool               `json:"more"`
	NextStart     *string            `json:"nextStart"`
}

type BatchSearchResultHandler func(result *BatchSearchResult) error

type BatchSearchScroller interface {
	ReadBatch(ctx context.Context, b Bucket, q []BatchSearch) ([]*BatchSearchResult, error)
}

type Bucket string

type BulkGetItem struct {
	PartitionKey   string
	SortKey        string
	CausalityToken CausalityToken
	Values         []Item
}

type CausalityToken string

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

type ClientOption func(*Client)

type IndexScroller interface {
	ReadIndex(ctx context.Context, b Bucket, q ReadIndexQuery) (*ReadIndexResponse, error)
}

type Item []byte

type ItemKey struct {
	PartitionKey string
	SortKey      string
}

type Key struct {
	ID     string
	Secret string
}

type PollRangeQuery struct {
	// Prefix restricts items to poll to those whose sort keys start with this prefix.
	Prefix string `json:"prefix,omitempty"`

	// Start is the sort key of the first item to poll.
	Start string `json:"start,omitempty"`

	// End is the sort key of the last item to poll (excluded).
	End string `json:"end,omitempty"`

	// SeenMarker is an opaque string returned by a previous PollRange call, that represents items already seen.
	SeenMarker string `json:"seenMarker,omitempty"`
}

type PollRangeResponse struct {
	SeenMarker string             `json:"seenMarker"`
	Items      []SearchResultItem `json:"items"`
}

type ReadIndexQuery struct {
	// Prefix restricts listing to partition keys that start with this value.
	Prefix string

	// Start is the first partition key to list, in lexicographical order.
	Start string

	// End is the last partition key to list (excluded).
	End string

	// Limit for maximum number of partition keys to list.
	Limit int

	// Reverse iterates in reverse lexicographical order.
	Reverse bool
}

type ReadIndexResponse struct {
	Prefix        *string                         `json:"prefix"`
	Start         *string                         `json:"start"`
	End           *string                         `json:"end"`
	Limit         *int                            `json:"limit"`
	Reverse       bool                            `json:"reverse"`
	PartitionKeys []ReadIndexResponsePartitionKey `json:"partitionKeys"`
	More          bool                            `json:"more"`
	NextStart     *string                         `json:"nextStart"`
}

type ReadIndexResponseHandler func(resp *ReadIndexResponse) error

type ReadIndexResponsePartitionKey struct {
	PK        string `json:"pk"`
	Entries   int    `json:"entries"`
	Conflicts int    `json:"conflicts"`
	Values    int    `json:"values"`
	Bytes     int    `json:"bytes"`
}

type RequestMiddleware func(*http.Request) error

type SearchResultItem struct {
	SortKey        string `json:"sk"`
	CausalityToken string `json:"ct"`
	Values         []Item `json:"v"`
}