log_streaming

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2024 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LogStreamingService_StartLogStreaming_FullMethodName        = "/mavsdk.rpc.log_streaming.LogStreamingService/StartLogStreaming"
	LogStreamingService_StopLogStreaming_FullMethodName         = "/mavsdk.rpc.log_streaming.LogStreamingService/StopLogStreaming"
	LogStreamingService_SubscribeLogStreamingRaw_FullMethodName = "/mavsdk.rpc.log_streaming.LogStreamingService/SubscribeLogStreamingRaw"
)

Variables

View Source 
var (
	LogStreamingResult_Result_name = map[int32]string{
		0: "RESULT_SUCCESS",
		1: "RESULT_NO_SYSTEM",
		2: "RESULT_CONNECTION_ERROR",
		3: "RESULT_BUSY",
		4: "RESULT_COMMAND_DENIED",
		5: "RESULT_TIMEOUT",
		6: "RESULT_UNSUPPORTED",
		7: "RESULT_UNKNOWN",
	}
	LogStreamingResult_Result_value = map[string]int32{
		"RESULT_SUCCESS":          0,
		"RESULT_NO_SYSTEM":        1,
		"RESULT_CONNECTION_ERROR": 2,
		"RESULT_BUSY":             3,
		"RESULT_COMMAND_DENIED":   4,
		"RESULT_TIMEOUT":          5,
		"RESULT_UNSUPPORTED":      6,
		"RESULT_UNKNOWN":          7,
	}
)

Enum value maps for LogStreamingResult_Result.

View Source 
var File_log_streaming_proto protoreflect.FileDescriptor
View Source 
var LogStreamingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mavsdk.rpc.log_streaming.LogStreamingService",
	HandlerType: (*LogStreamingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartLogStreaming",
			Handler:    _LogStreamingService_StartLogStreaming_Handler,
		},
		{
			MethodName: "StopLogStreaming",
			Handler:    _LogStreamingService_StopLogStreaming_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeLogStreamingRaw",
			Handler:       _LogStreamingService_SubscribeLogStreamingRaw_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "log_streaming.proto",
}

LogStreamingService_ServiceDesc is the grpc.ServiceDesc for LogStreamingService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLogStreamingServiceServer 

func RegisterLogStreamingServiceServer(s grpc.ServiceRegistrar, srv LogStreamingServiceServer)

Types

type LogStreamingRaw 

type LogStreamingRaw struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Ulog file stream data encoded as base64
	// contains filtered or unexported fields
}

Raw logging data type

func (*LogStreamingRaw) Descriptor deprecated 

func (*LogStreamingRaw) Descriptor() ([]byte, []int)

Deprecated: Use LogStreamingRaw.ProtoReflect.Descriptor instead.

func (*LogStreamingRaw) GetData 

func (x *LogStreamingRaw) GetData() string

func (*LogStreamingRaw) ProtoMessage 

func (*LogStreamingRaw) ProtoMessage()

func (*LogStreamingRaw) ProtoReflect 

func (x *LogStreamingRaw) ProtoReflect() protoreflect.Message

func (*LogStreamingRaw) Reset 

func (x *LogStreamingRaw) Reset()

func (*LogStreamingRaw) String 

func (x *LogStreamingRaw) String() string

type LogStreamingRawResponse 

type LogStreamingRawResponse struct {
	LoggingRaw *LogStreamingRaw `protobuf:"bytes,1,opt,name=logging_raw,json=loggingRaw,proto3" json:"logging_raw,omitempty"` // A message containing logged data
	// contains filtered or unexported fields
}

func (*LogStreamingRawResponse) Descriptor deprecated 

func (*LogStreamingRawResponse) Descriptor() ([]byte, []int)

Deprecated: Use LogStreamingRawResponse.ProtoReflect.Descriptor instead.

func (*LogStreamingRawResponse) GetLoggingRaw 

func (x *LogStreamingRawResponse) GetLoggingRaw() *LogStreamingRaw

