schema

Documentation

Index

• type EventKind
• type EventType
• type Group
• type MetadataEvent
• type Repository
  • func NewRepository(metadata metadata.Repo, repo discovery.ServiceRepo, l *logger.Logger, ...) Repository
• type Resource
• type ResourceSchema
• type ResourceSpec
• type ResourceSupplier

Types

type EventKind

type EventKind uint8

const (
	EventKindGroup EventKind = iota
	EventKindResource
)

type EventType

type EventType uint8

const (
	EventAddOrUpdate EventType = iota
	EventDelete
)

type Group

type Group interface {
	GetSchema() *commonv1.Group
	StoreResource(resourceSchema ResourceSchema) (Resource, error)
	LoadResource(name string) (Resource, bool)
}

type MetadataEvent

type MetadataEvent struct {
	Typ      EventType
	Kind     EventKind
	Metadata *commonv1.Metadata
}

type Repository

type Repository interface {
	Watcher()
	SendMetadataEvent(MetadataEvent)
	StoreGroup(groupMeta *commonv1.Metadata) (*group, error)
	LoadGroup(name string) (Group, bool)
	LoadResource(metadata *commonv1.Metadata) (Resource, bool)
	NotifyAll() (err error)
	Close()
}

func NewRepository

func NewRepository(
	metadata metadata.Repo,
	repo discovery.ServiceRepo,
	l *logger.Logger,
	resourceSupplier ResourceSupplier,
	shardTopic bus.Topic,
	entityTopic bus.Topic,
) Repository

type Resource

type Resource interface {
	GetIndexRules() []*databasev1.IndexRule
	MaxObservedModRevision() int64
	EntityLocator() partition.EntityLocator
	ResourceSchema
	io.Closer
}

type ResourceSchema

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

type ResourceSpec

type ResourceSpec struct {
	Schema     ResourceSchema
	IndexRules []*databasev1.IndexRule
}

type ResourceSupplier

type ResourceSupplier interface {
	OpenResource(shardNum uint32, db tsdb.Supplier, spec ResourceSpec) (Resource, error)
	ResourceSchema(repo metadata.Repo, metdata *commonv1.Metadata) (ResourceSchema, error)
	OpenDB(groupSchema *commonv1.Group) (tsdb.Database, error)
}