schema

Mar 26, 2026

Changes in this version

type DB

+ Drop func() error

type Repository

+ DropGroup func(groupName string) error

Apr 2, 2025

Changes in this version

+ type DB interface

+ UpdateOptions func(opts *commonv1.ResourceOpts)

type EventKind

+ const EventKindIndexRule

+ const EventKindIndexRuleBinding

+ type IndexListener interface

+ OnIndexUpdate func(index []*databasev1.IndexRule)

type Repository

+ LoadAllGroups func() []Group

Oct 7, 2024

Changes in this version

+ type Metrics struct

+ func NewMetrics(factory *observability.Factory) *Metrics

May 9, 2024

Changes in this version

type EventKind

+ const EventKindTopNAgg

type Group

+ SupplyTSDB func() io.Closer

type Repository

+ Init func(schema.Kind) []int64

+ type Supplier interface

+ SupplyTSDB func() io.Closer

Oct 17, 2023

Changes in this version

type Repository

+ func NewPortableRepository(metadata metadata.Repo, l *logger.Logger, supplier ResourceSchemaSupplier) Repository

+ StopCh func() <-chan struct{}

type Resource

+ Delegated func() io.Closer

+ IndexRules func() []*databasev1.IndexRule

+ Schema func() ResourceSchema

+ TopN func() []*databasev1.TopNAggregation

+ type ResourceSchemaSupplier interface

+ OpenResource func(shardNum uint32, db tsdb.Supplier, spec Resource) (io.Closer, error)

+ ResourceSchema func(metadata *commonv1.Metadata) (ResourceSchema, error)

Jun 28, 2023

Changes in this version

+ func ParseMaxModRevision(indexRules []T) (maxRevisionForIdxRules int64)

type Resource

+ GetTopN func() []*databasev1.TopNAggregation

Nov 5, 2022

Changes in this version

type ResourceSpec

+ Aggregations []*databasev1.TopNAggregation

Jun 2, 2022

Changes in this version

+ type EventKind uint8

+ const EventKindGroup

+ const EventKindResource

+ type EventType uint8

+ const EventAddOrUpdate

+ const EventDelete

+ type Group interface

+ GetSchema func() *commonv1.Group

+ LoadResource func(name string) (Resource, bool)

+ StoreResource func(resourceSchema ResourceSchema) (Resource, error)

+ type MetadataEvent struct

+ Kind EventKind

+ Metadata *commonv1.Metadata

+ Typ EventType

+ type Repository interface

+ Close func()

+ LoadGroup func(name string) (Group, bool)

+ LoadResource func(metadata *commonv1.Metadata) (Resource, bool)

+ NotifyAll func() (err error)

+ SendMetadataEvent func(MetadataEvent)

+ StoreGroup func(groupMeta *commonv1.Metadata) (*group, error)

+ Watcher func()

+ func NewRepository(metadata metadata.Repo, repo discovery.ServiceRepo, l *logger.Logger, ...) Repository

+ type Resource interface

+ EntityLocator func() partition.EntityLocator

+ GetIndexRules func() []*databasev1.IndexRule

+ MaxObservedModRevision func() int64

+ type ResourceSchema interface

+ GetMetadata func() *commonv1.Metadata

+ type ResourceSpec struct

+ IndexRules []*databasev1.IndexRule

+ Schema ResourceSchema

+ type ResourceSupplier interface

+ OpenDB func(groupSchema *commonv1.Group) (tsdb.Database, error)

+ OpenResource func(shardNum uint32, db tsdb.Supplier, spec ResourceSpec) (Resource, error)

+ ResourceSchema func(repo metadata.Repo, metdata *commonv1.Metadata) (ResourceSchema, error)