mongodb

Documentation

Index

• func MapToStructure(in map[string]interface{}, out interface{}) error
• func StructureToMap(obj interface{}) (map[string]interface{}, error)
• type Client
  • func New(connString string, databaseName string, opts ...ClientOpt) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) ContextWithTimeout() (context.Context, context.CancelFunc)
  • func (c *Client) Database() *mongo.Database
• type ClientOpt
  • func WithReadPref(pref *readpref.ReadPref) ClientOpt
  • func WithTimeout(timeout time.Duration) ClientOpt
  • func WithTraceProvider(traceProvider trace.TracerProvider) ClientOpt

Functions

func MapToStructure

func MapToStructure(in map[string]interface{}, out interface{}) error

func StructureToMap

func StructureToMap(obj interface{}) (map[string]interface{}, error)

Types

type Client

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

func New

func New(connString string, databaseName string, opts ...ClientOpt) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) ContextWithTimeout

func (c *Client) ContextWithTimeout() (context.Context, context.CancelFunc)

func (*Client) Database

func (c *Client) Database() *mongo.Database

type ClientOpt

type ClientOpt func(opts *clientOpts)

func WithReadPref

func WithReadPref(pref *readpref.ReadPref) ClientOpt

func WithTimeout

func WithTimeout(timeout time.Duration) ClientOpt

func WithTraceProvider

func WithTraceProvider(traceProvider trace.TracerProvider) ClientOpt