Versions in this module Expand all Collapse all v1 v1.1.0 Mar 15, 2026 Changes in this version + type SchemaHandler struct + func NewSchemaHandler(baseHandler RequestHandler, registry *schema.SchemaRegistry, enabled bool) *SchemaHandler + func (h *SchemaHandler) GetStats() map[string]int64 + func (h *SchemaHandler) Handle(req *protocol.Request) *protocol.Response v1.0.1 Nov 22, 2025 Changes in this version + type Config struct + Address string + IdleTimeout time.Duration + KeepAlive bool + KeepAlivePeriod time.Duration + MaxConnections int + MaxMessageSize uint32 + NumWorkers int + ReadTimeout time.Duration + WriteTimeout time.Duration + func DefaultConfig() *Config + type Handler struct + func NewHandler() *Handler + func NewHandlerWithDataDir(dataDir string) *Handler + func (h *Handler) Close() error + func (h *Handler) Handle(req *protocol.Request) *protocol.Response + func (h *Handler) Stats() HandlerStats + type HandlerStats struct + ErrorsHandled int64 + RequestsHandled int64 + Uptime time.Duration + type Partition struct + type RequestHandler interface + Handle func(req *protocol.Request) *protocol.Response + type SecurityHandler struct + func NewSecurityHandler(baseHandler RequestHandler, securityManager *security.Manager, enabled bool) *SecurityHandler + func (h *SecurityHandler) GetStats() map[string]int64 + func (h *SecurityHandler) Handle(req *protocol.Request) *protocol.Response + type Server struct + func New(config *Config, handler RequestHandler) (*Server, error) + func (s *Server) Listener() net.Listener + func (s *Server) Start() error + func (s *Server) Stats() ServerStats + func (s *Server) Stop() error + type ServerStats struct + ActiveConnections int64 + TotalBytesRecv int64 + TotalBytesSent int64 + TotalErrors int64 + TotalRequests int64 + Uptime time.Duration + type TenancyHandler struct + func NewTenancyHandler(baseHandler *Handler, tenancyManager *tenancy.Manager, enabled bool) *TenancyHandler + func (h *TenancyHandler) GetStats() map[string]int64 + func (h *TenancyHandler) Handle(req *protocol.Request) *protocol.Response + type Topic struct + type TopicInfo struct + Name string + NumPartitions uint32 + type TopicManager struct + func NewTopicManager(dataDir string) *TopicManager + func (tm *TopicManager) Close() error + func (tm *TopicManager) CreateTopic(name string, numPartitions uint32) error + func (tm *TopicManager) DeleteTopic(name string) error + func (tm *TopicManager) GetPartition(topic string, partitionID uint32) (*Partition, error) + func (tm *TopicManager) ListTopics() []TopicInfo + func (tm *TopicManager) TopicExists(name string) bool
Go to main page