query

type BaseService struct {
	plugins.Config
	// contains filtered or unexported fields
}

type CollectionMessageObject struct {
	Database   string
	Collection string
}

type CoordinatorService interface {
	// SetCoordinator sets the coordinator.
	SetCoordinator(coordinator coordinator.Coordinator)
	// Coordinator returns the coordinator.
	Coordinator() coordinator.Coordinator
	// Observer is an interface to receive a message from the coordinator.
	coordinator.Observer
	// PostDatabaseCreateMessage posts a create database message to the coordinator.
	PostDatabaseCreateMessage(database string) error
	// PostDatabaseDeleteMessage posts a update database message to the coordinator.
	PostDatabaseUpdateMessage(database string) error
	// PostDatabaseDropMessage posts a drop database message to the coordinator.
	PostDatabaseDropMessage(database string) error
	// PostCollectionCreateMessage posts a create collection message to the coordinator.
	PostCollectionCreateMessage(database string, collection string) error
	// PostCollectionDeleteMessage posts a update collection message to the coordinator.
	PostCollectionUpdateMessage(database string, collection string) error
	// PostCollectionDropMessage posts a drop collection message to the coordinator.
	PostCollectionDropMessage(database string, collection string) error
}

type DatabaseMessageObject struct {
	Database string
}

type Service interface {
	plugins.Service
	CoordinatorService
	StoreService
	// SetTracer sets the tracing tracer.
	SetTracer(t tracer.Tracer)
	// SetPort sets the listen port.
	SetPort(port int)
}

type StoreService interface {
	// SetStore sets the store.
	SetStore(store store.Store)
	// Store returns the store.
	Store() store.Store
}