coordinator

Documentation

Index

• type Coordinator
  • func NewCoordinator(ctx context.Context, db *gorm.DB, ...) (*Coordinator, error)
  • func (s *Coordinator) CreateCollection(ctx context.Context, createCollection *model.CreateCollection) (*model.Collection, error)
  • func (s *Coordinator) CreateDatabase(ctx context.Context, createDatabase *model.CreateDatabase) (*model.Database, error)
  • func (s *Coordinator) CreateSegment(ctx context.Context, segment *model.CreateSegment) error
  • func (s *Coordinator) CreateTenant(ctx context.Context, createTenant *model.CreateTenant) (*model.Tenant, error)
  • func (s *Coordinator) DeleteCollection(ctx context.Context, deleteCollection *model.DeleteCollection) error
  • func (s *Coordinator) DeleteSegment(ctx context.Context, segmentID types.UniqueID) error
  • func (s *Coordinator) FlushCollectionCompaction(ctx context.Context, ...) (*model.FlushCollectionInfo, error)
  • func (s *Coordinator) GetCollections(ctx context.Context, collectionID types.UniqueID, collectionName *string, ...) ([]*model.Collection, error)
  • func (s *Coordinator) GetDatabase(ctx context.Context, getDatabase *model.GetDatabase) (*model.Database, error)
  • func (s *Coordinator) GetSegments(ctx context.Context, segmentID types.UniqueID, segmentType *string, ...) ([]*model.Segment, error)
  • func (s *Coordinator) GetTenant(ctx context.Context, getTenant *model.GetTenant) (*model.Tenant, error)
  • func (s *Coordinator) GetTenantsLastCompactionTime(ctx context.Context, tenantIDs []string) ([]*dbmodel.Tenant, error)
  • func (s *Coordinator) ResetState(ctx context.Context) error
  • func (s *Coordinator) SetTenantLastCompactionTime(ctx context.Context, tenantID string, lastCompactionTime int64) error
  • func (s *Coordinator) Start() error
  • func (s *Coordinator) Stop() error
  • func (s *Coordinator) UpdateCollection(ctx context.Context, collection *model.UpdateCollection) (*model.Collection, error)
  • func (s *Coordinator) UpdateSegment(ctx context.Context, updateSegment *model.UpdateSegment) (*model.Segment, error)
• type ICoordinator

Types

type Coordinator

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

Coordinator is the implemenation of ICoordinator. It is the top level component. Currently, it only has the system catalog related APIs and will be extended to support other functionalities such as membership managed and propagation.

func NewCoordinator

func NewCoordinator(ctx context.Context, db *gorm.DB, notificationStore notification.NotificationStore, notifier notification.Notifier) (*Coordinator, error)

func (*Coordinator) CreateCollection

func (s *Coordinator) CreateCollection(ctx context.Context, createCollection *model.CreateCollection) (*model.Collection, error)

func (*Coordinator) CreateDatabase

func (s *Coordinator) CreateDatabase(ctx context.Context, createDatabase *model.CreateDatabase) (*model.Database, error)

func (*Coordinator) CreateSegment

func (s *Coordinator) CreateSegment(ctx context.Context, segment *model.CreateSegment) error

func (*Coordinator) CreateTenant

func (s *Coordinator) CreateTenant(ctx context.Context, createTenant *model.CreateTenant) (*model.Tenant, error)

func (*Coordinator) DeleteCollection

func (s *Coordinator) DeleteCollection(ctx context.Context, deleteCollection *model.DeleteCollection) error

func (*Coordinator) DeleteSegment

func (s *Coordinator) DeleteSegment(ctx context.Context, segmentID types.UniqueID) error

func (*Coordinator) FlushCollectionCompaction

func (s *Coordinator) FlushCollectionCompaction(ctx context.Context, flushCollectionCompaction *model.FlushCollectionCompaction) (*model.FlushCollectionInfo, error)

func (*Coordinator) GetCollections

func (s *Coordinator) GetCollections(ctx context.Context, collectionID types.UniqueID, collectionName *string, tenantID string, databaseName string, limit *int32, offset *int32) ([]*model.Collection, error)

func (*Coordinator) GetDatabase

func (s *Coordinator) GetDatabase(ctx context.Context, getDatabase *model.GetDatabase) (*model.Database, error)

func (*Coordinator) GetSegments

func (s *Coordinator) GetSegments(ctx context.Context, segmentID types.UniqueID, segmentType *string, scope *string, collectionID types.UniqueID) ([]*model.Segment, error)

func (*Coordinator) GetTenant

func (s *Coordinator) GetTenant(ctx context.Context, getTenant *model.GetTenant) (*model.Tenant, error)

func (*Coordinator) GetTenantsLastCompactionTime

func (s *Coordinator) GetTenantsLastCompactionTime(ctx context.Context, tenantIDs []string) ([]*dbmodel.Tenant, error)

func (*Coordinator) ResetState

func (s *Coordinator) ResetState(ctx context.Context) error

func (*Coordinator) SetTenantLastCompactionTime

func (s *Coordinator) SetTenantLastCompactionTime(ctx context.Context, tenantID string, lastCompactionTime int64) error

func (*Coordinator) Start

func (s *Coordinator) Start() error

func (*Coordinator) Stop

func (s *Coordinator) Stop() error

func (*Coordinator) UpdateCollection

func (s *Coordinator) UpdateCollection(ctx context.Context, collection *model.UpdateCollection) (*model.Collection, error)

func (*Coordinator) UpdateSegment

func (s *Coordinator) UpdateSegment(ctx context.Context, updateSegment *model.UpdateSegment) (*model.Segment, error)

type ICoordinator

type ICoordinator interface {
	common.Component
	ResetState(ctx context.Context) error
	CreateCollection(ctx context.Context, createCollection *model.CreateCollection) (*model.Collection, error)
	GetCollections(ctx context.Context, collectionID types.UniqueID, collectionName *string, tenantID string, dataName string, limit *int32, offset *int32) ([]*model.Collection, error)
	DeleteCollection(ctx context.Context, deleteCollection *model.DeleteCollection) error
	UpdateCollection(ctx context.Context, updateCollection *model.UpdateCollection) (*model.Collection, error)
	CreateSegment(ctx context.Context, createSegment *model.CreateSegment) error
	GetSegments(ctx context.Context, segmentID types.UniqueID, segmentType *string, scope *string, collectionID types.UniqueID) ([]*model.Segment, error)
	DeleteSegment(ctx context.Context, segmentID types.UniqueID) error
	UpdateSegment(ctx context.Context, updateSegment *model.UpdateSegment) (*model.Segment, error)
	CreateDatabase(ctx context.Context, createDatabase *model.CreateDatabase) (*model.Database, error)
	GetDatabase(ctx context.Context, getDatabase *model.GetDatabase) (*model.Database, error)
	CreateTenant(ctx context.Context, createTenant *model.CreateTenant) (*model.Tenant, error)
	GetTenant(ctx context.Context, getTenant *model.GetTenant) (*model.Tenant, error)
	SetTenantLastCompactionTime(ctx context.Context, tenantID string, lastCompactionTime int64) error
	GetTenantsLastCompactionTime(ctx context.Context, tenantIDs []string) ([]*dbmodel.Tenant, error)
	FlushCollectionCompaction(ctx context.Context, flushCollectionCompaction *model.FlushCollectionCompaction) (*model.FlushCollectionInfo, error)
}

ICoordinator is an interface that defines the methods for interacting with the Chroma Coordinator. It is designed in a way that can be run standalone without spinning off the GRPC service.