stream

Documentation

Index

• type Interface
  • func NewStream(conf local.MongoConf) (Interface, error)

Types

type Interface

type Interface interface {
	List(ctx context.Context, opts *types.ListOptions) (ch chan *types.Event, err error)
	Watch(ctx context.Context, opts *types.WatchOptions) (*types.Watcher, error)
	ListWatch(ctx context.Context, opts *types.ListWatchOptions) (*types.Watcher, error)
}

Stream Interface defines all the functionality it have.

func NewStream

func NewStream(conf local.MongoConf) (Interface, error)