rpc

Documentation

Index

• func EnablePlugin(ctx context.Context)
• func GetLocalIP() (net.IP, error)
• func SetRPCServerAddr(addr string)
• func WarpServiceAddr(serviceAddr string) (string, error)
• type RpcConfig
• type Service
  • func GetService() Service

Functions

func EnablePlugin

func EnablePlugin(ctx context.Context)

func GetLocalIP

func GetLocalIP() (net.IP, error)

func SetRPCServerAddr

func SetRPCServerAddr(addr string)

func WarpServiceAddr

func WarpServiceAddr(serviceAddr string) (string, error)

Types

type RpcConfig

type RpcConfig struct {
	MaxMsgSize           int    `mapstructure:"max_msg_size,omitempty" json:"max_msg_size,omitempty"`
	MaxConcurrentStreams uint32 `mapstructure:"max_concurrent_streams,omitempty" json:"max_concurrent_streams,omitempty"`
	RPCServerAddr        string `mapstructure:"rpc_server_addr,omitempty" json:"rpc_server_addr,omitempty"`
	DisableTCPServer     bool   `mapstructure:"disable_tcp_server,omitempty" json:"disable_tcp_server,omitempty"`
	DisableQUICServer    bool   `mapstructure:"disable_quic_server,omitempty" json:"disable_quic_server,omitempty"`
}

type Service

type Service interface {
	GetGRPCServer() *grpc.Server
	GetRPCServerAddr() string
	GetRegisterServiceId() string
}

func GetService

func GetService() Service