ddb

Documentation

Index

• func MarshalKey(chatID int64) map[string]*dynamodb.AttributeValue
• func MarshalMap(in interface{}) map[string]*dynamodb.AttributeValue
• type DDBChatStateMap
  • func NewDDBChatStateMap(table string) DDBChatStateMap
  • func (ddb DDBChatStateMap) Get(chatID int64) (*chatstate.ChatState, func())
  • func (ddb DDBChatStateMap) Unlock(chatID int64, cs *chatstate.ChatState)
• type DDBChatStateMapItem

Functions

func MarshalKey

func MarshalKey(chatID int64) map[string]*dynamodb.AttributeValue

func MarshalMap

func MarshalMap(in interface{}) map[string]*dynamodb.AttributeValue

Types

type DDBChatStateMap

type DDBChatStateMap struct {
	*dynamodb.DynamoDB
	Table string
}

func NewDDBChatStateMap

func NewDDBChatStateMap(table string) DDBChatStateMap

func (DDBChatStateMap) Get

func (ddb DDBChatStateMap) Get(chatID int64) (*chatstate.ChatState, func())

func (DDBChatStateMap) Unlock

func (ddb DDBChatStateMap) Unlock(chatID int64, cs *chatstate.ChatState)

type DDBChatStateMapItem

type DDBChatStateMapItem struct {
	ID      int64
	Expired time.Time `dynamodbav:",unixtime"` // Time at which DDB can erase this item.
	Locked  time.Time `dynamodbav:",unixtime"` // Time until which this item is locked by the handler, or 0.
	CS      []byte
}