schema

Documentation

Index

• func NewRegistry(topicNameGenerator namegenerator.NameGenerator) schema.Registry
• type Registry
  • func (r *Registry) GetSchema(schemaName string) schema.Struct
  • func (r *Registry) GetSchemaOrCreate(schemaName string, creator func() schema.Struct) schema.Struct
  • func (r *Registry) HypertableEnvelopeSchemaName(hypertable *systemcatalog.Hypertable) string
  • func (r *Registry) HypertableKeySchemaName(hypertable *systemcatalog.Hypertable) string
  • func (r *Registry) MessageEnvelopeSchemaName() string
  • func (r *Registry) RegisterSchema(schemaName string, schema schema.Struct)

Functions

func NewRegistry

func NewRegistry(topicNameGenerator namegenerator.NameGenerator) schema.Registry

Types

type Registry

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

func (*Registry) GetSchema

func (r *Registry) GetSchema(schemaName string) schema.Struct

func (*Registry) GetSchemaOrCreate

func (r *Registry) GetSchemaOrCreate(schemaName string, creator func() schema.Struct) schema.Struct

func (*Registry) HypertableEnvelopeSchemaName

func (r *Registry) HypertableEnvelopeSchemaName(hypertable *systemcatalog.Hypertable) string

func (*Registry) HypertableKeySchemaName

func (r *Registry) HypertableKeySchemaName(hypertable *systemcatalog.Hypertable) string

func (*Registry) MessageEnvelopeSchemaName

func (r *Registry) MessageEnvelopeSchemaName() string

func (*Registry) RegisterSchema

func (r *Registry) RegisterSchema(schemaName string, schema schema.Struct)