Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterDriverServer(s grpc.ServiceRegistrar, srv DriverServer)
- func RegisterReportServer(s grpc.ServiceRegistrar, srv ReportServer)
- type DriverClient
- type DriverServer
- type ReportClient
- type ReportServer
- type RequestArgs
- func (*RequestArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RequestArgs) GetPluginId() uint32
- func (x *RequestArgs) GetRequest() string
- func (x *RequestArgs) GetRequestId() string
- func (*RequestArgs) ProtoMessage()
- func (x *RequestArgs) ProtoReflect() protoreflect.Message
- func (x *RequestArgs) Reset()
- func (x *RequestArgs) String() string
- type ResponseResult
- func (*ResponseResult) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseResult) GetData() string
- func (x *ResponseResult) GetRequestId() string
- func (*ResponseResult) ProtoMessage()
- func (x *ResponseResult) ProtoReflect() protoreflect.Message
- func (x *ResponseResult) Reset()
- func (x *ResponseResult) String() string
- type UnimplementedDriverServer
- func (UnimplementedDriverServer) Get(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) GetDriverInfo(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) Restart(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) Set(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) SetConfig(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) Setup(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) Start(context.Context, *RequestArgs) (*ResponseResult, error)
- func (UnimplementedDriverServer) Stop(context.Context, *RequestArgs) (*ResponseResult, error)
- type UnimplementedReportServer
- type UnsafeDriverServer
- type UnsafeReportServer
Constants ¶
const ( Driver_GetDriverInfo_FullMethodName = "/proto.Driver/GetDriverInfo" Driver_SetConfig_FullMethodName = "/proto.Driver/SetConfig" Driver_Setup_FullMethodName = "/proto.Driver/Setup" Driver_Start_FullMethodName = "/proto.Driver/Start" Driver_Restart_FullMethodName = "/proto.Driver/Restart" Driver_Stop_FullMethodName = "/proto.Driver/Stop" Driver_Get_FullMethodName = "/proto.Driver/Get" Driver_Set_FullMethodName = "/proto.Driver/Set" )
const ( Report_Post_FullMethodName = "/proto.Report/Post" Report_State_FullMethodName = "/proto.Report/State" )
Variables ¶
var Driver_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Driver", HandlerType: (*DriverServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetDriverInfo", Handler: _Driver_GetDriverInfo_Handler, }, { MethodName: "SetConfig", Handler: _Driver_SetConfig_Handler, }, { MethodName: "Setup", Handler: _Driver_Setup_Handler, }, { MethodName: "Start", Handler: _Driver_Start_Handler, }, { MethodName: "Restart", Handler: _Driver_Restart_Handler, }, { MethodName: "Stop", Handler: _Driver_Stop_Handler, }, { MethodName: "Get", Handler: _Driver_Get_Handler, }, { MethodName: "Set", Handler: _Driver_Set_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "plugin.proto", }
Driver_ServiceDesc is the grpc.ServiceDesc for Driver service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_plugin_proto protoreflect.FileDescriptor
var Report_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Report", HandlerType: (*ReportServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Post", Handler: _Report_Post_Handler, }, { MethodName: "State", Handler: _Report_State_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "plugin.proto", }
Report_ServiceDesc is the grpc.ServiceDesc for Report service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterDriverServer ¶
func RegisterDriverServer(s grpc.ServiceRegistrar, srv DriverServer)
func RegisterReportServer ¶
func RegisterReportServer(s grpc.ServiceRegistrar, srv ReportServer)
Types ¶
type DriverClient ¶
type DriverClient interface { GetDriverInfo(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) SetConfig(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) Setup(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) Start(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) Restart(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) Stop(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) Get(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) Set(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) }
DriverClient is the client API for Driver 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 NewDriverClient ¶
func NewDriverClient(cc grpc.ClientConnInterface) DriverClient
type DriverServer ¶
type DriverServer interface { GetDriverInfo(context.Context, *RequestArgs) (*ResponseResult, error) SetConfig(context.Context, *RequestArgs) (*ResponseResult, error) Setup(context.Context, *RequestArgs) (*ResponseResult, error) Start(context.Context, *RequestArgs) (*ResponseResult, error) Restart(context.Context, *RequestArgs) (*ResponseResult, error) Stop(context.Context, *RequestArgs) (*ResponseResult, error) Get(context.Context, *RequestArgs) (*ResponseResult, error) Set(context.Context, *RequestArgs) (*ResponseResult, error) // contains filtered or unexported methods }
DriverServer is the server API for Driver service. All implementations must embed UnimplementedDriverServer for forward compatibility.
type ReportClient ¶
type ReportClient interface { Post(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) State(ctx context.Context, in *RequestArgs, opts ...grpc.CallOption) (*ResponseResult, error) }
ReportClient is the client API for Report 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 NewReportClient ¶
func NewReportClient(cc grpc.ClientConnInterface) ReportClient
type ReportServer ¶
type ReportServer interface { Post(context.Context, *RequestArgs) (*ResponseResult, error) State(context.Context, *RequestArgs) (*ResponseResult, error) // contains filtered or unexported methods }
ReportServer is the server API for Report service. All implementations must embed UnimplementedReportServer for forward compatibility.
type RequestArgs ¶
type RequestArgs struct { PluginId uint32 `protobuf:"varint,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` Request string `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
func (*RequestArgs) Descriptor
deprecated
func (*RequestArgs) Descriptor() ([]byte, []int)
Deprecated: Use RequestArgs.ProtoReflect.Descriptor instead.
func (*RequestArgs) GetPluginId ¶
func (x *RequestArgs) GetPluginId() uint32
func (*RequestArgs) GetRequest ¶
func (x *RequestArgs) GetRequest() string
func (*RequestArgs) GetRequestId ¶ added in v1.0.3
func (x *RequestArgs) GetRequestId() string
func (*RequestArgs) ProtoMessage ¶
func (*RequestArgs) ProtoMessage()
func (*RequestArgs) ProtoReflect ¶
func (x *RequestArgs) ProtoReflect() protoreflect.Message
func (*RequestArgs) Reset ¶
func (x *RequestArgs) Reset()
func (*RequestArgs) String ¶
func (x *RequestArgs) String() string
type ResponseResult ¶
type ResponseResult struct { Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
func (*ResponseResult) Descriptor
deprecated
func (*ResponseResult) Descriptor() ([]byte, []int)
Deprecated: Use ResponseResult.ProtoReflect.Descriptor instead.
func (*ResponseResult) GetData ¶
func (x *ResponseResult) GetData() string
func (*ResponseResult) GetRequestId ¶ added in v1.0.3
func (x *ResponseResult) GetRequestId() string
func (*ResponseResult) ProtoMessage ¶
func (*ResponseResult) ProtoMessage()
func (*ResponseResult) ProtoReflect ¶
func (x *ResponseResult) ProtoReflect() protoreflect.Message
func (*ResponseResult) Reset ¶
func (x *ResponseResult) Reset()
func (*ResponseResult) String ¶
func (x *ResponseResult) String() string
type UnimplementedDriverServer ¶
type UnimplementedDriverServer struct{}
UnimplementedDriverServer must 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 (UnimplementedDriverServer) Get ¶
func (UnimplementedDriverServer) Get(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) GetDriverInfo ¶
func (UnimplementedDriverServer) GetDriverInfo(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) Restart ¶
func (UnimplementedDriverServer) Restart(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) Set ¶
func (UnimplementedDriverServer) Set(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) SetConfig ¶
func (UnimplementedDriverServer) SetConfig(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) Setup ¶
func (UnimplementedDriverServer) Setup(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) Start ¶
func (UnimplementedDriverServer) Start(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedDriverServer) Stop ¶
func (UnimplementedDriverServer) Stop(context.Context, *RequestArgs) (*ResponseResult, error)
type UnimplementedReportServer ¶
type UnimplementedReportServer struct{}
UnimplementedReportServer must 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 (UnimplementedReportServer) Post ¶
func (UnimplementedReportServer) Post(context.Context, *RequestArgs) (*ResponseResult, error)
func (UnimplementedReportServer) State ¶
func (UnimplementedReportServer) State(context.Context, *RequestArgs) (*ResponseResult, error)
type UnsafeDriverServer ¶
type UnsafeDriverServer interface {
// contains filtered or unexported methods
}
UnsafeDriverServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DriverServer will result in compilation errors.
type UnsafeReportServer ¶
type UnsafeReportServer interface {
// contains filtered or unexported methods
}
UnsafeReportServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReportServer will result in compilation errors.