schemaregistry

Documentation

Index

• func NewSchemaRpcServer(m *schemastorage.SchemaManager) *schemaRpcServer
• type SchemaServer
  • func NewSchemaServer(cfg *utils.SchemaRegistryConfig) (*SchemaServer, error)
  • func (s *SchemaServer) Prepare() error
  • func (s *SchemaServer) Start() error
  • func (s *SchemaServer) Stop() error
  • func (s *SchemaServer) Wait() error

Functions

func NewSchemaRpcServer

func NewSchemaRpcServer(m *schemastorage.SchemaManager) *schemaRpcServer

Types

type SchemaServer

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

func NewSchemaServer

func NewSchemaServer(cfg *utils.SchemaRegistryConfig) (*SchemaServer, error)

func (*SchemaServer) Prepare

func (s *SchemaServer) Prepare() error

Prepare prepares the server.

func (*SchemaServer) Start

func (s *SchemaServer) Start() error

func (*SchemaServer) Stop

func (s *SchemaServer) Stop() error

func (*SchemaServer) Wait

func (s *SchemaServer) Wait() error