sarama

Documentation

Index

• Variables
• type KafkaServer
  • func NewKafkaServer(opt ...KafkaServerOption) (*KafkaServer, error)
  • func (s *KafkaServer) GracefulStop()
  • func (s *KafkaServer) Serve(lis net.Listener) error
• type KafkaServerOption
  • func WithMetadataStoreGrpcClient(c pb.MetadataStoreClient) KafkaServerOption

Variables

var (
	ErrServerStopped = fmt.Errorf("server stopped")
)

Types

type KafkaServer

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

func NewKafkaServer

func NewKafkaServer(opt ...KafkaServerOption) (*KafkaServer, error)

func (*KafkaServer) GracefulStop

func (s *KafkaServer) GracefulStop()

func (*KafkaServer) Serve

func (s *KafkaServer) Serve(lis net.Listener) error

Serve accepts incoming connections on the listener lis, creating a new service goroutine for each.

Serve panics if lis is nil.

type KafkaServerOption

type KafkaServerOption interface {
	// contains filtered or unexported methods
}

func WithMetadataStoreGrpcClient

func WithMetadataStoreGrpcClient(c pb.MetadataStoreClient) KafkaServerOption