service

Documentation

Index

• type PingService
  • func NewPingService(list net.Listener) *PingService
  • func (s *PingService) Ping(ctx context.Context, req *pb.PingRequest) (res *pb.PingResponse, err error)
  • func (s *PingService) Start(ctx context.Context) error
  • func (s *PingService) StartHTTP(ctx context.Context, addr string) error
  • func (s *PingService) Stream(stream pb.Service_StreamServer) error

Types

type PingService

type PingService struct {
	pb.UnimplementedServiceServer
	// contains filtered or unexported fields
}

PingService represents the server that responds to pings

func NewPingService

func NewPingService(list net.Listener) *PingService

NewPingService creates an instance of the PingService

func (*PingService) Ping

func (s *PingService) Ping(ctx context.Context, req *pb.PingRequest) (res *pb.PingResponse, err error)

Ping performs ping

func (*PingService) Start

func (s *PingService) Start(ctx context.Context) error

Start starts the ping service as a gRPC server

func (*PingService) StartHTTP

func (s *PingService) StartHTTP(ctx context.Context, addr string) error

StartHTTP starts the ping service as a HTTP server

func (*PingService) Stream

func (s *PingService) Stream(stream pb.Service_StreamServer) error

Stream stream messages