mongo

Documentation

Index

• Constants
• Variables
• type Adapter
  • func New(ctx context.Context, c config.Mongo) (*Adapter, error)
  • func (a *Adapter) CreateExchanges(ctx context.Context, exchanges ...exchange.Exchange) error
  • func (a *Adapter) CreateIndexes() error
  • func (a *Adapter) DeleteExchanges(ctx context.Context, names ...string) error
  • func (a *Adapter) ReadExchanges(ctx context.Context, names ...string) ([]exchange.Exchange, error)
  • func (a *Adapter) Reset(ctx context.Context) error
  • func (a *Adapter) UpdateExchanges(ctx context.Context, exchanges ...exchange.Exchange) error

Constants

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

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) CreateExchanges

func (a *Adapter) CreateExchanges(ctx context.Context, exchanges ...exchange.Exchange) error

func (*Adapter) CreateIndexes

func (a *Adapter) CreateIndexes() error

func (*Adapter) DeleteExchanges

func (a *Adapter) DeleteExchanges(ctx context.Context, names ...string) error

func (*Adapter) ReadExchanges

func (a *Adapter) ReadExchanges(ctx context.Context, names ...string) ([]exchange.Exchange, error)

func (*Adapter) Reset

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

func (*Adapter) UpdateExchanges

func (a *Adapter) UpdateExchanges(ctx context.Context, exchanges ...exchange.Exchange) error