rethink

Documentation

Index

• func NewAuth(c *Client) *authStorage
• func NewCatalog(c *Client, lg logging.Logger) dotagiftx.CatalogStorage
• func NewDelivery(c *Client) dotagiftx.DeliveryStorage
• func NewInventory(c *Client) dotagiftx.InventoryStorage
• func NewItem(c *Client) dotagiftx.ItemStorage
• func NewMarket(c *Client) dotagiftx.MarketStorage
• func NewQueue(c *Client) *taskStorage
• func NewReport(c *Client) dotagiftx.ReportStorage
• func NewStats(c *Client, lg logging.Logger) dotagiftx.StatsStorage
• func NewTrack(c *Client) *trackStorage
• func NewUser(c *Client) dotagiftx.UserStorage
• type Client
  • func New(c Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) ListenChangeFeed(table string, exec func(prev, next []byte) error) error
  • func (c *Client) SetTracer(t *tracing.Tracer)
• type Config
• type SpanStorage
  • func NewSpan(c *Client) *SpanStorage
  • func (s *SpanStorage) Add(name string, elapsedMs int64, t time.Time)

Functions

func NewAuth

func NewAuth(c *Client) *authStorage

NewAuth creates a new instance of auth data store.

func NewCatalog

func NewCatalog(c *Client, lg logging.Logger) dotagiftx.CatalogStorage

NewCatalog creates new instance of catalog data store.

func NewDelivery

func NewDelivery(c *Client) dotagiftx.DeliveryStorage

NewDelivery creates new instance of delivery data store.

func NewInventory

func NewInventory(c *Client) dotagiftx.InventoryStorage

NewInventory creates new instance of inventory data store.

func NewItem

func NewItem(c *Client) dotagiftx.ItemStorage

NewItem creates new instance of item data store.

func NewMarket

func NewMarket(c *Client) dotagiftx.MarketStorage

NewMarket creates new instance of market data store.

func NewQueue

func NewQueue(c *Client) *taskStorage

func NewReport

func NewReport(c *Client) dotagiftx.ReportStorage

NewReport creates new instance of report data store.

func NewStats

func NewStats(c *Client, lg logging.Logger) dotagiftx.StatsStorage

NewStats creates new instance of market data store.

func NewTrack

func NewTrack(c *Client) *trackStorage

NewTrack creates new instance of track data store.

func NewUser

func NewUser(c *Client) dotagiftx.UserStorage

NewUser creates new instance of user data store.

Types

type Client

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

Client represents rethink database client.

func New

func New(c Config) (*Client, error)

New create new rethink database instance.

func (*Client) Close

func (c *Client) Close() error

Close ends rethink database session.

func (*Client) ListenChangeFeed

func (c *Client) ListenChangeFeed(table string, exec func(prev, next []byte) error) error

func (*Client) SetTracer

func (c *Client) SetTracer(t *tracing.Tracer)

type Config

type Config struct {
	Addr string
	Name string
	User string
	Pass string
}

Config represents rethink database config.

type SpanStorage

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

func NewSpan

func NewSpan(c *Client) *SpanStorage

func (*SpanStorage) Add

func (s *SpanStorage) Add(name string, elapsedMs int64, t time.Time)