Versions in this module Expand all Collapse all v0 v0.0.5 Dec 25, 2021 v0.0.4 Oct 15, 2021 Changes in this version + type Config struct + ListenAddr string + MultiCore bool + type Server struct + ConnMap sync.Map + SaslMap sync.Map + func Run(config *Config, kfkProtocolConfig *codec.KafkaProtocolConfig, ...) (*Server, error) + func (s *Server) ApiVersions(frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) AuthFailed() ([]byte, gnet.Action) + func (s *Server) Authed(context *context.NetworkContext) bool + func (s *Server) Fetch(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) FindCoordinator(frame []byte, version int16, config *codec.KafkaProtocolConfig) ([]byte, gnet.Action) + func (s *Server) FindCoordinatorVersion(frame []byte, version int16, config *codec.KafkaProtocolConfig) ([]byte, gnet.Action) + func (s *Server) Heartbeat(frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) JoinGroup(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) LeaveGroup(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ListOffsets(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ListOffsetsVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) Metadata(frame []byte, version int16, config *codec.KafkaProtocolConfig) ([]byte, gnet.Action) + func (s *Server) OffsetCommit(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) OffsetCommitVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) OffsetFetch(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) OffsetFetchVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) OnClosed(c gnet.Conn, err error) (action gnet.Action) + func (s *Server) OnInitComplete(server gnet.Server) (action gnet.Action) + func (s *Server) OnOpened(c gnet.Conn) (out []byte, action gnet.Action) + func (s *Server) React(frame []byte, c gnet.Conn) ([]byte, gnet.Action) + func (s *Server) ReactApiVersion(frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ReactFetchVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ReactHeartbeatVersion(frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ReactJoinGroupVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ReactLeaveGroupVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ReactMetadataVersion(frame []byte, version int16, config *codec.KafkaProtocolConfig) ([]byte, gnet.Action) + func (s *Server) ReactSaslHandshakeAuthVersion(frame []byte, version int16, context *context.NetworkContext) ([]byte, gnet.Action) + func (s *Server) ReactSaslVersion(frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) ReactSyncGroupVersion(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) SaslAuthenticate(frame []byte, version int16, context *context.NetworkContext) ([]byte, gnet.Action) + func (s *Server) SaslHandshake(frame []byte, version int16) ([]byte, gnet.Action) + func (s *Server) SyncGroup(ctx *context.NetworkContext, frame []byte, version int16) ([]byte, gnet.Action)
Go to main page