mongo

Documentation

Index

• Constants
• Variables
• type Adapter
  • func New(ctx context.Context, c config.Mongo) (*Adapter, error)
  • func (a *Adapter) ClearAllSymbolListenersCount(ctx context.Context) error
  • func (a *Adapter) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pair string) error
  • func (a *Adapter) CreateIndexes() error
  • func (a *Adapter) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pair string) (int64, error)
  • func (a *Adapter) GetSymbolListenerSubscribers(ctx context.Context, exchange, pair string) (int64, error)
  • func (a *Adapter) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pair string) (int64, error)
  • func (a *Adapter) Reset(ctx context.Context) error

Constants

const (
	// CollectionName is the name of the collection in the database
	CollectionName = "symbol_listeners"
)

Variables

var (
	// ErrNilID is returned when the ID is nil
	ErrNilID = fmt.Errorf("ID is nil")
	// ErrNoDocument is returned when no document is found
	ErrNoDocument = fmt.Errorf("no document found")
)

Types

type Adapter

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

func New

func New(ctx context.Context, c config.Mongo) (*Adapter, error)

func (*Adapter) ClearAllSymbolListenersCount

func (a *Adapter) ClearAllSymbolListenersCount(ctx context.Context) error

func (*Adapter) ClearSymbolListenerSubscribers

func (a *Adapter) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pair string) error

func (*Adapter) CreateIndexes

func (a *Adapter) CreateIndexes() error

func (*Adapter) DecrementSymbolListenerSubscribers

func (a *Adapter) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pair string) (int64, error)

func (*Adapter) GetSymbolListenerSubscribers

func (a *Adapter) GetSymbolListenerSubscribers(ctx context.Context, exchange, pair string) (int64, error)

func (*Adapter) IncrementSymbolListenerSubscribers

func (a *Adapter) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pair string) (int64, error)

func (*Adapter) Reset

func (a *Adapter) Reset(ctx context.Context) error