mongo

Documentation

Index

• type DataSourceSession
  • func (d *DataSourceSession) CreateUserDataSource(ctx context.Context, userID string, create *data.DataSourceCreate) (*data.DataSource, error)
  • func (d *DataSourceSession) DeleteDataSource(ctx context.Context, id string) error
  • func (d *DataSourceSession) EnsureIndexes() error
  • func (d *DataSourceSession) GetDataSource(ctx context.Context, id string) (*data.DataSource, error)
  • func (d *DataSourceSession) ListUserDataSources(ctx context.Context, userID string, filter *data.DataSourceFilter, ...) (data.DataSources, error)
  • func (d *DataSourceSession) UpdateDataSource(ctx context.Context, id string, update *data.DataSourceUpdate) (*data.DataSource, error)
• type Store
  • func NewStore(cfg *mongo.Config, lgr log.Logger) (*Store, error)
  • func (s *Store) EnsureIndexes() error
  • func (s *Store) NewDataSourceSession() store.DataSourceSession

Types

type DataSourceSession

type DataSourceSession struct {
	*mongo.Session
}

func (*DataSourceSession) CreateUserDataSource

func (d *DataSourceSession) CreateUserDataSource(ctx context.Context, userID string, create *data.DataSourceCreate) (*data.DataSource, error)

func (*DataSourceSession) DeleteDataSource

func (d *DataSourceSession) DeleteDataSource(ctx context.Context, id string) error

func (*DataSourceSession) EnsureIndexes

func (d *DataSourceSession) EnsureIndexes() error

func (*DataSourceSession) GetDataSource

func (d *DataSourceSession) GetDataSource(ctx context.Context, id string) (*data.DataSource, error)

func (*DataSourceSession) ListUserDataSources

func (d *DataSourceSession) ListUserDataSources(ctx context.Context, userID string, filter *data.DataSourceFilter, pagination *page.Pagination) (data.DataSources, error)

func (*DataSourceSession) UpdateDataSource

func (d *DataSourceSession) UpdateDataSource(ctx context.Context, id string, update *data.DataSourceUpdate) (*data.DataSource, error)

type Store

type Store struct {
	*mongo.Store
}

func NewStore

func NewStore(cfg *mongo.Config, lgr log.Logger) (*Store, error)

func (*Store) EnsureIndexes

func (s *Store) EnsureIndexes() error

func (*Store) NewDataSourceSession

func (s *Store) NewDataSourceSession() store.DataSourceSession