tables

Documentation

Index

• func CreateQueueEntry(svc *dynamodb.DynamoDB, queueName, clientId string, entryTimestamp int64, ...) error
• func DeleteQueueEntry(svc *dynamodb.DynamoDB, queueName, clientId string, entryTimestamp int64, ...) error
• func IsQueueMemberZombie(lastUpdated int64) bool
• func WaitForTurn(svc *dynamodb.DynamoDB, queueName, clientId, tableName string) chan bool
• type QueueEntry

Functions

func CreateQueueEntry

func CreateQueueEntry(svc *dynamodb.DynamoDB, queueName, clientId string, entryTimestamp int64, tableName string, stopHeartBeat chan bool) error

func DeleteQueueEntry

func DeleteQueueEntry(svc *dynamodb.DynamoDB, queueName, clientId string, entryTimestamp int64, tableName string) error

func IsQueueMemberZombie

func IsQueueMemberZombie(lastUpdated int64) bool

func WaitForTurn

func WaitForTurn(svc *dynamodb.DynamoDB, queueName, clientId, tableName string) chan bool

Types

type QueueEntry

type QueueEntry struct {
	ClientId       string
	EntryTimestamp int64
	LastUpdated    int64
	Zombie         bool
	// contains filtered or unexported fields
}