schema

package

Go to main page

Versions in this module

v0

v0.7.1

Nov 12, 2024

v0.7.0

Oct 7, 2024

v0.7.0-rc0

Sep 13, 2024

v0.6.1

May 30, 2024

Changes in this version

+ var CheckerMap = map[Kind]EqualityChecker

+ type EqualityChecker func(a, b proto.Message) bool

type Node

+ GetNode func(ctx context.Context, node string) (*databasev1.Node, error)

type Registry

+ NewWatcher func(string, Kind, watchEventHandler) *watcher

+ Register func(context.Context, Metadata, bool) error

v0.6.0

May 9, 2024

Changes in this version

type EventHandler

+ OnInit func([]Kind) (bool, []int64)

type RegistryOption

+ func ConfigureEtcdTLSCAFile(file string) RegistryOption

+ func ConfigureEtcdTLSCertAndKey(certFile string, keyFile string) RegistryOption

+ func ConfigureEtcdUser(username string, password string) RegistryOption

+ type UnimplementedOnInitHandler struct

+ func (u UnimplementedOnInitHandler) OnInit([]Kind) (bool, []int64)

v0.5.0

Oct 17, 2023

Changes in this version

type Kind

+ const KindNode

+ const KindSize

+ func (k Kind) String() string

+ func (k Kind) Unmarshal(kv *mvccpb.KeyValue) (Metadata, error)

+ type Node interface

+ ListNode func(ctx context.Context, role databasev1.Role) ([]*databasev1.Node, error)

+ RegisterNode func(ctx context.Context, node *databasev1.Node, forced bool) error

type Property

+ KeepAlive func(ctx context.Context, leaseID int64) error

type Registry

+ RegisterHandler func(string, Kind, EventHandler)

type RegistryOption

+ func ConfigureServerEndpoints(url []string) RegistryOption

+ func Namespace(namespace string) RegistryOption

type TypeMeta

+ ModRevision int64

v0.4.0

Jun 28, 2023

Changes in this version

+ var ErrClosed = errors.New("metadata registry is closed")

v0.3.1

Feb 21, 2023

v0.3.0

Feb 6, 2023

v0.2.0

Nov 5, 2022

Changes in this version

type Measure

+ TopNAggregations func(ctx context.Context, metadata *commonv1.Metadata) ([]*databasev1.TopNAggregation, error)

type Property

+ ApplyProperty func(ctx context.Context, property *propertyv1.Property, ...) (bool, uint32, error)

v0.1.0

Jun 2, 2022

Changes in this version

+ const KindMask

+ const MeasureKeyPrefix

+ const TagTypeID

+ var ErrConcurrentModification = errors.New("concurrent modification of entities")

+ var ErrGRPCAlreadyExists = statusGRPCAlreadyExists.Err()

+ var ErrGRPCDataLoss = statusDataLoss.Err()

+ var ErrGRPCInvalidArgument = statusGRPCInvalidArgument.Err()

+ var ErrGRPCResourceNotFound = statusGRPCResourceNotFound.Err()

+ var ErrUnexpectedNumberOfEntities = errors.New("unexpected number of entities")

+ var ErrUnsupportedEntityType = errors.New("unsupported entity type")

+ var GroupMetadataKey = "/__meta_group__"

+ var GroupsKeyPrefix = "/groups/"

+ var IndexRuleBindingKeyPrefix = "/index-rule-bindings/"

+ var IndexRuleKeyPrefix = "/index-rules/"

+ var PropertyKeyPrefix = "/properties/"

+ var StreamKeyPrefix = "/streams/"

+ var TopNAggregationKeyPrefix = "/topnagg/"

+ func BadRequest(field, desc string) error

+ func IsNotFound(err error) bool

+ type EventHandler interface

+ OnAddOrUpdate func(Metadata)

+ OnDelete func(Metadata)

+ type Group interface

+ CreateGroup func(ctx context.Context, group *commonv1.Group) error

+ DeleteGroup func(ctx context.Context, group string) (bool, error)

+ GetGroup func(ctx context.Context, group string) (*commonv1.Group, error)

+ ListGroup func(ctx context.Context) ([]*commonv1.Group, error)

+ UpdateGroup func(ctx context.Context, group *commonv1.Group) error

+ type HasMetadata interface

+ GetMetadata func() *commonv1.Metadata

+ type IndexRule interface

+ CreateIndexRule func(ctx context.Context, indexRule *databasev1.IndexRule) error

