Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterXrayServiceServer(s grpc.ServiceRegistrar, srv XrayServiceServer)
- type FetchLogsRequest
- type FetchXrayVersionRequest
- type FetchXrayVersionResponse
- func (*FetchXrayVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchXrayVersionResponse) GetVersion() string
- func (*FetchXrayVersionResponse) ProtoMessage()
- func (x *FetchXrayVersionResponse) ProtoReflect() protoreflect.Message
- func (x *FetchXrayVersionResponse) Reset()
- func (x *FetchXrayVersionResponse) String() string
- type LogMessage
- type RestartRequest
- type RestartResponse
- type StartRequest
- type StartResponse
- type StopRequest
- type StopResponse
- type UnimplementedXrayServiceServer
- func (UnimplementedXrayServiceServer) FetchLogs(*FetchLogsRequest, XrayService_FetchLogsServer) error
- func (UnimplementedXrayServiceServer) FetchXrayVersion(context.Context, *FetchXrayVersionRequest) (*FetchXrayVersionResponse, error)
- func (UnimplementedXrayServiceServer) Restart(context.Context, *RestartRequest) (*RestartResponse, error)
- func (UnimplementedXrayServiceServer) Start(context.Context, *StartRequest) (*StartResponse, error)
- func (UnimplementedXrayServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
- type UnsafeXrayServiceServer
- type XrayServiceClient
- type XrayServiceServer
- type XrayService_FetchLogsClient
- type XrayService_FetchLogsServer
Constants ¶
const ( XrayService_Start_FullMethodName = "/xrayservice.XrayService/Start" XrayService_Stop_FullMethodName = "/xrayservice.XrayService/Stop" XrayService_Restart_FullMethodName = "/xrayservice.XrayService/Restart" XrayService_FetchXrayVersion_FullMethodName = "/xrayservice.XrayService/FetchXrayVersion" XrayService_FetchLogs_FullMethodName = "/xrayservice.XrayService/FetchLogs" )
Variables ¶
var File_proto_xray_service_proto protoreflect.FileDescriptor
var XrayService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "xrayservice.XrayService", HandlerType: (*XrayServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _XrayService_Start_Handler, }, { MethodName: "Stop", Handler: _XrayService_Stop_Handler, }, { MethodName: "Restart", Handler: _XrayService_Restart_Handler, }, { MethodName: "FetchXrayVersion", Handler: _XrayService_FetchXrayVersion_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "FetchLogs", Handler: _XrayService_FetchLogs_Handler, ServerStreams: true, }, }, Metadata: "proto/xray_service.proto", }
XrayService_ServiceDesc is the grpc.ServiceDesc for XrayService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterXrayServiceServer ¶
func RegisterXrayServiceServer(s grpc.ServiceRegistrar, srv XrayServiceServer)
Types ¶
type FetchLogsRequest ¶
type FetchLogsRequest struct {
// contains filtered or unexported fields
}
func (*FetchLogsRequest) Descriptor
deprecated
func (*FetchLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchLogsRequest.ProtoReflect.Descriptor instead.
func (*FetchLogsRequest) ProtoMessage ¶
func (*FetchLogsRequest) ProtoMessage()
func (*FetchLogsRequest) ProtoReflect ¶
func (x *FetchLogsRequest) ProtoReflect() protoreflect.Message
func (*FetchLogsRequest) Reset ¶
func (x *FetchLogsRequest) Reset()
func (*FetchLogsRequest) String ¶
func (x *FetchLogsRequest) String() string
type FetchXrayVersionRequest ¶
type FetchXrayVersionRequest struct {
// contains filtered or unexported fields
}
func (*FetchXrayVersionRequest) Descriptor
deprecated
func (*FetchXrayVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchXrayVersionRequest.ProtoReflect.Descriptor instead.
func (*FetchXrayVersionRequest) ProtoMessage ¶
func (*FetchXrayVersionRequest) ProtoMessage()
func (*FetchXrayVersionRequest) ProtoReflect ¶
func (x *FetchXrayVersionRequest) ProtoReflect() protoreflect.Message
func (*FetchXrayVersionRequest) Reset ¶
func (x *FetchXrayVersionRequest) Reset()
func (*FetchXrayVersionRequest) String ¶
func (x *FetchXrayVersionRequest) String() string
type FetchXrayVersionResponse ¶
type FetchXrayVersionResponse struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*FetchXrayVersionResponse) Descriptor
deprecated
func (*FetchXrayVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchXrayVersionResponse.ProtoReflect.Descriptor instead.
func (*FetchXrayVersionResponse) GetVersion ¶
func (x *FetchXrayVersionResponse) GetVersion() string
func (*FetchXrayVersionResponse) ProtoMessage ¶
func (*FetchXrayVersionResponse) ProtoMessage()
func (*FetchXrayVersionResponse) ProtoReflect ¶
func (x *FetchXrayVersionResponse) ProtoReflect() protoreflect.Message
func (*FetchXrayVersionResponse) Reset ¶
func (x *FetchXrayVersionResponse) Reset()
func (*FetchXrayVersionResponse) String ¶
func (x *FetchXrayVersionResponse) String() string
type LogMessage ¶
type LogMessage struct {
Log string `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
// contains filtered or unexported fields
}
func (*LogMessage) Descriptor
deprecated
func (*LogMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.
func (*LogMessage) GetLog ¶
func (x *LogMessage) GetLog() string
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) ProtoReflect ¶
func (x *LogMessage) ProtoReflect() protoreflect.Message
func (*LogMessage) Reset ¶
func (x *LogMessage) Reset()
func (*LogMessage) String ¶
func (x *LogMessage) String() string
type RestartRequest ¶
type RestartRequest struct {
Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*RestartRequest) Descriptor
deprecated
func (*RestartRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartRequest.ProtoReflect.Descriptor instead.
func (*RestartRequest) GetConfig ¶
func (x *RestartRequest) GetConfig() string
func (*RestartRequest) ProtoMessage ¶
func (*RestartRequest) ProtoMessage()
func (*RestartRequest) ProtoReflect ¶
func (x *RestartRequest) ProtoReflect() protoreflect.Message
func (*RestartRequest) Reset ¶
func (x *RestartRequest) Reset()
func (*RestartRequest) String ¶
func (x *RestartRequest) String() string
type RestartResponse ¶
type RestartResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*RestartResponse) Descriptor
deprecated
func (*RestartResponse) Descriptor() ([]byte, []int)
Deprecated: Use RestartResponse.ProtoReflect.Descriptor instead.
func (*RestartResponse) GetMessage ¶
func (x *RestartResponse) GetMessage() string
func (*RestartResponse) ProtoMessage ¶
func (*RestartResponse) ProtoMessage()
func (*RestartResponse) ProtoReflect ¶
func (x *RestartResponse) ProtoReflect() protoreflect.Message
func (*RestartResponse) Reset ¶
func (x *RestartResponse) Reset()
func (*RestartResponse) String ¶
func (x *RestartResponse) String() string
type StartRequest ¶
type StartRequest struct {
Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
Request and Response messages
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetConfig ¶
func (x *StartRequest) GetConfig() string
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) ProtoReflect ¶
func (x *StartRequest) ProtoReflect() protoreflect.Message
func (*StartRequest) Reset ¶
func (x *StartRequest) Reset()
func (*StartRequest) String ¶
func (x *StartRequest) String() string
type StartResponse ¶
type StartResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) GetMessage ¶
func (x *StartResponse) GetMessage() string
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) ProtoReflect ¶
func (x *StartResponse) ProtoReflect() protoreflect.Message
func (*StartResponse) Reset ¶
func (x *StartResponse) Reset()
func (*StartResponse) String ¶
func (x *StartResponse) String() string
type StopRequest ¶
type StopRequest struct {
// contains filtered or unexported fields
}
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type StopResponse ¶
type StopResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) GetMessage ¶
func (x *StopResponse) GetMessage() string
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type UnimplementedXrayServiceServer ¶
type UnimplementedXrayServiceServer struct{}
UnimplementedXrayServiceServer must be embedded to have forward compatible implementations
func (UnimplementedXrayServiceServer) FetchLogs ¶
func (UnimplementedXrayServiceServer) FetchLogs(*FetchLogsRequest, XrayService_FetchLogsServer) error
func (UnimplementedXrayServiceServer) FetchXrayVersion ¶
func (UnimplementedXrayServiceServer) FetchXrayVersion(context.Context, *FetchXrayVersionRequest) (*FetchXrayVersionResponse, error)
func (UnimplementedXrayServiceServer) Restart ¶
func (UnimplementedXrayServiceServer) Restart(context.Context, *RestartRequest) (*RestartResponse, error)
func (UnimplementedXrayServiceServer) Start ¶
func (UnimplementedXrayServiceServer) Start(context.Context, *StartRequest) (*StartResponse, error)
func (UnimplementedXrayServiceServer) Stop ¶
func (UnimplementedXrayServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
type UnsafeXrayServiceServer ¶
type UnsafeXrayServiceServer interface {
// contains filtered or unexported methods
}
UnsafeXrayServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to XrayServiceServer will result in compilation errors.
type XrayServiceClient ¶
type XrayServiceClient interface {
Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
Restart(ctx context.Context, in *RestartRequest, opts ...grpc.CallOption) (*RestartResponse, error)
FetchXrayVersion(ctx context.Context, in *FetchXrayVersionRequest, opts ...grpc.CallOption) (*FetchXrayVersionResponse, error)
FetchLogs(ctx context.Context, in *FetchLogsRequest, opts ...grpc.CallOption) (XrayService_FetchLogsClient, error)
}
XrayServiceClient is the client API for XrayService 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.
Service definition for XrayService
func NewXrayServiceClient ¶
func NewXrayServiceClient(cc grpc.ClientConnInterface) XrayServiceClient
type XrayServiceServer ¶
type XrayServiceServer interface {
Start(context.Context, *StartRequest) (*StartResponse, error)
Stop(context.Context, *StopRequest) (*StopResponse, error)
Restart(context.Context, *RestartRequest) (*RestartResponse, error)
FetchXrayVersion(context.Context, *FetchXrayVersionRequest) (*FetchXrayVersionResponse, error)
FetchLogs(*FetchLogsRequest, XrayService_FetchLogsServer) error
// contains filtered or unexported methods
}
XrayServiceServer is the server API for XrayService service. All implementations must embed UnimplementedXrayServiceServer for forward compatibility
type XrayService_FetchLogsClient ¶
type XrayService_FetchLogsClient interface {
Recv() (*LogMessage, error)
grpc.ClientStream
}
type XrayService_FetchLogsServer ¶
type XrayService_FetchLogsServer interface {
Send(*LogMessage) error
grpc.ServerStream
}