schema

type DB interface {
	io.Closer
	UpdateOptions(opts *commonv1.ResourceOpts)
	Drop() error
}

type EventKind uint8

type EventType uint8

type Group interface {
	GetSchema() *commonv1.Group
	SupplyTSDB() io.Closer
}

type IndexListener interface {
	OnIndexUpdate(index []*databasev1.IndexRule)
}

type MetadataEvent struct {
	Metadata       ResourceSchema
	DeleteRevision int64 // non-zero only for EventDelete; carries the tombstone mod_revision
	Typ            EventType
	Kind           EventKind
}

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

type Repository interface {
	Watcher()
	Init(schema.Kind) ([]string, []int64)
	SendMetadataEvent(MetadataEvent)
	LoadGroup(name string) (Group, bool)
	LoadAllGroups() []Group
	LoadResource(metadata *commonv1.Metadata) (Resource, bool)
	LoadAllResources(group string) []Resource
	LoadAllIndexRules(group string) []*databasev1.IndexRule
	IndexRules(resourceSchema ResourceSchema) []*databasev1.IndexRule
	LatestModRevision() int64
	Close()
	StopCh() <-chan struct{}
	DropGroup(groupName string) error
}

type Resource interface {
	Schema() ResourceSchema
	Delegated() IndexListener
}

type ResourceSchema interface {
	GetMetadata() *commonv1.Metadata
}

type ResourceSchemaSupplier interface {
	ResourceSchema(metadata *commonv1.Metadata) (ResourceSchema, error)
	OpenResource(spec Resource) (IndexListener, error)
}

type ResourceSupplier interface {
	ResourceSchemaSupplier
	OpenDB(groupSchema *commonv1.Group) (DB, error)
	// ResolveResourceOpts returns the ResourceOpts that should drive the tsdb for this
	// supplier's node: a data supplier resolves the matched lifecycle stage's
	// interval/ttl/shardNum, a liaison/queue supplier returns the group default. It lets
	// a group UpdateOptions apply the same stage-resolved values that OpenDB used, instead
	// of silently overwriting them with the group default.
	ResolveResourceOpts(groupSchema *commonv1.Group) *commonv1.ResourceOpts
}

type ResourceView struct {
	Cached       proto.Message
	Runtime      proto.Message
	Name         string
	RuntimeRules []*databasev1.IndexRule
}

type ResourceViewer func(Resource) (ResourceView, bool)

type RevisionRepository interface {
	Repository
	ResourceRevision(kind schema.Kind, group, name string) (int64, bool)
	IsAbsent(kind schema.Kind, group, name string) bool
}

type Supplier interface {
	SupplyTSDB() io.Closer
}