collector

Documentation

Index

• type Collector
  • func New(uri string, databases []string, collections []string) *Collector
  • func (c *Collector) Collect(opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

Types

type Collector

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

Collector is a used to fetch change stream from a client, database or collection.

func New

func New(uri string, databases []string, collections []string) *Collector

New creates a new Collector instance.

func (*Collector) Collect

func (c *Collector) Collect(opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

Collect returns a change stream for all changes on the corresponding container.

The opts parameter can be used to specify options for change stream creation. See https://godoc.org/go.mongodb.org/mongo-driver/mongo/options#ChangeStreamOptions for details.