db

Documentation

Index

• type Client
  • func NewClient(address, username, password, database, collection string, ...) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) EnsureIndexes() error
  • func (c *Client) FindNotificationByPartialTransactionID(transactionID string) (model.InternalNotification, error)
  • func (c *Client) FindNotificationByTransactionID(transactionID string) (model.InternalNotification, error)
  • func (c *Client) GetLimit() int
  • func (c *Client) Ping() error
  • func (c *Client) ReadNotifications(offset int, since time.Time) (*[]model.InternalNotification, error)
  • func (c *Client) WriteNotification(notification *model.InternalNotification) error

Types

type Client

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

func NewClient

func NewClient(address, username, password, database, collection string, cacheDelay, maxLimit int, log *logger.UPPLogger) (*Client, error)

NewClient creates new client instance

func (*Client) Close

func (c *Client) Close() error

Close closes the entire database connection

func (*Client) EnsureIndexes

func (c *Client) EnsureIndexes() error

EnsureIndexes creates indexes

func (*Client) FindNotificationByPartialTransactionID

func (c *Client) FindNotificationByPartialTransactionID(transactionID string) (model.InternalNotification, error)

FindNotificationByPartialTransactionID locates one instance of a notification with the given Transaction ID (publishReference)

func (*Client) FindNotificationByTransactionID

func (c *Client) FindNotificationByTransactionID(transactionID string) (model.InternalNotification, error)

FindNotificationByTransactionID locates one instance of a notification with the given Transaction ID (publishReference)

func (*Client) GetLimit

func (c *Client) GetLimit() int

GetLimit returns the max number of records returned by a query

func (*Client) Ping

func (c *Client) Ping() error

Ping returns a database ping response

func (*Client) ReadNotifications

func (c *Client) ReadNotifications(offset int, since time.Time) (*[]model.InternalNotification, error)

ReadNotifications reads notifications from the collection.

func (*Client) WriteNotification

func (c *Client) WriteNotification(notification *model.InternalNotification) error

WriteNotification inserts a notification into database