kafka

Documentation

Index

• Constants
• type Server
  • func NewServer(serverAddr string, timeout time.Duration, ...) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Start() error

Constants

const (
	ProducePipelineSize = 100
)

Types

type Server

type Server struct {
	Addr               string
	Ln                 *net.TCPListener
	ShutdownCh         chan struct{}
	APIHandler         *handler.KafkaAPIHandler
	ConnectionsMaxIdle time.Duration
}

func NewServer

func NewServer(serverAddr string, timeout time.Duration, getter handler.LogStreamWrapperGetter, runtimeConfig *runtimeconfig.RuntimeConfig) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

func (s *Server) Start() error