mongo

Documentation

Index

• Variables
• func ConnectAndPing(ctx context.Context, authenticatedUri string) error
• func FailsWithAuthError(err error) bool
• type Client
  • func NewClient(ctx context.Context, uri string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) DeleteUser(ctx context.Context, dbName string, username string) error
  • func (c *Client) Ping(ctx context.Context) error
  • func (c *Client) UpdateUserPassword(ctx context.Context, dbName string, userName string, password string) error
  • func (c *Client) UpsertUser(ctx context.Context, dbName string, userName string, password string) error
  • func (c *Client) UserExists(ctx context.Context, dbName string, userName string) (bool, error)
• type ErrUserExists
  • func (e ErrUserExists) Error() string

Variables

var ErrNotConnected = fmt.Errorf("is not connected to db yet, call Connect() method")

Functions

func ConnectAndPing

func ConnectAndPing(ctx context.Context, authenticatedUri string) error

func FailsWithAuthError

func FailsWithAuthError(err error) bool

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, uri string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) DeleteUser

func (c *Client) DeleteUser(ctx context.Context, dbName string, username string) error

func (*Client) Ping

func (c *Client) Ping(ctx context.Context) error

func (*Client) UpdateUserPassword

func (c *Client) UpdateUserPassword(ctx context.Context, dbName string, userName string, password string) error

func (*Client) UpsertUser

func (c *Client) UpsertUser(ctx context.Context, dbName string, userName string, password string) error

func (*Client) UserExists

func (c *Client) UserExists(ctx context.Context, dbName string, userName string) (bool, error)

type ErrUserExists

type ErrUserExists struct {
	Message string `json:"message"`
}

func (ErrUserExists) Error

func (e ErrUserExists) Error() string