grpc

Documentation

Index

• type Server
  • func New(opts ...ServerOption) (srv *Server, err error)
  • func (s *Server) Endpoint() (*url.URL, error)
  • func (s *Server) HandleNotify(ctx context.Context, req *cluster.NotifyMessage) (rsp *cluster.MemberHandleResponse, err error)
  • func (s *Server) HandlePush(ctx context.Context, req *cluster.PushMessage) (rsp *cluster.MemberHandleResponse, err error)
  • func (s *Server) HandleRequest(ctx context.Context, req *cluster.RequestMessage) (rsp *cluster.MemberHandleResponse, err error)
  • func (s *Server) HandleResponse(ctx context.Context, req *cluster.ResponseMessage) (rsp *cluster.MemberHandleResponse, err error)
  • func (s *Server) Name() string
  • func (s *Server) Start(ctx context.Context) (err error)
  • func (s *Server) Stop(ctx context.Context) (err error)
• type ServerOption
  • func Address(addr string) ServerOption
  • func Listen(lis net.Listener) ServerOption
  • func Log(log log.Logger) ServerOption
  • func Network(network string) ServerOption

Types

type Server

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

func New

func New(opts ...ServerOption) (srv *Server, err error)

func (*Server) Endpoint

func (s *Server) Endpoint() (*url.URL, error)

func (*Server) HandleNotify

func (s *Server) HandleNotify(ctx context.Context, req *cluster.NotifyMessage) (rsp *cluster.MemberHandleResponse, err error)

func (*Server) HandlePush

func (s *Server) HandlePush(ctx context.Context, req *cluster.PushMessage) (rsp *cluster.MemberHandleResponse, err error)

func (*Server) HandleRequest

func (s *Server) HandleRequest(ctx context.Context, req *cluster.RequestMessage) (rsp *cluster.MemberHandleResponse, err error)

func (*Server) HandleResponse

func (s *Server) HandleResponse(ctx context.Context, req *cluster.ResponseMessage) (rsp *cluster.MemberHandleResponse, err error)

func (*Server) Name

func (s *Server) Name() string

func (*Server) Start

func (s *Server) Start(ctx context.Context) (err error)

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) (err error)

type ServerOption

type ServerOption func(s *Server)

func Address

func Address(addr string) ServerOption

func Listen

func Listen(lis net.Listener) ServerOption

func Log

func Log(log log.Logger) ServerOption

func Network

func Network(network string) ServerOption