func (*LogStreamingRawResponse) ProtoMessage 

func (*LogStreamingRawResponse) ProtoMessage()

func (*LogStreamingRawResponse) ProtoReflect 

func (x *LogStreamingRawResponse) ProtoReflect() protoreflect.Message

func (*LogStreamingRawResponse) Reset 

func (x *LogStreamingRawResponse) Reset()

func (*LogStreamingRawResponse) String 

func (x *LogStreamingRawResponse) String() string

type LogStreamingResult 

type LogStreamingResult struct {
	Result    LogStreamingResult_Result `protobuf:"varint,1,opt,name=result,proto3,enum=mavsdk.rpc.log_streaming.LogStreamingResult_Result" json:"result,omitempty"` // Result enum value
	ResultStr string                    `protobuf:"bytes,2,opt,name=result_str,json=resultStr,proto3" json:"result_str,omitempty"`                                   // Human-readable English string describing the result
	// contains filtered or unexported fields
}

Result type.

func (*LogStreamingResult) Descriptor deprecated 

func (*LogStreamingResult) Descriptor() ([]byte, []int)

Deprecated: Use LogStreamingResult.ProtoReflect.Descriptor instead.

func (*LogStreamingResult) GetResult 

func (x *LogStreamingResult) GetResult() LogStreamingResult_Result

func (*LogStreamingResult) GetResultStr 

func (x *LogStreamingResult) GetResultStr() string

func (*LogStreamingResult) ProtoMessage 

func (*LogStreamingResult) ProtoMessage()

func (*LogStreamingResult) ProtoReflect 

func (x *LogStreamingResult) ProtoReflect() protoreflect.Message

func (*LogStreamingResult) Reset 

func (x *LogStreamingResult) Reset()

func (*LogStreamingResult) String 

func (x *LogStreamingResult) String() string

type LogStreamingResult_Result 

type LogStreamingResult_Result int32

Possible results returned for logging requests 

const (
	LogStreamingResult_RESULT_SUCCESS          LogStreamingResult_Result = 0 // Request succeeded
	LogStreamingResult_RESULT_NO_SYSTEM        LogStreamingResult_Result = 1 // No system connected
	LogStreamingResult_RESULT_CONNECTION_ERROR LogStreamingResult_Result = 2 // Connection error
	LogStreamingResult_RESULT_BUSY             LogStreamingResult_Result = 3 // System busy
	LogStreamingResult_RESULT_COMMAND_DENIED   LogStreamingResult_Result = 4 // Command denied
	LogStreamingResult_RESULT_TIMEOUT          LogStreamingResult_Result = 5 // Timeout
	LogStreamingResult_RESULT_UNSUPPORTED      LogStreamingResult_Result = 6 // Unsupported
	LogStreamingResult_RESULT_UNKNOWN          LogStreamingResult_Result = 7 // Unknown error
)

func (LogStreamingResult_Result) Descriptor 

func (LogStreamingResult_Result) Descriptor() protoreflect.EnumDescriptor

func (LogStreamingResult_Result) Enum 

func (x LogStreamingResult_Result) Enum() *LogStreamingResult_Result

func (LogStreamingResult_Result) EnumDescriptor deprecated 

func (LogStreamingResult_Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogStreamingResult_Result.Descriptor instead.

func (LogStreamingResult_Result) Number 

func (x LogStreamingResult_Result) Number() protoreflect.EnumNumber

func (LogStreamingResult_Result) String 

func (x LogStreamingResult_Result) String() string

func (LogStreamingResult_Result) Type 

func (LogStreamingResult_Result) Type() protoreflect.EnumType

type LogStreamingServiceClient 

type LogStreamingServiceClient interface {
	// Start streaming logging data.
	StartLogStreaming(ctx context.Context, in *StartLogStreamingRequest, opts ...grpc.CallOption) (*StartLogStreamingResponse, error)
	// Stop streaming logging data.
	StopLogStreaming(ctx context.Context, in *StopLogStreamingRequest, opts ...grpc.CallOption) (*StopLogStreamingResponse, error)
	// Subscribe to logging messages
	SubscribeLogStreamingRaw(ctx context.Context, in *SubscribeLogStreamingRawRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogStreamingRawResponse], error)
}

