rpcx

Documentation

Index

• func WithBasePath(basePath string) rpcxOption
• func WithClientName(clientName string) rpcxOption
• func WithConsulServer(server string) rpcxOption
• func WithConsulServers(servers ...string) rpcxOption
• func WithJeagerAgentHostPort(JaegeragentHostPort string) rpcxOption
• func WithMetaData(key, val string) metaDataWarp
• func WithOpenTracing(disable bool) rpcxOption
• func WithServerAddress(server string) rpcxOption
• func WithServiceName(serviceName string) rpcxOption
• func WithUseConsulRegistry(useConsulRegistry bool) rpcxOption
• type RpcxClientWithOpt
  • func NewClient(opts ...rpcxOption) (*RpcxClientWithOpt, error)
  • func (s *RpcxClientWithOpt) Broadcast(ctx context.Context, serviceMethod string, arg interface{}, replay interface{}, ...) error
  • func (s *RpcxClientWithOpt) Call(ctx context.Context, serviceMethod string, arg interface{}, replay interface{}, ...) error
  • func (s *RpcxClientWithOpt) Close() error
  • func (s *RpcxClientWithOpt) CloseAndShutdownTrace() error
  • func (c *RpcxClientWithOpt) GetOnce() (client.XClient, error)
  • func (c *RpcxClientWithOpt) NewBidirectionalXClient(ch chan *protocol.Message) (client.XClient, error)
  • func (s *RpcxClientWithOpt) ShutdownTrace() error

Functions

func WithBasePath

func WithBasePath(basePath string) rpcxOption

func WithClientName

func WithClientName(clientName string) rpcxOption

func WithConsulServer

func WithConsulServer(server string) rpcxOption

func WithConsulServers

func WithConsulServers(servers ...string) rpcxOption

func WithJeagerAgentHostPort

func WithJeagerAgentHostPort(JaegeragentHostPort string) rpcxOption

func WithMetaData

func WithMetaData(key, val string) metaDataWarp

func WithOpenTracing

func WithOpenTracing(disable bool) rpcxOption

func WithServerAddress

func WithServerAddress(server string) rpcxOption

func WithServiceName

func WithServiceName(serviceName string) rpcxOption

func WithUseConsulRegistry

func WithUseConsulRegistry(useConsulRegistry bool) rpcxOption

Types

type RpcxClientWithOpt

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

func NewClient

func NewClient(opts ...rpcxOption) (*RpcxClientWithOpt, error)

func (*RpcxClientWithOpt) Broadcast

func (s *RpcxClientWithOpt) Broadcast(ctx context.Context, serviceMethod string, arg interface{}, replay interface{}, metadata ...metaDataWarp) error

func (*RpcxClientWithOpt) Call

func (s *RpcxClientWithOpt) Call(ctx context.Context, serviceMethod string, arg interface{}, replay interface{}, metadata ...metaDataWarp) error

func (*RpcxClientWithOpt) Close

func (s *RpcxClientWithOpt) Close() error

func (*RpcxClientWithOpt) CloseAndShutdownTrace

func (s *RpcxClientWithOpt) CloseAndShutdownTrace() error

func (*RpcxClientWithOpt) GetOnce

func (c *RpcxClientWithOpt) GetOnce() (client.XClient, error)

func (*RpcxClientWithOpt) NewBidirectionalXClient

func (c *RpcxClientWithOpt) NewBidirectionalXClient(ch chan *protocol.Message) (client.XClient, error)

func (*RpcxClientWithOpt) ShutdownTrace

func (s *RpcxClientWithOpt) ShutdownTrace() error