server

Documentation

Index

• type Server
  • func (s *Server) Close() (err error)
  • func (s *Server) Listen(addr string, certPath string, keyPath string) (err error)
  • func (s *Server) Send(ctx context.Context, ping *pb.Ping) (*pb.Pong, error)
  • func (s *Server) Subscribe(ping *pb.Ping, stream pb.Echo_SubscribeServer) (err error)

Types

type Server

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

Server echo server side implement struct

func (*Server) Close

func (s *Server) Close() (err error)

Close server

func (*Server) Listen

func (s *Server) Listen(
	addr string,
	certPath string,
	keyPath string,
) (err error)

Listen a http/grpc server

func (*Server) Send

func (s *Server) Send(ctx context.Context, ping *pb.Ping) (*pb.Pong, error)

Send return pong

func (*Server) Subscribe

func (s *Server) Subscribe(ping *pb.Ping, stream pb.Echo_SubscribeServer) (err error)

Subscribe response message for every second