mongo

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

type DocumentKey struct {
	ID primitive.ObjectID `json:"_id" bson:"_id"`
}

type Listener[T d] struct {
	// contains filtered or unexported fields
}

type Mongo[T d] struct {
	Searcher  searcher[T]
	Processor processor[T]
	Listener  StreamListener
	Creator   creator
	Updater   updater
	Upserter  upserter
	Remover   remover
}

type NS struct {
	Db   string `bson:"db"`
	Coll string `bson:"coll"`
}

type Processor[T d] struct {
	// contains filtered or unexported fields
}

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

type Searcher[T d] struct {
	// contains filtered or unexported fields
}

type Stream struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type StreamDelete struct {
	DocumentKey DocumentKey `json:"documentKey" bson:"documentKey"`
}

type StreamInsert[T any] struct {
	FullDocument T `json:"fullDocument" bson:"fullDocument"`
}

type StreamListener = interface {
	Listen(ctx context.Context, change []byte) (err error)
}

type StreamType struct {
	OperationType string `json:"operationType" bson:"operationType"`
}

type StreamUpdate[T any] struct {
	DocumentKey       DocumentKey          `json:"documentKey" bson:"documentKey"`
	UpdateDescription UpdateDescription[T] `json:"updateDescription" bson:"updateDescription"`
}

type StreamingNS struct {
	NS NS `bson:"ns"`
}

type UpdateDescription[T any] struct {
	UpdatedFields T        `json:"updatedFields" bson:"updatedFields"`
	RemovedFields []string `json:"removedFields" bson:"removedFields"`
}

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

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