mongo

Documentation

Index

• Variables
• type ChangeEvent
  • func DecodeChangeEvent(changeEvent []byte) (*ChangeEvent, error)
• type ChangeStreamCallback
• type Client
  • func (c *Client) Close()
  • func (c *Client) Monitor() error
  • func (c *Client) StartChangeStream(callback ChangeStreamCallback)
  • func (c *Client) StopChangeStream()
• type Options
  • func (o Options) New() *Client

Variables

var ErrClientDisconnected = errors.New("could not reach mongodb: connection closed")

Types

type ChangeEvent

type ChangeEvent struct {
	OperationType string                 `json:"operationType"`
	FullDocument  changeEventDocument    `json:"fullDocument"`
	ResumeToken   changeEventResumeToken `json:"_id"`
	Ns            changeEventNs          `json:"ns"`
}

func DecodeChangeEvent

func DecodeChangeEvent(changeEvent []byte) (*ChangeEvent, error)

type ChangeStreamCallback

type ChangeStreamCallback func(event *ChangeEvent, json []byte)

type Client

type Client struct {
	Db   *mongo.Database
	Conn *mongo.Client
	Options
}

func (*Client) Close

func (c *Client) Close()

func (*Client) Monitor

func (c *Client) Monitor() error

func (*Client) StartChangeStream

func (c *Client) StartChangeStream(callback ChangeStreamCallback)

func (*Client) StopChangeStream

func (c *Client) StopChangeStream()

type Options

type Options struct {
	Context context.Context
	Logger  logger.Logger
	Config  *config.MongoConfig
}

func (Options) New

func (o Options) New() *Client