dynago

type AttrCondition map[string]Condition

type AttributeDefinition struct {
	AttributeName string
	AttributeType string
}

type AttributeNameValue map[string]AttributeValue

type AttributeValue map[string]interface{}

type Condition struct {
	ComparisonOperator string
	AttributeValueList []AttributeValue
}

type ConsumedCapacityDescription struct {
	CapacityUnits float32
	TableName     string
}

type CreateTableRequest struct {
	TableName             string
	ProvisionedThroughput ProvisionedThroughputRequest
	AttributeDefinitions  []AttributeDefinition
	KeySchema             []KeySchemaElement
	LocalSecondaryIndexes []LocalSecondaryIndexRequest
	StreamSpecification   StreamSpecification
}

type CreateTableResult struct {
	TableDescription TableDescription
}

type DBClient struct {
	dydb.DB
}

type DeleteTableRequest struct {
	TableName string
}

type DeleteTableResult struct {
	Table TableDescription
}

type DescribeStreamOption func(*DescribeStreamRequest)

type DescribeStreamRequest struct {
	StreamId              string
	Limit                 int    `json:",omitempty"`
	ExclusiveStartShardId string `json:",omitempty"`
}

type DescribeStreamResult struct {
	StreamDescription StreamDescription
}

type DescribeTableRequest struct {
	TableName string
}

type DescribeTableResult struct {
	Table TableDescription
}

type EpochTime struct {
	time.Time
}

type GetItemRequest struct {
	TableName              string
	Key                    AttributeNameValue
	AttributesToGet        []string `json:",omitempty"`
	ConsistentRead         bool
	ReturnConsumedCapacity string `json:",omitempty"`
}

type GetItemResult struct {
	ConsumedCapacity ConsumedCapacityDescription

	Item Item
}

type GetRecordsRequest struct {
	ShardIterator string
	Limit         int `json:",omitempty"`
}

type GetRecordsResult struct {
	NextShardIterator string
	Records           []Record
}

type GetShardIteratorRequest struct {
	StreamId          string
	ShardId           string
	ShardIteratorType string // TRIM_HORIZON | LATEST | AT_SEQUENCE_NUMBER | AFTER_SEQUENCE_NUMBER
	SequenceNumber    string `json:",omitempty"`
}

type GetShardIteratorResult struct {
	ShardIterator string
}

type Item map[string]interface{}

type ItemCollectionMetrics struct {
	ItemCollectionKey   AttributeNameValue
	SizeEstimateRangeGB []float64
}

type ItemOption func(*ItemRequest)

type ItemRequest struct {
	TableName string

	Item             *Item              `json:",omitempty"` // PutItem
	Key              AttributeNameValue `json:",omitempty"` // UpdateItem/DeleteItem
	UpdateExpression string             `json:",omitempty"` // UpdateItem

	ConditionExpression       string             `json:",omitempty"`
	ExpressionAttributeNames  map[string]string  `json:",omitempty"`
	ExpressionAttributeValues AttributeNameValue `json:",omitempty"`

	ReturnConsumedCapacity      string `json:",omitempty"` // INDEXED | TOTAL | NONE
	ReturnItemCollectionMetrics string `json:",omitempty"` // SIZE | NONE
	ReturnValues                string `json:",omitempty"` // NONE | ALL_OLD | UPDATED_OLD | ALL_NEW | UPDATED_NEW
}

type ItemResult struct {
	Attributes            Item
	ConsumedCapacity      ConsumedCapacityDescription
	ItemCollectionMetrics ItemCollectionMetrics
}

type KeySchemaElement struct {
	AttributeName string
	KeyType       string
}

type KeyValue struct {
	Key   AttributeDefinition
	Value interface{}
}

type ListStreamsOption func(*ListStreamsRequest)

type ListStreamsRequest struct {
	TableName          string `json:",omitempty"`
	Limit              int    `json:",omitempty"`
	ExclusiveStartItem string `json:",omitempty"`
}

type ListStreamsResult struct {
	LastEvaluatedStreamId string
	StreamIds             []string
}

type ListTablesResult struct {
	TableNames []string
}

type LocalSecondaryIndexDescription struct {
	IndexName      string
	IndexSizeBytes int64
	ItemCount      int64

	KeySchema  []KeySchemaElement
	Projection ProjectionDescription
}

