schema

type Cache interface {
	Get(interface{}) (interface{}, bool)
	Set(interface{}, interface{}, int64) bool
}

type ChangeDetectorService interface {
	IdentifySchemaChange(ctx context.Context, request *changedetector.ChangeRequest) (*stencilv1beta1.SchemaChangedEvent, error)
}

type CompatibilityFn func(ParsedSchema, []ParsedSchema) error

type Metadata struct {
	Authority     string
	Format        string
	Compatibility string
	SourceURL     string
}

type NamespaceService interface {
	Get(ctx context.Context, name string) (namespace.Namespace, error)
}

type NotificationEventRepository interface {
	Create(ctx context.Context, event changedetector.NotificationEvent) (changedetector.NotificationEvent, error)
	Update(ctx context.Context, Id string, success bool) (changedetector.NotificationEvent, error)
	GetByNameSpaceSchemaVersionAndSuccess(ctx context.Context, namespace string, schemaID int32, versionID string, success bool) (changedetector.NotificationEvent, error)
}

type ParsedSchema interface {
	IsBackwardCompatible(ParsedSchema) error
	IsForwardCompatible(ParsedSchema) error
	IsFullCompatible(ParsedSchema) error
	Format() string
	GetCanonicalValue() *SchemaFile
}

type Producer interface {
	Write(topic string, protoMessage proto.Message) error
}

type Provider interface {
	ParseSchema(format string, data []byte) (ParsedSchema, error)
}

type Repository interface {
	Create(ctx context.Context, request *UpdateSchemaRequest, versionID string, commitSHA string) (version int32, err error)
	List(context.Context, string) ([]Schema, error)
	ListVersions(context.Context, string, string) ([]int32, error)
	Get(context.Context, string, string, int32) ([]byte, error)
	GetLatestVersion(context.Context, string, string) (int32, error)
	GetMetadata(context.Context, string, string) (*Metadata, error)
	UpdateMetadata(context.Context, string, string, *Metadata) (*Metadata, error)
	Delete(context.Context, string, string) error
	DeleteVersion(context.Context, string, string, int32) error
	GetSchemaID(ctx context.Context, ns string, sc string) (int32, error)
	GetVersionCommitSHA(ctx context.Context, schemaID int32, version int32) (string, error)
}

type Schema struct {
	Name          string
	Format        string
	Compatibility string
	Authority     string
	SourceURL     string
}

type SchemaFile struct {
	ID     string
	Types  []string
	Fields []string
	Data   []byte
}

type SchemaInfo struct {
	ID       string `json:"id"`
	Version  int32  `json:"version"`
	Location string `json:"location"`
}

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

type UpdateSchemaRequest struct {
	Namespace  string
	Schema     string
	Metadata   *Metadata
	SchemaFile *SchemaFile
}

type ValidationStrategy func(ParsedSchema, ParsedSchema) error