Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collector ¶
type Collector struct {
// contains filtered or unexported fields
}
func New ¶
func New(co *option.CollectorOptions, pipeline mongo.Pipeline, cso *options.ChangeStreamOptions) *Collector
func (*Collector) ChangeStream ¶
func (c *Collector) ChangeStream() (*mongo.ChangeStream, error)
Click to show internal directories.
Click to hide internal directories.