opentelemetry

Documentation

Index

• type HTTPServerSettings
• type Protocals
• type Server
  • func (s *Server) Description() string
  • func (s *Server) Init(context pipeline.Context) (int, error)
  • func (s *Server) Start(c pipeline.Collector) error
  • func (s *Server) StartService(ctx pipeline.PipelineContext) error
  • func (s *Server) Stop() error

Types

type HTTPServerSettings

type HTTPServerSettings struct {
	Endpoint              string
	MaxRequestBodySizeMiB int
	ReadTimeoutSec        int
	ShutdownTimeoutSec    int
}

type Protocals

type Protocals struct {
	GRPC *helper.GRPCServerSettings
	HTTP *HTTPServerSettings
}

type Server

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

Server implements ServiceInputV1 and ServiceInputV2

func (*Server) Description

func (s *Server) Description() string

Description ...

func (*Server) Init

func (s *Server) Init(context pipeline.Context) (int, error)

Init ...

func (*Server) Start

func (s *Server) Start(c pipeline.Collector) error

Start ...

func (*Server) StartService

func (s *Server) StartService(ctx pipeline.PipelineContext) error

StartService(PipelineContext) error

func (*Server) Stop

func (s *Server) Stop() error

Stop stops the services and closes any necessary channels and connections