xrayservice

package
v0.0.0-...-8f6ad63 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 13, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
var File_proto_xray_service_proto protoreflect.FileDescriptor
View Source
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) FetchXrayVersion

func (UnimplementedXrayServiceServer) Restart

func (UnimplementedXrayServiceServer) Start

func (UnimplementedXrayServiceServer) Stop

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL