Documentation
¶
Index ¶
- func WithMeta(meta string) serviceOptionFunc
- func WithName(name string) serviceOptionFunc
- type RpcClient
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RpcClient ¶
type RpcClient struct {
// contains filtered or unexported fields
}
func NewGrpcClient ¶
func (*RpcClient) DownloadFile ¶
type RpcServer ¶
type RpcServer struct {
// contains filtered or unexported fields
}
func NewGrpcServer ¶
func (*RpcServer) ReigsterService ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.