grpc_run

Documentation

Index

• Variables
• func ClientRegister(serviceName string, fn ClientFn) error
• func ServiceLocalList() error
• func ServiceRedisList() error
• func ServiceRegister(serviceName string, fn ServiceFn) (err error)
• type ClientFn
• type GrpcHelper
  • func (h *GrpcHelper) ClientRegister(host, port string, fn ClientFn) error
  • func (GrpcHelper) NewGrpcHelper() GrpcHelperInterface
  • func (h *GrpcHelper) ServiceRegister(host, port string, fn ServiceFn) (err error)
• type GrpcHelperInterface
• type GrpcOprion
• type ServiceFn

Variables

var (
	Conn *grpc.ClientConn
)

var OutTime time.Duration

var ServiceHostList map[string]string

Functions

func ClientRegister

func ClientRegister(serviceName string, fn ClientFn) error

func ServiceLocalList

func ServiceLocalList() error

*@Author Administrator *@Date 23/4/2021 13:31 *@desc 获取当前本地注册服务列表

func ServiceRedisList

func ServiceRedisList() error

*@Author Administrator *@Date 23/4/2021 13:40 *@desc

func ServiceRegister

func ServiceRegister(serviceName string, fn ServiceFn) (err error)

Types

type ClientFn

type ClientFn func(conn *grpc.ClientConn, ctx context.Context) (err error)

type GrpcHelper

type GrpcHelper struct {
	Conn *grpc.ClientConn
	// contains filtered or unexported fields
}

func (*GrpcHelper) ClientRegister

func (h *GrpcHelper) ClientRegister(host, port string, fn ClientFn) error

func (GrpcHelper) NewGrpcHelper

func (GrpcHelper) NewGrpcHelper() GrpcHelperInterface

func (*GrpcHelper) ServiceRegister

func (h *GrpcHelper) ServiceRegister(host, port string, fn ServiceFn) (err error)

type GrpcHelperInterface

type GrpcHelperInterface interface {
	ServiceRegister(host, port string, fn ServiceFn) (err error)
	ClientRegister(host, port string, fn ClientFn) error
}

type GrpcOprion

type GrpcOprion struct {
}

type ServiceFn

type ServiceFn func(server *grpc.Server)