grpc

Documentation

Index

• func Start(ctx context.Context, name string, ch chan interface{}) error
• type Config
• type Server
  • func (s *Server) Tracepoint(srv pb.TCPDog_TracepointServer) error
  • func (s *Server) TracepointSPB(srv pb.TCPDog_TracepointSPBServer) error

Functions

func Start

func Start(ctx context.Context, name string, ch chan interface{}) error

Start starts gRPC server

Types

type Config

type Config struct {
	Addr             string
	NumStreamWorkers uint32
	TLSConfig        *config.TLSConfig
}

Config represents kafka consumer configuration

type Server

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

Server represents gRPC server

func (*Server) Tracepoint

func (s *Server) Tracepoint(srv pb.TCPDog_TracepointServer) error

Tracepoint receives protobuf messages

func (*Server) TracepointSPB

func (s *Server) TracepointSPB(srv pb.TCPDog_TracepointSPBServer) error

TracepointSPB receives struct protobuf messages