gxyrpc

Documentation

Index

• func WithMeta(meta string) serviceOptionFunc
• func WithName(name string) serviceOptionFunc
• type RpcClient
  • func NewGrpcClient(configFile string) (*RpcClient, error)
  • func (g *RpcClient) Broadcast(ctx context.Context, servicePath string, serviceMethod string, ...) error
  • func (g *RpcClient) Call(ctx context.Context, servicePath string, serviceMethod string, ...) error
  • func (g *RpcClient) Close() error
  • func (g *RpcClient) DownloadFile(ctx context.Context, requestFileName string, saveTo io.Writer, ...) error
  • func (g *RpcClient) Fork(ctx context.Context, servicePath string, serviceMethod string, ...) error
  • func (g *RpcClient) Go(ctx context.Context, servicePath string, serviceMethod string, ...) (*client.Call, error)
  • func (g *RpcClient) SendFile(ctx context.Context, fileName string, rateInBytesPerSecond int64, ...) error
  • func (g *RpcClient) Stream(ctx context.Context, meta map[string]string) (net.Conn, error)
• type RpcServer
  • func NewGrpcServer(configFile string) (*RpcServer, error)
  • func (g *RpcServer) ReigsterService(service interface{}, opts ...serviceOptionFunc) error
  • func (g *RpcServer) Start() error
  • func (g *RpcServer) Stop() error

Functions

func WithMeta

func WithMeta(meta string) serviceOptionFunc

func WithName

func WithName(name string) serviceOptionFunc

Types

type RpcClient

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

func NewGrpcClient

func NewGrpcClient(configFile string) (*RpcClient, error)

func (*RpcClient) Broadcast

func (g *RpcClient) Broadcast(ctx context.Context, servicePath string, serviceMethod string, args interface{}, reply interface{}) error

func (*RpcClient) Call

func (g *RpcClient) Call(ctx context.Context, servicePath string, serviceMethod string, args interface{}, reply interface{}) error

func (*RpcClient) Close

func (g *RpcClient) Close() error

func (*RpcClient) DownloadFile

func (g *RpcClient) DownloadFile(ctx context.Context, requestFileName string, saveTo io.Writer, meta map[string]string) error

func (*RpcClient) Fork

func (g *RpcClient) Fork(ctx context.Context, servicePath string, serviceMethod string, args interface{}, reply interface{}) error

func (*RpcClient) Go

func (g *RpcClient) Go(ctx context.Context, servicePath string, serviceMethod string, args interface{}, reply interface{}, done chan *client.Call) (*client.Call, error)

func (*RpcClient) SendFile

func (g *RpcClient) SendFile(ctx context.Context, fileName string, rateInBytesPerSecond int64, meta map[string]string) error

func (*RpcClient) Stream

func (g *RpcClient) Stream(ctx context.Context, meta map[string]string) (net.Conn, error)

type RpcServer

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

func NewGrpcServer

func NewGrpcServer(configFile string) (*RpcServer, error)

func (*RpcServer) ReigsterService

func (g *RpcServer) ReigsterService(service interface{}, opts ...serviceOptionFunc) error

func (*RpcServer) Start

func (g *RpcServer) Start() error

func (*RpcServer) Stop

func (g *RpcServer) Stop() error