Versions in this module Expand all Collapse all v0 v0.1.1 Feb 11, 2024 Changes in this version + type Cursor struct + ID int64 + func (c *Cursor) Close() + func (c *Cursor) Next() (struct{}, *types.Document, error) + func (c *Cursor) Reset(iter types.DocumentsIterator) error + type NewParams struct + Collection string + DB string + Data any + ShowRecordID bool + Type Type + Username string + type Registry struct + func NewRegistry(l *zap.Logger) *Registry + func (r *Registry) All() []*Cursor + func (r *Registry) Close() + func (r *Registry) CloseAndRemove(c *Cursor) + func (r *Registry) Collect(ch chan<- prometheus.Metric) + func (r *Registry) Describe(ch chan<- *prometheus.Desc) + func (r *Registry) Get(id int64) *Cursor + func (r *Registry) NewCursor(ctx context.Context, iter types.DocumentsIterator, params *NewParams) *Cursor + type Type int + const Normal + const Tailable + const TailableAwait + func (i Type) String() string v0.1.0 Feb 11, 2024
Go to main page