data

Documentation

Index

• type Client
  • func NewClient(db *mongo.Client) *Client
  • func Open(uri string) (*Client, error)
  • func (c *Client) ListDatabaseNames(ctx context.Context, filter filters.Filter, ...) ([]string, error)
  • func (c *Client) ListDatabases(ctx context.Context, filter filters.Filter, ...) (mongo.ListDatabasesResult, error)
  • func (c *Client) UseSession(ctx context.Context, opts *options.SessionOptions, ...) error
  • func (c *Client) Watch(ctx context.Context, pipeline watch.WatchPipe, ...) (*mongo.ChangeStream, error)
  • func (c *Client) WithTransaction(ctx context.Context, ...) (interface{}, error)

Types

type Client

type Client struct {
	DB   *mongo.Client
	User *user.UserClient
}

Client .

func NewClient

func NewClient(db *mongo.Client) *Client

NewClient .

func Open

func Open(uri string) (*Client, error)

Open .

func (*Client) ListDatabaseNames

func (c *Client) ListDatabaseNames(ctx context.Context, filter filters.Filter, opts ...*options.ListDatabasesOptions) ([]string, error)

func (*Client) ListDatabases

func (c *Client) ListDatabases(ctx context.Context, filter filters.Filter, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)

func (*Client) UseSession

func (c *Client) UseSession(ctx context.Context, opts *options.SessionOptions, fn func(sessionContext mongo.SessionContext) error) error

func (*Client) Watch

func (c *Client) Watch(ctx context.Context, pipeline watch.WatchPipe, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

func (*Client) WithTransaction

func (c *Client) WithTransaction(ctx context.Context, fn func(sessCtx mongo.SessionContext) (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)