+ DeleteIndexRule func(ctx context.Context, metadata *commonv1.Metadata) (bool, error)

+ GetIndexRule func(ctx context.Context, metadata *commonv1.Metadata) (*databasev1.IndexRule, error)

+ ListIndexRule func(ctx context.Context, opt ListOpt) ([]*databasev1.IndexRule, error)

+ UpdateIndexRule func(ctx context.Context, indexRule *databasev1.IndexRule) error

+ type IndexRuleBinding interface

+ CreateIndexRuleBinding func(ctx context.Context, indexRuleBinding *databasev1.IndexRuleBinding) error

+ DeleteIndexRuleBinding func(ctx context.Context, metadata *commonv1.Metadata) (bool, error)

+ GetIndexRuleBinding func(ctx context.Context, metadata *commonv1.Metadata) (*databasev1.IndexRuleBinding, error)

+ ListIndexRuleBinding func(ctx context.Context, opt ListOpt) ([]*databasev1.IndexRuleBinding, error)

+ UpdateIndexRuleBinding func(ctx context.Context, indexRuleBinding *databasev1.IndexRuleBinding) error

+ type Kind int

+ const KindGroup

+ const KindIndexRule

+ const KindIndexRuleBinding

+ const KindMeasure

+ const KindProperty

+ const KindStream

+ const KindTopNAggregation

+ type ListOpt struct

+ Group string

+ type Measure interface

+ CreateMeasure func(ctx context.Context, measure *databasev1.Measure) error

+ DeleteMeasure func(ctx context.Context, metadata *commonv1.Metadata) (bool, error)

+ GetMeasure func(ctx context.Context, metadata *commonv1.Metadata) (*databasev1.Measure, error)

+ ListMeasure func(ctx context.Context, opt ListOpt) ([]*databasev1.Measure, error)

+ RegisterHandler func(Kind, EventHandler)

+ UpdateMeasure func(ctx context.Context, measure *databasev1.Measure) error

+ type Metadata struct

+ Spec Spec

+ func (m Metadata) Equal(other proto.Message) bool

+ func (m Metadata) Key() (string, error)

+ type Property interface

+ CreateProperty func(ctx context.Context, property *propertyv1.Property) error

+ DeleteProperty func(ctx context.Context, metadata *propertyv1.Metadata) (bool, error)

+ GetProperty func(ctx context.Context, metadata *propertyv1.Metadata) (*propertyv1.Property, error)

+ ListProperty func(ctx context.Context, container *commonv1.Metadata) ([]*propertyv1.Property, error)

+ UpdateProperty func(ctx context.Context, property *propertyv1.Property) error

+ type Registry interface

+ ReadyNotify func() <-chan struct{}

+ StopNotify func() <-chan struct{}

+ StoppingNotify func() <-chan struct{}

+ func NewEtcdSchemaRegistry(options ...RegistryOption) (Registry, error)

+ type RegistryOption func(*etcdSchemaRegistryConfig)

+ func ConfigureListener(lc, lp string) RegistryOption

+ func LoggerLevel(loggerLevel string) RegistryOption

+ func RootDir(rootDir string) RegistryOption

+ type Spec interface

+ type Stream interface

+ CreateStream func(ctx context.Context, stream *databasev1.Stream) error

+ DeleteStream func(ctx context.Context, metadata *commonv1.Metadata) (bool, error)

+ GetStream func(ctx context.Context, metadata *commonv1.Metadata) (*databasev1.Stream, error)

+ ListStream func(ctx context.Context, opt ListOpt) ([]*databasev1.Stream, error)

+ RegisterHandler func(Kind, EventHandler)

+ UpdateStream func(ctx context.Context, stream *databasev1.Stream) error

+ type TopNAggregation interface

+ CreateTopNAggregation func(ctx context.Context, measure *databasev1.TopNAggregation) error

+ DeleteTopNAggregation func(ctx context.Context, metadata *commonv1.Metadata) (bool, error)

+ GetTopNAggregation func(ctx context.Context, metadata *commonv1.Metadata) (*databasev1.TopNAggregation, error)

+ ListTopNAggregation func(ctx context.Context, opt ListOpt) ([]*databasev1.TopNAggregation, error)

+ UpdateTopNAggregation func(ctx context.Context, measure *databasev1.TopNAggregation) error

+ type TypeMeta struct

+ Group string

+ Kind Kind

+ Name string

+ func (tm TypeMeta) Unmarshal(data []byte) (m proto.Message, err error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL