server

Documentation

Index

• Constants
• Variables
• func New(opts server.Options) server.ProtocolServer
• func Request2Invocation(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo) *invocation.Invocation
• type Server
  • func (s *Server) Register(schema interface{}, options ...server.RegisterOption) (string, error)
  • func (s *Server) Start() error
  • func (s *Server) Stop() error
  • func (s *Server) String() string

Constants

const (
	Name = "grpc"
)

const

Variables

var (
	ErrGRPCSvcDescMissing = errors.New("must use server.WithRPCServiceDesc to set desc")
	ErrGRPCSvcType        = errors.New("must set *grpc.ServiceDesc")
)

err define

Functions

func New

func New(opts server.Options) server.ProtocolServer

New create grpc server

func Request2Invocation

func Request2Invocation(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo) *invocation.Invocation

Request2Invocation convert grpc protocol to invocation

Types

type Server

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

Server is grpc server holder

func (*Server) Register

func (s *Server) Register(schema interface{}, options ...server.RegisterOption) (string, error)

Register register grpc services

func (*Server) Start

func (s *Server) Start() error

Start launch the server

func (*Server) Stop

func (s *Server) Stop() error

Stop gracfully shutdown grpc server

func (*Server) String

func (s *Server) String() string

String return server name