Documentation
¶
Index ¶
- type Catalog
- func (tc *Catalog) CreateCollection(ctx context.Context, createCollection *model.CreateCollection, ...) (*model.Collection, error)
- func (tc *Catalog) CreateDatabase(ctx context.Context, createDatabase *model.CreateDatabase, ts types.Timestamp) (*model.Database, error)
- func (tc *Catalog) CreateSegment(ctx context.Context, createSegment *model.CreateSegment, ts types.Timestamp) (*model.Segment, error)
- func (tc *Catalog) CreateTenant(ctx context.Context, createTenant *model.CreateTenant, ts types.Timestamp) (*model.Tenant, error)
- func (tc *Catalog) DeleteCollection(ctx context.Context, deleteCollection *model.DeleteCollection) error
- func (tc *Catalog) DeleteSegment(ctx context.Context, segmentID types.UniqueID) error
- func (tc *Catalog) FlushCollectionCompaction(ctx context.Context, ...) (*model.FlushCollectionInfo, error)
- func (tc *Catalog) GetAllDatabases(ctx context.Context, ts types.Timestamp) ([]*model.Database, error)
- func (tc *Catalog) GetAllTenants(ctx context.Context, ts types.Timestamp) ([]*model.Tenant, error)
- func (tc *Catalog) GetCollections(ctx context.Context, collectionID types.UniqueID, collectionName *string, ...) ([]*model.Collection, error)
- func (tc *Catalog) GetDatabases(ctx context.Context, getDatabase *model.GetDatabase, ts types.Timestamp) (*model.Database, error)
- func (tc *Catalog) GetSegments(ctx context.Context, segmentID types.UniqueID, segmentType *string, ...) ([]*model.Segment, error)
- func (tc *Catalog) GetTenants(ctx context.Context, getTenant *model.GetTenant, ts types.Timestamp) (*model.Tenant, error)
- func (tc *Catalog) GetTenantsLastCompactionTime(ctx context.Context, tenantIDs []string) ([]*dbmodel.Tenant, error)
- func (tc *Catalog) ResetState(ctx context.Context) error
- func (tc *Catalog) SetTenantLastCompactionTime(ctx context.Context, tenantID string, lastCompactionTime int64) error
- func (tc *Catalog) UpdateCollection(ctx context.Context, updateCollection *model.UpdateCollection, ...) (*model.Collection, error)
- func (tc *Catalog) UpdateSegment(ctx context.Context, updateSegment *model.UpdateSegment, ts types.Timestamp) (*model.Segment, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Catalog ¶
type Catalog struct {
// contains filtered or unexported fields
}
The catalog backed by databases using GORM.
func NewTableCatalog ¶
func NewTableCatalog(txImpl dbmodel.ITransaction, metaDomain dbmodel.IMetaDomain) *Catalog
func NewTableCatalogWithNotification ¶
func NewTableCatalogWithNotification(txImpl dbmodel.ITransaction, metaDomain dbmodel.IMetaDomain, store notification.NotificationStore) *Catalog
func (*Catalog) CreateCollection ¶
func (tc *Catalog) CreateCollection(ctx context.Context, createCollection *model.CreateCollection, ts types.Timestamp) (*model.Collection, error)
func (*Catalog) CreateDatabase ¶
func (*Catalog) CreateSegment ¶
func (*Catalog) CreateTenant ¶
func (*Catalog) DeleteCollection ¶
func (*Catalog) DeleteSegment ¶
func (*Catalog) FlushCollectionCompaction ¶
func (tc *Catalog) FlushCollectionCompaction(ctx context.Context, flushCollectionCompaction *model.FlushCollectionCompaction) (*model.FlushCollectionInfo, error)
func (*Catalog) GetAllDatabases ¶
func (*Catalog) GetAllTenants ¶
func (*Catalog) GetCollections ¶
func (*Catalog) GetDatabases ¶
func (*Catalog) GetSegments ¶
func (*Catalog) GetTenants ¶
func (*Catalog) GetTenantsLastCompactionTime ¶
func (*Catalog) SetTenantLastCompactionTime ¶
func (*Catalog) UpdateCollection ¶
func (tc *Catalog) UpdateCollection(ctx context.Context, updateCollection *model.UpdateCollection, ts types.Timestamp) (*model.Collection, error)
Source Files
Click to show internal directories.
Click to hide internal directories.