schema

Jul 16, 2024

Changes in this version

type Repository

+ GetVersionCommitSHA func(ctx context.Context, schemaID int32, version int32) (string, error)

Jul 3, 2024

Changes in this version

type Service

+ func (s *Service) DetectSchemaChange(namespace string, schemaName string, fromVersion string, toVersion string, ...) (*stencilv1beta1.SchemaChangedEvent, error)

+ func (s *Service) ValidateVersions(ctx context.Context, namespace string, schemaName string, fromVersion string, ...) (int32, int32, error)

Jun 25, 2024

Changes in this version

type Metadata

+ SourceURL string

type Schema

+ SourceURL string

+ type UpdateSchemaRequest struct

+ Metadata *Metadata

+ Namespace string

+ Schema string

+ SchemaFile *SchemaFile

Apr 30, 2024

Changes in this version

+ const EventTypeSchemaChange

+ type ChangeDetectorService interface

+ IdentifySchemaChange func(ctx context.Context, request *changedetector.ChangeRequest) (*stencilv1beta2.SchemaChangedEvent, error)

+ type NotificationEventRepository interface

+ Create func(ctx context.Context, event changedetector.NotificationEvent) (changedetector.NotificationEvent, error)

+ GetByNameSpaceSchemaVersionAndSuccess func(ctx context.Context, namespace string, schemaID int32, versionID string, ...) (changedetector.NotificationEvent, error)

+ Update func(ctx context.Context, Id string, success bool) (changedetector.NotificationEvent, error)

+ type Producer interface

+ Write func(topic string, protoMessage proto.Message) error

type Repository

+ GetSchemaID func(ctx context.Context, ns string, sc string) (int32, error)

Mar 14, 2023

Changes in this version

+ type Cache interface

+ Get func(interface{}) (interface{}, bool)

+ Set func(interface{}, interface{}, int64) bool

+ type CompatibilityFn func(ParsedSchema, []ParsedSchema) error

+ type Metadata struct

+ Authority string

+ Compatibility string

+ Format string

+ type NamespaceService interface

+ Get func(ctx context.Context, name string) (namespace.Namespace, error)

+ type ParsedSchema interface

+ Format func() string

+ GetCanonicalValue func() *SchemaFile

+ IsBackwardCompatible func(ParsedSchema) error

+ IsForwardCompatible func(ParsedSchema) error

+ IsFullCompatible func(ParsedSchema) error

+ type Provider interface

+ ParseSchema func(format string, data []byte) (ParsedSchema, error)

+ type Repository interface

+ Create func(ctx context.Context, namespace string, schema string, metadata *Metadata, ...) (version int32, err error)

+ Delete func(context.Context, string, string) error

+ DeleteVersion func(context.Context, string, string, int32) error

+ Get func(context.Context, string, string, int32) ([]byte, error)

+ GetLatestVersion func(context.Context, string, string) (int32, error)

+ GetMetadata func(context.Context, string, string) (*Metadata, error)

+ List func(context.Context, string) ([]Schema, error)

+ ListVersions func(context.Context, string, string) ([]int32, error)

+ UpdateMetadata func(context.Context, string, string, *Metadata) (*Metadata, error)

+ type Schema struct

+ Authority string

+ Compatibility string

+ Format string

+ Name string

+ type SchemaFile struct

+ Data []byte

+ Fields []string

+ ID string

+ Types []string

+ type SchemaInfo struct

+ ID string

+ Location string

+ Version int32

+ type Service struct

+ func NewService(repo Repository, provider Provider, nsSvc NamespaceService, cache Cache) *Service

+ func (s *Service) CheckCompatibility(ctx context.Context, nsName, schemaName, compatibility string, data []byte) error

+ func (s *Service) Create(ctx context.Context, nsName string, schemaName string, metadata *Metadata, ...) (SchemaInfo, error)

+ func (s *Service) Delete(ctx context.Context, namespace string, schemaName string) error

+ func (s *Service) DeleteVersion(ctx context.Context, namespace string, schemaName string, version int32) error

+ func (s *Service) Get(ctx context.Context, namespace string, schemaName string, version int32) (*Metadata, []byte, error)

+ func (s *Service) GetLatest(ctx context.Context, namespace string, schemaName string) (*Metadata, []byte, error)

+ func (s *Service) GetMetadata(ctx context.Context, namespace, schemaName string) (*Metadata, error)

+ func (s *Service) List(ctx context.Context, namespaceID string) ([]Schema, error)

+ func (s *Service) ListVersions(ctx context.Context, namespaceID string, schemaName string) ([]int32, error)

+ func (s *Service) UpdateMetadata(ctx context.Context, namespace, schemaName string, meta *Metadata) (*Metadata, error)

+ type ValidationStrategy func(ParsedSchema, ParsedSchema) error