protocol

Documentation

Index

• func HandleProtocolPacket(kreq kmsg.Request) (kmsg.Response, error)
• type APIVersions
  • func (h *APIVersions) Handle(kreq kmsg.Request) (kmsg.Response, error)
• type APIVersionsProtocolHandler
• type Metadata
  • func (h *Metadata) Handle(kreq kmsg.Request) (kmsg.Response, error)
• type Produce
  • func (h *Produce) Handle(kreq kmsg.Request) (kmsg.Response, error)
• type ProtocolHandler

Functions

func HandleProtocolPacket

func HandleProtocolPacket(kreq kmsg.Request) (kmsg.Response, error)

Types

type APIVersions

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

func (*APIVersions) Handle

func (h *APIVersions) Handle(kreq kmsg.Request) (kmsg.Response, error)

type APIVersionsProtocolHandler

type APIVersionsProtocolHandler struct {
	ApiKey     int16
	MinVersion int16
	MaxVersion int16

	Handler ProtocolHandler
}

type Metadata

type Metadata struct {
}

func (*Metadata) Handle

func (h *Metadata) Handle(kreq kmsg.Request) (kmsg.Response, error)

type Produce

type Produce struct {
}

func (*Produce) Handle

func (h *Produce) Handle(kreq kmsg.Request) (kmsg.Response, error)

type ProtocolHandler

type ProtocolHandler interface {
	Handle(kreq kmsg.Request) (kmsg.Response, error)
}