db

Documentation

Index

• func DatabaseInstance() apis.DataStorage
• func MakeItemPrefix(serviceId string) string
• func MakePayloadPrefix(serviceId string) string
• func SetDatabase(ds apis.DataStorage)
• type DBService
  • func (d *DBService) CacheAllItemData(itemId string, metaData, payload []byte)
  • func (d *DBService) CacheItemData(itemId string, itemData []byte)
  • func (d *DBService) DeleteAllItemData(itemId string)
  • func (d *DBService) InitServiceDB(serviceId string)
  • func (d *DBService) ItemIterator() apis.ItemIterator
  • func (d *DBService) Payload(itemId string) []byte
  • func (d *DBService) WaitFlush()

Functions

func DatabaseInstance

func DatabaseInstance() apis.DataStorage

GetDatabase returns DataStorage singleton.

func MakeItemPrefix

func MakeItemPrefix(serviceId string) string

MakeItemPrefix makes a prefix which will be used to identify to which service item belongs to.

func MakePayloadPrefix

func MakePayloadPrefix(serviceId string) string

MakePayloadPrefix makes a prefix which will be used to identify to which service payload belongs to.

func SetDatabase

func SetDatabase(ds apis.DataStorage)

Types

type DBService

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

func (*DBService) CacheAllItemData

func (d *DBService) CacheAllItemData(itemId string, metaData, payload []byte)

CacheAllItemData stores messages data and payload data into database.

func (*DBService) CacheItemData

func (d *DBService) CacheItemData(itemId string, itemData []byte)

CacheItemData stores only message metadata in the database.

func (*DBService) DeleteAllItemData

func (d *DBService) DeleteAllItemData(itemId string)

DeleteAllItemData removes item from database including its payload.

func (*DBService) InitServiceDB

func (d *DBService) InitServiceDB(serviceId string)

func (*DBService) ItemIterator

func (d *DBService) ItemIterator() apis.ItemIterator

ItemIterator returns an iterator over items which are matching provided prefix.

func (*DBService) Payload

func (d *DBService) Payload(itemId string) []byte

Payload returns message payload.

func (*DBService) WaitFlush

func (d *DBService) WaitFlush()