Versions in this module Expand all Collapse all v1 v1.0.0 Nov 17, 2021 Changes in this version + var ClusterID = "dekafclusterid" + type Config struct + Debug bool + Host string + MaxMessagesPerTopic int + MessageWaitDeadline time.Duration + Port int32 + type Context struct + func (c *Context) Header() *protocol.RequestHeader + func (ctx *Context) Deadline() (deadline time.Time, ok bool) + func (ctx *Context) Done() <-chan struct{} + func (ctx *Context) Err() error + func (ctx *Context) Request() interface{} + func (ctx *Context) Response() interface{} + func (ctx *Context) String() string + func (ctx *Context) Value(key interface{}) interface{} + type Handler struct + func NewHandler(config Config) (*Handler, error) + func (h *Handler) AddTopic(name string, mp MessageProvider) + func (h *Handler) Run(ctx context.Context, requests <-chan *Context, responses chan<- *Context) + func (h *Handler) Shutdown() error + type MessageProvider func(ctx context.Context, startOffset int64) (int64, []byte, error) + type Server struct + func NewServer(ctx context.Context, listen string, handler *Handler) (*Server, error) + func (s *Server) Addr() net.Addr + func (s *Server) Shutdown() error
Go to main page