controllers

Documentation

Index

• func Index(item Indexer, data primitive.M) error
• func IndexStream(waitGroup *sync.WaitGroup, stream *mongo.ChangeStream, collectionName string)
• type Indexer

Functions

func Index

func Index(item Indexer, data primitive.M) error

func IndexStream

func IndexStream(waitGroup *sync.WaitGroup, stream *mongo.ChangeStream, collectionName string)

Types

type Indexer

type Indexer interface {
	Collection() string
	Insert(collection typesense.CollectionInterface) error
	Update(collection typesense.CollectionInterface, documentKey primitive.M, updatedFields primitive.M, removedFields primitive.A) error
	Delete(collection typesense.CollectionInterface, documentKey primitive.M) error
}