grpc

Documentation

Index

• Constants
• Variables
• func RequestSign(ts string, secret string) string
• func RpcSign(secret string) (string, int64)
• type Client
  • func NewClient() *Client
  • func (g *Client) Close() error
  • func (g *Client) Connect() (*grpc.ClientConn, error)
  • func (g *Client) Init(address string, token string) *Client
• type CustomCredential
  • func NewCustomCredential(token string) *CustomCredential
  • func (c CustomCredential) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)
  • func (c CustomCredential) RequireTransportSecurity() bool
• type Server
  • func NewServer() *Server
  • func (g *Server) Init(network, address, token string) *Server
  • func (g *Server) RegisterServer(register ServerRegister) *Server
  • func (g *Server) Start() error
• type ServerRegister

Constants

const (
	TCP = "tcp"
	UDP = "udp"
)

Variables

var GrpcClient = new(Client)

var GrpcServer = new(Server)

Functions

func RequestSign

func RequestSign(ts string, secret string) string

func RpcSign

func RpcSign(secret string) (string, int64)

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Close

func (g *Client) Close() error

func (*Client) Connect

func (g *Client) Connect() (*grpc.ClientConn, error)

func (*Client) Init

func (g *Client) Init(address string, token string) *Client

Init 初始化

type CustomCredential

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

CustomCredential 自定义认证

func NewCustomCredential

func NewCustomCredential(token string) *CustomCredential

func (CustomCredential) GetRequestMetadata

func (c CustomCredential) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

GetRequestMetadata 实现自定义认证接口

func (CustomCredential) RequireTransportSecurity

func (c CustomCredential) RequireTransportSecurity() bool

RequireTransportSecurity 自定义认证是否开启TLS

type Server

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

func NewServer

func NewServer() *Server

func (*Server) Init

func (g *Server) Init(network, address, token string) *Server

Init 初始化

func (*Server) RegisterServer

func (g *Server) RegisterServer(register ServerRegister) *Server

func (*Server) Start

func (g *Server) Start() error

Start 启动grpc 服务

type ServerRegister

type ServerRegister func(server *grpc.Server)