grpc

Documentation

Index

• type ServerGRPC
  • func NewServer(config *configgrpc.ServerConfig, set *receiver.Settings, logger *zap.Logger, ...) *ServerGRPC
  • func (s *ServerGRPC) Report(ctx context.Context, rq *pb.ReportRequest) (*pb.ReportResponse, error)
  • func (s *ServerGRPC) Shutdown()
  • func (s *ServerGRPC) Start(host component.Host) error

Types

type ServerGRPC

type ServerGRPC struct {
	*grpc.Server
	// contains filtered or unexported fields
}

ServerGRPC represents the PbGrpc server components satifsying Receiver interface

func NewServer

func NewServer(config *configgrpc.ServerConfig, set *receiver.Settings, logger *zap.Logger, nextTraces consumer.Traces, obsreport *receiverhelper.ObsReport, telemetry *telemetry.Telemetry) *ServerGRPC

func (*ServerGRPC) Report

func (s *ServerGRPC) Report(ctx context.Context, rq *pb.ReportRequest) (*pb.ReportResponse, error)

Report listens to incoming PbGrpc calls

func (*ServerGRPC) Shutdown

func (s *ServerGRPC) Shutdown()

Shutdown shuts server down

func (*ServerGRPC) Start

func (s *ServerGRPC) Start(host component.Host) error

Start starts the server