LogStreamingServiceClient is the client API for LogStreamingService 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.

Provide log streaming data.

func NewLogStreamingServiceClient 

func NewLogStreamingServiceClient(cc grpc.ClientConnInterface) LogStreamingServiceClient

type LogStreamingServiceServer 

type LogStreamingServiceServer interface {
	// Start streaming logging data.
	StartLogStreaming(context.Context, *StartLogStreamingRequest) (*StartLogStreamingResponse, error)
	// Stop streaming logging data.
	StopLogStreaming(context.Context, *StopLogStreamingRequest) (*StopLogStreamingResponse, error)
	// Subscribe to logging messages
	SubscribeLogStreamingRaw(*SubscribeLogStreamingRawRequest, grpc.ServerStreamingServer[LogStreamingRawResponse]) error
	// contains filtered or unexported methods
}

LogStreamingServiceServer is the server API for LogStreamingService service. All implementations must embed UnimplementedLogStreamingServiceServer for forward compatibility.

Provide log streaming data.

type LogStreamingService_SubscribeLogStreamingRawClient 

type LogStreamingService_SubscribeLogStreamingRawClient = grpc.ServerStreamingClient[LogStreamingRawResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type LogStreamingService_SubscribeLogStreamingRawServer 

type LogStreamingService_SubscribeLogStreamingRawServer = grpc.ServerStreamingServer[LogStreamingRawResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ServiceImpl 

type ServiceImpl struct {
	Client LogStreamingServiceClient
}

func (*ServiceImpl) LogStreamingRaw 

func (a *ServiceImpl) LogStreamingRaw(ctx context.Context) (<-chan *LogStreamingRaw, error)

func (*ServiceImpl) StartLogStreaming 

func (s *ServiceImpl) StartLogStreaming(ctx context.Context) (*StartLogStreamingResponse, error)

func (*ServiceImpl) StopLogStreaming 

func (s *ServiceImpl) StopLogStreaming(ctx context.Context) (*StopLogStreamingResponse, error)

type StartLogStreamingRequest 

type StartLogStreamingRequest struct {
	// contains filtered or unexported fields
}

func (*StartLogStreamingRequest) Descriptor deprecated 

func (*StartLogStreamingRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartLogStreamingRequest.ProtoReflect.Descriptor instead.

func (*StartLogStreamingRequest) ProtoMessage 

func (*StartLogStreamingRequest) ProtoMessage()

func (*StartLogStreamingRequest) ProtoReflect 

func (x *StartLogStreamingRequest) ProtoReflect() protoreflect.Message

func (*StartLogStreamingRequest) Reset 

func (x *StartLogStreamingRequest) Reset()

func (*StartLogStreamingRequest) String 

func (x *StartLogStreamingRequest) String() string

type StartLogStreamingResponse 

type StartLogStreamingResponse struct {
	LogStreamingResult *LogStreamingResult `protobuf:"bytes,1,opt,name=log_streaming_result,json=logStreamingResult,proto3" json:"log_streaming_result,omitempty"`
	// contains filtered or unexported fields
}

func (*StartLogStreamingResponse) Descriptor deprecated 

func (*StartLogStreamingResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartLogStreamingResponse.ProtoReflect.Descriptor instead.

func (*StartLogStreamingResponse) GetLogStreamingResult 

func (x *StartLogStreamingResponse) GetLogStreamingResult() *LogStreamingResult

func (*StartLogStreamingResponse) ProtoMessage 

func (*StartLogStreamingResponse) ProtoMessage()

func (*StartLogStreamingResponse) ProtoReflect 

func (x *StartLogStreamingResponse) ProtoReflect() protoreflect.Message

func (*StartLogStreamingResponse) Reset 

func (x *StartLogStreamingResponse) Reset()

func (*StartLogStreamingResponse) String 

func (x *StartLogStreamingResponse) String() string

type StopLogStreamingRequest 

type StopLogStreamingRequest struct {
	// contains filtered or unexported fields
}

func (*StopLogStreamingRequest) Descriptor deprecated 

func (*StopLogStreamingRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopLogStreamingRequest.ProtoReflect.Descriptor instead.

func (*StopLogStreamingRequest) ProtoMessage 

func (*StopLogStreamingRequest) ProtoMessage()

func (*StopLogStreamingRequest) ProtoReflect 

func (x *StopLogStreamingRequest) ProtoReflect() protoreflect.Message

func (*StopLogStreamingRequest) Reset 

func (x *StopLogStreamingRequest) Reset()

func (*StopLogStreamingRequest) String 

func (x *StopLogStreamingRequest) String() string

type StopLogStreamingResponse 

type StopLogStreamingResponse struct {
	LogStreamingResult *LogStreamingResult `protobuf:"bytes,1,opt,name=log_streaming_result,json=logStreamingResult,proto3" json:"log_streaming_result,omitempty"`
	// contains filtered or unexported fields
}

func (*StopLogStreamingResponse) Descriptor deprecated 

func (*StopLogStreamingResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopLogStreamingResponse.ProtoReflect.Descriptor instead.

func (*StopLogStreamingResponse) GetLogStreamingResult 

func (x *StopLogStreamingResponse) GetLogStreamingResult() *LogStreamingResult

func (*StopLogStreamingResponse) ProtoMessage 

func (*StopLogStreamingResponse) ProtoMessage()

func (*StopLogStreamingResponse) ProtoReflect 

func (x *StopLogStreamingResponse) ProtoReflect() protoreflect.Message

func (*StopLogStreamingResponse) Reset 

func (x *StopLogStreamingResponse) Reset()

func (*StopLogStreamingResponse) String 

func (x *StopLogStreamingResponse) String() string

type SubscribeLogStreamingRawRequest 

type SubscribeLogStreamingRawRequest struct {
	// contains filtered or unexported fields
}

func (*SubscribeLogStreamingRawRequest) Descriptor deprecated 

func (*SubscribeLogStreamingRawRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubscribeLogStreamingRawRequest.ProtoReflect.Descriptor instead.

func (*SubscribeLogStreamingRawRequest) ProtoMessage 

func (*SubscribeLogStreamingRawRequest) ProtoMessage()

func (*SubscribeLogStreamingRawRequest) ProtoReflect 

func (x *SubscribeLogStreamingRawRequest) ProtoReflect() protoreflect.Message

func (*SubscribeLogStreamingRawRequest) Reset 

func (x *SubscribeLogStreamingRawRequest) Reset()

func (*SubscribeLogStreamingRawRequest) String 

func (x *SubscribeLogStreamingRawRequest) String() string

type UnimplementedLogStreamingServiceServer 

type UnimplementedLogStreamingServiceServer struct{}

UnimplementedLogStreamingServiceServer 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 (UnimplementedLogStreamingServiceServer) StartLogStreaming 

func (UnimplementedLogStreamingServiceServer) StartLogStreaming(context.Context, *StartLogStreamingRequest) (*StartLogStreamingResponse, error)

func (UnimplementedLogStreamingServiceServer) StopLogStreaming 

func (UnimplementedLogStreamingServiceServer) StopLogStreaming(context.Context, *StopLogStreamingRequest) (*StopLogStreamingResponse, error)

func (UnimplementedLogStreamingServiceServer) SubscribeLogStreamingRaw 

func (UnimplementedLogStreamingServiceServer) SubscribeLogStreamingRaw(*SubscribeLogStreamingRawRequest, grpc.ServerStreamingServer[LogStreamingRawResponse]) error

type UnsafeLogStreamingServiceServer 

type UnsafeLogStreamingServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLogStreamingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogStreamingServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.