server

Documentation

Index

• type Server
  • func NewServer(port uint16, v1Ingress plumbingv1.DopplerIngestorServer, ...) (*Server, error)
  • func (g *Server) Addr() string
  • func (g *Server) Start()
  • func (g *Server) Stop()

Types

type Server

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

Server represents the gRPC interface of Doppler. It wraps a gRPC server and handles service registration.

func NewServer

func NewServer(
	port uint16,
	v1Ingress plumbingv1.DopplerIngestorServer,
	v1Egress plumbingv1.DopplerServer,
	v2Ingress loggregator_v2.IngressServer,
	v2Egress loggregator_v2.EgressServer,
	srvOpts ...grpc.ServerOption,
) (*Server, error)

NewServer is the constructor for Server. The constructor attempts to open a listener on the provided port and will return an error if that binding fails.

func (*Server) Addr

func (g *Server) Addr() string

Addr provides the address of the listener.

func (*Server) Start

func (g *Server) Start()

Start initiates the gRPC server.

func (*Server) Stop

func (g *Server) Stop()

Stop closes the gRPC server.