datastore

Documentation

Index

• type MongoDB
  • func NewMongoDB() *MongoDB
  • func (mongodb MongoDB) AddTokenToQueue(id db.QueueId, token db.Token) (db.TokenId, error)
  • func (mongodb MongoDB) CreateQueue(queue db.Queue) (db.QueueId, error)
  • func (mongodb MongoDB) DeleteQueue(id db.QueueId) error
  • func (mongodb MongoDB) GetMaxToken(id db.QueueId) (uint32, error)
  • func (mongodb MongoDB) ReadQueue(id db.QueueId) (db.Queue, error)
  • func (mongodb MongoDB) ReadToken(id db.TokenId) (db.Token, error)
  • func (mongodb MongoDB) RemoveToken(id db.TokenId) error
  • func (mongodb MongoDB) SetIsPaused(id db.QueueId, isPaused bool) error
• type QueueStore

Types

type MongoDB

type MongoDB struct {
	Client *mongo.Client
	Queue  *mongo.Collection
	Token  *mongo.Collection
}

A Structure with Collections frequently used and a pointer to the client

func NewMongoDB

func NewMongoDB() *MongoDB

func (MongoDB) AddTokenToQueue

func (mongodb MongoDB) AddTokenToQueue(id db.QueueId, token db.Token) (db.TokenId, error)

func (MongoDB) CreateQueue

func (mongodb MongoDB) CreateQueue(queue db.Queue) (db.QueueId, error)

func (MongoDB) DeleteQueue

func (mongodb MongoDB) DeleteQueue(id db.QueueId) error

func (MongoDB) GetMaxToken

func (mongodb MongoDB) GetMaxToken(id db.QueueId) (uint32, error)

func (MongoDB) ReadQueue

func (mongodb MongoDB) ReadQueue(id db.QueueId) (db.Queue, error)

func (MongoDB) ReadToken

func (mongodb MongoDB) ReadToken(id db.TokenId) (db.Token, error)

func (MongoDB) RemoveToken

func (mongodb MongoDB) RemoveToken(id db.TokenId) error

func (MongoDB) SetIsPaused

func (mongodb MongoDB) SetIsPaused(id db.QueueId, isPaused bool) error

type QueueStore

type QueueStore interface {
	// Create a new queue and return the queue ID.
	CreateQueue(db.Queue) (db.QueueId, error)

	// Read a queue by id.
	ReadQueue(db.QueueId) (db.Queue, error)

	// Set the queue pause status to true/false
	SetIsPaused(db.QueueId, bool) error

	// Set the queue delete status to new value.
	DeleteQueue(db.QueueId) error

	// Add a new token to the queue.
	AddTokenToQueue(db.QueueId, db.Token) (db.TokenId, error)

	// Read token by id.
	ReadToken(db.TokenId) (db.Token, error)

	// Delete token
	RemoveToken(db.TokenId) error
}

var Store QueueStore = NewMongoDB()