istio

README

istio

通用istio处理

Documentation

Index

• func GetHTTPForwardHeadergo(req *http.Request) http.Header
• type GrpcClient
  • func NewGrpcClient(serviceName string, port int, ...) *GrpcClient
  • func (c *GrpcClient) Close()
  • func (c *GrpcClient) GetConn() *grpc.ClientConn
• type GrpcServer
  • func NewGrpcServer(name string, address string, ...) *GrpcServer
  • func (s *GrpcServer) GetSrv() *grpc.Server
  • func (s *GrpcServer) Run()
  • func (s *GrpcServer) Start()
  • func (s *GrpcServer) Stop()

Functions

func GetHTTPForwardHeadergo

func GetHTTPForwardHeadergo(req *http.Request) http.Header

GetHTTPForwardHeadergo 获取Http跟踪Header

Types

type GrpcClient

type GrpcClient struct {
	Log log.Logger
	// contains filtered or unexported fields
}

GrpcClient grpc客户端

func NewGrpcClient

func NewGrpcClient(serviceName string, port int, streamClientInterceptors []grpc.StreamClientInterceptor, unaryClientInterceptors []grpc.UnaryClientInterceptor) *GrpcClient

NewGrpcClient 创建Grpc客户端

func (*GrpcClient) Close

func (c *GrpcClient) Close()

Close 关闭

func (*GrpcClient) GetConn

func (c *GrpcClient) GetConn() *grpc.ClientConn

GetConn 获取客户端连接

type GrpcServer

type GrpcServer struct {
	Log log.Logger
	// contains filtered or unexported fields
}

GrpcServer 服务端

func NewGrpcServer

func NewGrpcServer(name string, address string, streamServerInterceptors []grpc.StreamServerInterceptor, unaryServerInterceptors []grpc.UnaryServerInterceptor) *GrpcServer

NewGrpcServer 创建Grpc服务端

func (*GrpcServer) GetSrv

func (s *GrpcServer) GetSrv() *grpc.Server

GetSrv 获取rpc server

func (*GrpcServer) Run

func (s *GrpcServer) Run()

Run ...

func (*GrpcServer) Start

func (s *GrpcServer) Start()

Start 启动

func (*GrpcServer) Stop

func (s *GrpcServer) Stop()

Stop ...