type LocalSecondaryIndexRequest struct {
	IndexName  string
	KeySchema  []KeySchemaElement
	Projection ProjectionDescription
}

type ProjectionDescription struct {
	NonKeyAttributes []string
	ProjectionType   string
}

type ProvisionedThroughputDescription struct {
	LastDecreaseDateTime   EpochTime
	LastIncreaseDateTime   EpochTime
	NumberOfDecreasesToday int
	ReadCapacityUnits      int
	WriteCapacityUnits     int
}

type ProvisionedThroughputRequest struct {
	ReadCapacityUnits  int
	WriteCapacityUnits int
}

type QueryRequest struct {
	TableName        string
	AttributesToGet  []string `json:",omitempty"` // deprecated
	ScanIndexForward bool

	ExclusiveStartKey AttributeNameValue   `json:",omitempty"`
	KeyConditions     map[string]Condition `json:",omitempty"` // deprecated
	IndexName         string               `json:",omitempty"`

	KeyConditionExpression    string             `json:",omitempty"`
	FilterExpression          string             `json:",omitempty"`
	ProjectionExpression      string             `json:",omitempty"`
	ExpressionAttributeNames  map[string]string  `json:",omitempty"`
	ExpressionAttributeValues AttributeNameValue `json:",omitempty"`

	Limit                  *int   `json:",omitempty"`
	Select                 string `json:",omitempty"`
	ReturnConsumedCapacity string `json:",omitempty"`
	// contains filtered or unexported fields
}

type QueryResult struct {
	Items            []Item
	ConsumedCapacity ConsumedCapacityDescription
	LastEvaluatedKey AttributeNameValue
	Count            int
	ScannedCount     int
}

type Record struct {
	AwsRegion    string       `json:"awsRegion"`
	Dynamodb     StreamRecord `json:"dynamodb"`
	EventID      string       `json:"eventID"`
	EventName    string       `json:"eventName"`
	EventSource  string       `json:"eventSource"`
	EventVersion string       `json:"eventVersion"`
}

type ScanRequest struct {
	TableName string
	//AttributesToGet   []string    // use ProjectionExpression instead
	ExclusiveStartKey AttributeNameValue

	FilterExpression          string             `json:",omitempty"`
	ProjectionExpression      string             `json:",omitempty"`
	ExpressionAttributeNames  map[string]string  `json:",omitempty"`
	ExpressionAttributeValues AttributeNameValue `json:",omitempty"`

	Limit                  *int   `json:",omitempty"`
	Segment                *int   `json:",omitempty"`
	TotalSegments          *int   `json:",omitempty"`
	Select                 string `json:",omitempty"`
	ReturnConsumedCapacity string `json:",omitempty"`
	// contains filtered or unexported fields
}

type SequenceNumberRange struct {
	StartingSequenceNumber string
	EndingSequenceNumber   string
}

type ShardDescription struct {
	ShardId             string
	ParentShardId       string
	SequenceNumberRange SequenceNumberRange
}

type StreamDescription struct {
	TableName               string
	KeySchema               []KeySchemaElement
	CreationRequestDateTime EpochTime
	StreamARN               string
	StreamId                string
	StreamStatus            string
	StreamViewType          string
	LastEvaluatedShardId    string
	Shards                  []ShardDescription
}

type StreamRecord struct {
	Keys           Item
	NewImage       Item
	OldImage       Item
	SequenceNumber string
	SizeBytes      int64
	StreamViewType string
}

type StreamSpecification struct {
	StreamEnabled  bool
	StreamViewType string `json:",omitempty"`
}

type TableDescription struct {
	AttributeDefinitions []AttributeDefinition

	CreationDateTime EpochTime
	ItemCount        int64

	KeySchema             []KeySchemaElement
	LocalSecondaryIndexes []LocalSecondaryIndexDescription
	ProvisionedThroughput ProvisionedThroughputDescription

	TableName      string
	TableSizeBytes int64
	TableStatus    string

	StreamSpecification StreamSpecification
}

type TableInstance struct {
	DB   *DBClient
	Name string
	Keys map[string]*AttributeDefinition
}

type UpdateTableRequest struct {
	TableName string

	ProvisionedThroughput *ProvisionedThroughputRequest `json:",omitempty"`
	StreamSpecification   *StreamSpecification          `json:",omitempty"`
}

type UpdateTableResult struct {
	TableDescription TableDescription
}