Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterBloaderSlaveServiceServer(s grpc.ServiceRegistrar, srv BloaderSlaveServiceServer)
- type BloaderSlaveServiceClient
- type BloaderSlaveServiceServer
- type BloaderSlaveService_CallExecClient
- type BloaderSlaveService_CallExecServer
- type BloaderSlaveService_ReceiveChanelConnectClient
- type BloaderSlaveService_ReceiveChanelConnectServer
- type BloaderSlaveService_SendLoaderClient
- type BloaderSlaveService_SendLoaderServer
- type BloaderSlaveService_SendStoreDataClient
- type BloaderSlaveService_SendStoreDataServer
- type BloaderSlaveService_SlaveCommandDefaultStoreClient
- type BloaderSlaveService_SlaveCommandDefaultStoreServer
- type UnimplementedBloaderSlaveServiceServer
- func (UnimplementedBloaderSlaveServiceServer) CallExec(*v1.CallExecRequest, grpc.ServerStreamingServer[v1.CallExecResponse]) error
- func (UnimplementedBloaderSlaveServiceServer) Connect(context.Context, *v1.ConnectRequest) (*v1.ConnectResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) Disconnect(context.Context, *v1.DisconnectRequest) (*v1.DisconnectResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) ReceiveChanelConnect(*v1.ReceiveChanelConnectRequest, ...) error
- func (UnimplementedBloaderSlaveServiceServer) ReceiveLoadTermChannel(context.Context, *v1.ReceiveLoadTermChannelRequest) (*v1.ReceiveLoadTermChannelResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) SendAuth(context.Context, *v1.SendAuthRequest) (*v1.SendAuthResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) SendLoader(grpc.ClientStreamingServer[v1.SendLoaderRequest, v1.SendLoaderResponse]) error
- func (UnimplementedBloaderSlaveServiceServer) SendStoreData(grpc.ClientStreamingServer[v1.SendStoreDataRequest, v1.SendStoreDataResponse]) error
- func (UnimplementedBloaderSlaveServiceServer) SendStoreOk(context.Context, *v1.SendStoreOkRequest) (*v1.SendStoreOkResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) SendTarget(context.Context, *v1.SendTargetRequest) (*v1.SendTargetResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) SlaveCommand(context.Context, *v1.SlaveCommandRequest) (*v1.SlaveCommandResponse, error)
- func (UnimplementedBloaderSlaveServiceServer) SlaveCommandDefaultStore(...) error
- type UnsafeBloaderSlaveServiceServer
Constants ¶
const ( BloaderSlaveService_Connect_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/Connect" BloaderSlaveService_Disconnect_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/Disconnect" BloaderSlaveService_SlaveCommand_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SlaveCommand" BloaderSlaveService_SlaveCommandDefaultStore_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SlaveCommandDefaultStore" BloaderSlaveService_CallExec_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/CallExec" BloaderSlaveService_ReceiveChanelConnect_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/ReceiveChanelConnect" BloaderSlaveService_SendLoader_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SendLoader" BloaderSlaveService_SendAuth_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SendAuth" BloaderSlaveService_SendStoreData_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SendStoreData" BloaderSlaveService_SendStoreOk_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SendStoreOk" BloaderSlaveService_SendTarget_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/SendTarget" BloaderSlaveService_ReceiveLoadTermChannel_FullMethodName = "/cresplanex.bloader.v1.BloaderSlaveService/ReceiveLoadTermChannel" )
Variables ¶
var BloaderSlaveService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cresplanex.bloader.v1.BloaderSlaveService", HandlerType: (*BloaderSlaveServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Connect", Handler: _BloaderSlaveService_Connect_Handler, }, { MethodName: "Disconnect", Handler: _BloaderSlaveService_Disconnect_Handler, }, { MethodName: "SlaveCommand", Handler: _BloaderSlaveService_SlaveCommand_Handler, }, { MethodName: "SendAuth", Handler: _BloaderSlaveService_SendAuth_Handler, }, { MethodName: "SendStoreOk", Handler: _BloaderSlaveService_SendStoreOk_Handler, }, { MethodName: "SendTarget", Handler: _BloaderSlaveService_SendTarget_Handler, }, { MethodName: "ReceiveLoadTermChannel", Handler: _BloaderSlaveService_ReceiveLoadTermChannel_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SlaveCommandDefaultStore", Handler: _BloaderSlaveService_SlaveCommandDefaultStore_Handler, ClientStreams: true, }, { StreamName: "CallExec", Handler: _BloaderSlaveService_CallExec_Handler, ServerStreams: true, }, { StreamName: "ReceiveChanelConnect", Handler: _BloaderSlaveService_ReceiveChanelConnect_Handler, ServerStreams: true, }, { StreamName: "SendLoader", Handler: _BloaderSlaveService_SendLoader_Handler, ClientStreams: true, }, { StreamName: "SendStoreData", Handler: _BloaderSlaveService_SendStoreData_Handler, ClientStreams: true, }, }, Metadata: "cresplanex/bloader/v1/bloader.proto", }
BloaderSlaveService_ServiceDesc is the grpc.ServiceDesc for BloaderSlaveService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBloaderSlaveServiceServer ¶
func RegisterBloaderSlaveServiceServer(s grpc.ServiceRegistrar, srv BloaderSlaveServiceServer)
Types ¶
type BloaderSlaveServiceClient ¶
type BloaderSlaveServiceClient interface {
Connect(ctx context.Context, in *v1.ConnectRequest, opts ...grpc.CallOption) (*v1.ConnectResponse, error)
Disconnect(ctx context.Context, in *v1.DisconnectRequest, opts ...grpc.CallOption) (*v1.DisconnectResponse, error)
SlaveCommand(ctx context.Context, in *v1.SlaveCommandRequest, opts ...grpc.CallOption) (*v1.SlaveCommandResponse, error)
SlaveCommandDefaultStore(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[v1.SlaveCommandDefaultStoreRequest, v1.SlaveCommandDefaultStoreResponse], error)
CallExec(ctx context.Context, in *v1.CallExecRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v1.CallExecResponse], error)
ReceiveChanelConnect(ctx context.Context, in *v1.ReceiveChanelConnectRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v1.ReceiveChanelConnectResponse], error)
SendLoader(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[v1.SendLoaderRequest, v1.SendLoaderResponse], error)
SendAuth(ctx context.Context, in *v1.SendAuthRequest, opts ...grpc.CallOption) (*v1.SendAuthResponse, error)
SendStoreData(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[v1.SendStoreDataRequest, v1.SendStoreDataResponse], error)
SendStoreOk(ctx context.Context, in *v1.SendStoreOkRequest, opts ...grpc.CallOption) (*v1.SendStoreOkResponse, error)
SendTarget(ctx context.Context, in *v1.SendTargetRequest, opts ...grpc.CallOption) (*v1.SendTargetResponse, error)
ReceiveLoadTermChannel(ctx context.Context, in *v1.ReceiveLoadTermChannelRequest, opts ...grpc.CallOption) (*v1.ReceiveLoadTermChannelResponse, error)
}
BloaderSlaveServiceClient is the client API for BloaderSlaveService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewBloaderSlaveServiceClient ¶
func NewBloaderSlaveServiceClient(cc grpc.ClientConnInterface) BloaderSlaveServiceClient
type BloaderSlaveServiceServer ¶
type BloaderSlaveServiceServer interface {
Connect(context.Context, *v1.ConnectRequest) (*v1.ConnectResponse, error)
Disconnect(context.Context, *v1.DisconnectRequest) (*v1.DisconnectResponse, error)
SlaveCommand(context.Context, *v1.SlaveCommandRequest) (*v1.SlaveCommandResponse, error)
SlaveCommandDefaultStore(grpc.ClientStreamingServer[v1.SlaveCommandDefaultStoreRequest, v1.SlaveCommandDefaultStoreResponse]) error
CallExec(*v1.CallExecRequest, grpc.ServerStreamingServer[v1.CallExecResponse]) error
ReceiveChanelConnect(*v1.ReceiveChanelConnectRequest, grpc.ServerStreamingServer[v1.ReceiveChanelConnectResponse]) error
SendLoader(grpc.ClientStreamingServer[v1.SendLoaderRequest, v1.SendLoaderResponse]) error
SendAuth(context.Context, *v1.SendAuthRequest) (*v1.SendAuthResponse, error)
SendStoreData(grpc.ClientStreamingServer[v1.SendStoreDataRequest, v1.SendStoreDataResponse]) error
SendStoreOk(context.Context, *v1.SendStoreOkRequest) (*v1.SendStoreOkResponse, error)
SendTarget(context.Context, *v1.SendTargetRequest) (*v1.SendTargetResponse, error)
ReceiveLoadTermChannel(context.Context, *v1.ReceiveLoadTermChannelRequest) (*v1.ReceiveLoadTermChannelResponse, error)
}
BloaderSlaveServiceServer is the server API for BloaderSlaveService service. All implementations should embed UnimplementedBloaderSlaveServiceServer for forward compatibility.
type BloaderSlaveService_CallExecClient ¶
type BloaderSlaveService_CallExecClient = grpc.ServerStreamingClient[v1.CallExecResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_CallExecServer ¶
type BloaderSlaveService_CallExecServer = grpc.ServerStreamingServer[v1.CallExecResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_ReceiveChanelConnectClient ¶
type BloaderSlaveService_ReceiveChanelConnectClient = grpc.ServerStreamingClient[v1.ReceiveChanelConnectResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_ReceiveChanelConnectServer ¶
type BloaderSlaveService_ReceiveChanelConnectServer = grpc.ServerStreamingServer[v1.ReceiveChanelConnectResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_SendLoaderClient ¶
type BloaderSlaveService_SendLoaderClient = grpc.ClientStreamingClient[v1.SendLoaderRequest, v1.SendLoaderResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_SendLoaderServer ¶
type BloaderSlaveService_SendLoaderServer = grpc.ClientStreamingServer[v1.SendLoaderRequest, v1.SendLoaderResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_SendStoreDataClient ¶
type BloaderSlaveService_SendStoreDataClient = grpc.ClientStreamingClient[v1.SendStoreDataRequest, v1.SendStoreDataResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_SendStoreDataServer ¶
type BloaderSlaveService_SendStoreDataServer = grpc.ClientStreamingServer[v1.SendStoreDataRequest, v1.SendStoreDataResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_SlaveCommandDefaultStoreClient ¶
type BloaderSlaveService_SlaveCommandDefaultStoreClient = grpc.ClientStreamingClient[v1.SlaveCommandDefaultStoreRequest, v1.SlaveCommandDefaultStoreResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BloaderSlaveService_SlaveCommandDefaultStoreServer ¶
type BloaderSlaveService_SlaveCommandDefaultStoreServer = grpc.ClientStreamingServer[v1.SlaveCommandDefaultStoreRequest, v1.SlaveCommandDefaultStoreResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedBloaderSlaveServiceServer ¶
type UnimplementedBloaderSlaveServiceServer struct{}
UnimplementedBloaderSlaveServiceServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedBloaderSlaveServiceServer) CallExec ¶
func (UnimplementedBloaderSlaveServiceServer) CallExec(*v1.CallExecRequest, grpc.ServerStreamingServer[v1.CallExecResponse]) error
func (UnimplementedBloaderSlaveServiceServer) Connect ¶
func (UnimplementedBloaderSlaveServiceServer) Connect(context.Context, *v1.ConnectRequest) (*v1.ConnectResponse, error)
func (UnimplementedBloaderSlaveServiceServer) Disconnect ¶
func (UnimplementedBloaderSlaveServiceServer) Disconnect(context.Context, *v1.DisconnectRequest) (*v1.DisconnectResponse, error)
func (UnimplementedBloaderSlaveServiceServer) ReceiveChanelConnect ¶
func (UnimplementedBloaderSlaveServiceServer) ReceiveChanelConnect(*v1.ReceiveChanelConnectRequest, grpc.ServerStreamingServer[v1.ReceiveChanelConnectResponse]) error
func (UnimplementedBloaderSlaveServiceServer) ReceiveLoadTermChannel ¶
func (UnimplementedBloaderSlaveServiceServer) ReceiveLoadTermChannel(context.Context, *v1.ReceiveLoadTermChannelRequest) (*v1.ReceiveLoadTermChannelResponse, error)
func (UnimplementedBloaderSlaveServiceServer) SendAuth ¶
func (UnimplementedBloaderSlaveServiceServer) SendAuth(context.Context, *v1.SendAuthRequest) (*v1.SendAuthResponse, error)
func (UnimplementedBloaderSlaveServiceServer) SendLoader ¶
func (UnimplementedBloaderSlaveServiceServer) SendLoader(grpc.ClientStreamingServer[v1.SendLoaderRequest, v1.SendLoaderResponse]) error
func (UnimplementedBloaderSlaveServiceServer) SendStoreData ¶
func (UnimplementedBloaderSlaveServiceServer) SendStoreData(grpc.ClientStreamingServer[v1.SendStoreDataRequest, v1.SendStoreDataResponse]) error
func (UnimplementedBloaderSlaveServiceServer) SendStoreOk ¶
func (UnimplementedBloaderSlaveServiceServer) SendStoreOk(context.Context, *v1.SendStoreOkRequest) (*v1.SendStoreOkResponse, error)
func (UnimplementedBloaderSlaveServiceServer) SendTarget ¶
func (UnimplementedBloaderSlaveServiceServer) SendTarget(context.Context, *v1.SendTargetRequest) (*v1.SendTargetResponse, error)
func (UnimplementedBloaderSlaveServiceServer) SlaveCommand ¶
func (UnimplementedBloaderSlaveServiceServer) SlaveCommand(context.Context, *v1.SlaveCommandRequest) (*v1.SlaveCommandResponse, error)
func (UnimplementedBloaderSlaveServiceServer) SlaveCommandDefaultStore ¶
func (UnimplementedBloaderSlaveServiceServer) SlaveCommandDefaultStore(grpc.ClientStreamingServer[v1.SlaveCommandDefaultStoreRequest, v1.SlaveCommandDefaultStoreResponse]) error
type UnsafeBloaderSlaveServiceServer ¶
type UnsafeBloaderSlaveServiceServer interface {
// contains filtered or unexported methods
}
UnsafeBloaderSlaveServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BloaderSlaveServiceServer will result in compilation errors.
Source Files
¶
- bloader_grpc.pb.go