Documentation
¶
Index ¶
- func RegisterServerAppRpcServer(s *grpc.Server, srv ServerAppRpcServer)
- type ServerAppRpcClient
- type ServerAppRpcServer
- type UnimplementedServerAppRpcServer
- func (*UnimplementedServerAppRpcServer) Boot(ctx context.Context, req *dto.BootReq) (*dto.BootResp, error)
- func (*UnimplementedServerAppRpcServer) Close(ctx context.Context, req *dto.CloseReq) (*dto.CloseResp, error)
- func (*UnimplementedServerAppRpcServer) Open(ctx context.Context, req *dto.OpenReq) (*dto.OpenResp, error)
- func (*UnimplementedServerAppRpcServer) Shutdown(ctx context.Context, req *dto.ShutdownReq) (*dto.ShutdownResp, error)
- func (*UnimplementedServerAppRpcServer) Tick(ctx context.Context, req *dto.TickReq) (*dto.TickResp, error)
- func (*UnimplementedServerAppRpcServer) Traffic(ctx context.Context, req *dto.TrafficReq) (*dto.TrafficResp, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterServerAppRpcServer ¶
func RegisterServerAppRpcServer(s *grpc.Server, srv ServerAppRpcServer)
Types ¶
type ServerAppRpcClient ¶
type ServerAppRpcClient interface { Boot(ctx context.Context, in *dto.BootReq, opts ...grpc.CallOption) (*dto.BootResp, error) Traffic(ctx context.Context, in *dto.TrafficReq, opts ...grpc.CallOption) (*dto.TrafficResp, error) Open(ctx context.Context, in *dto.OpenReq, opts ...grpc.CallOption) (*dto.OpenResp, error) Close(ctx context.Context, in *dto.CloseReq, opts ...grpc.CallOption) (*dto.CloseResp, error) Tick(ctx context.Context, in *dto.TickReq, opts ...grpc.CallOption) (*dto.TickResp, error) Shutdown(ctx context.Context, in *dto.ShutdownReq, opts ...grpc.CallOption) (*dto.ShutdownResp, error) }
ServerAppRpcClient is the client API for ServerAppRpc service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewServerAppRpcClient ¶
func NewServerAppRpcClient(cc *grpc.ClientConn) ServerAppRpcClient
type ServerAppRpcServer ¶
type ServerAppRpcServer interface { Boot(context.Context, *dto.BootReq) (*dto.BootResp, error) Traffic(context.Context, *dto.TrafficReq) (*dto.TrafficResp, error) Open(context.Context, *dto.OpenReq) (*dto.OpenResp, error) Close(context.Context, *dto.CloseReq) (*dto.CloseResp, error) Tick(context.Context, *dto.TickReq) (*dto.TickResp, error) Shutdown(context.Context, *dto.ShutdownReq) (*dto.ShutdownResp, error) }
ServerAppRpcServer is the server API for ServerAppRpc service.
type UnimplementedServerAppRpcServer ¶
type UnimplementedServerAppRpcServer struct { }
UnimplementedServerAppRpcServer can be embedded to have forward compatible implementations.
func (*UnimplementedServerAppRpcServer) Shutdown ¶
func (*UnimplementedServerAppRpcServer) Shutdown(ctx context.Context, req *dto.ShutdownReq) (*dto.ShutdownResp, error)
func (*UnimplementedServerAppRpcServer) Traffic ¶
func (*UnimplementedServerAppRpcServer) Traffic(ctx context.Context, req *dto.TrafficReq) (*dto.TrafficResp, error)
Click to show internal directories.
Click to hide internal directories.