qbw1diagrpcgen

package
v0.0.14 Latest Latest
Warning

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

Go to latest
Published: Jan 27, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_diagnosis_idl_proto protoreflect.FileDescriptor
View Source
var Qabalwrap1DiagnosisGRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "qabalwrap1diag.Qabalwrap1DiagnosisGRPC",
	HandlerType: (*Qabalwrap1DiagnosisGRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Qabalwrap1DiagnosisGRPC_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReadTrace",
			Handler:       _Qabalwrap1DiagnosisGRPC_ReadTrace_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "diagnosis-idl.proto",
}

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

Functions

func RegisterQabalwrap1DiagnosisGRPCServer

func RegisterQabalwrap1DiagnosisGRPCServer(s grpc.ServiceRegistrar, srv Qabalwrap1DiagnosisGRPCServer)

Types

type PingReply

type PingReply struct {
	Timestamp    int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ProcessIdent int32 `protobuf:"varint,2,opt,name=process_ident,json=processIdent,proto3" json:"process_ident,omitempty"`
	// contains filtered or unexported fields
}

func (*PingReply) Descriptor deprecated

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

Deprecated: Use PingReply.ProtoReflect.Descriptor instead.

func (*PingReply) GetProcessIdent

func (x *PingReply) GetProcessIdent() int32

func (*PingReply) GetTimestamp

func (x *PingReply) GetTimestamp() int64

func (*PingReply) ProtoMessage

func (*PingReply) ProtoMessage()

func (*PingReply) ProtoReflect

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

func (*PingReply) Reset

func (x *PingReply) Reset()

func (*PingReply) String

func (x *PingReply) String() string

type PingRequest

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

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type Qabalwrap1DiagnosisGRPCClient

type Qabalwrap1DiagnosisGRPCClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error)
	ReadTrace(ctx context.Context, in *ReadTraceRequest, opts ...grpc.CallOption) (Qabalwrap1DiagnosisGRPC_ReadTraceClient, error)
}

Qabalwrap1DiagnosisGRPCClient is the client API for Qabalwrap1DiagnosisGRPC 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.

type Qabalwrap1DiagnosisGRPCServer

type Qabalwrap1DiagnosisGRPCServer interface {
	Ping(context.Context, *PingRequest) (*PingReply, error)
	ReadTrace(*ReadTraceRequest, Qabalwrap1DiagnosisGRPC_ReadTraceServer) error
	// contains filtered or unexported methods
}

Qabalwrap1DiagnosisGRPCServer is the server API for Qabalwrap1DiagnosisGRPC service. All implementations must embed UnimplementedQabalwrap1DiagnosisGRPCServer for forward compatibility

type Qabalwrap1DiagnosisGRPC_ReadTraceClient

type Qabalwrap1DiagnosisGRPC_ReadTraceClient interface {
	Recv() (*TraceRecord, error)
	grpc.ClientStream
}

type Qabalwrap1DiagnosisGRPC_ReadTraceServer

type Qabalwrap1DiagnosisGRPC_ReadTraceServer interface {
	Send(*TraceRecord) error
	grpc.ServerStream
}

type ReadTraceRequest

type ReadTraceRequest struct {
	ClientInstanceIdent string `protobuf:"bytes,1,opt,name=client_instance_ident,json=clientInstanceIdent,proto3" json:"client_instance_ident,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadTraceRequest) Descriptor deprecated

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

Deprecated: Use ReadTraceRequest.ProtoReflect.Descriptor instead.

func (*ReadTraceRequest) GetClientInstanceIdent

func (x *ReadTraceRequest) GetClientInstanceIdent() string

func (*ReadTraceRequest) ProtoMessage

func (*ReadTraceRequest) ProtoMessage()

func (*ReadTraceRequest) ProtoReflect

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

func (*ReadTraceRequest) Reset

func (x *ReadTraceRequest) Reset()

func (*ReadTraceRequest) String

func (x *ReadTraceRequest) String() string

type SpanIdent

type SpanIdent struct {
	TraceIdent int32 `protobuf:"varint,1,opt,name=trace_ident,json=traceIdent,proto3" json:"trace_ident,omitempty"`
	SpanIdent  int32 `protobuf:"varint,2,opt,name=span_ident,json=spanIdent,proto3" json:"span_ident,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanIdent) Descriptor deprecated

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

Deprecated: Use SpanIdent.ProtoReflect.Descriptor instead.

func (*SpanIdent) GetSpanIdent

func (x *SpanIdent) GetSpanIdent() int32

func (*SpanIdent) GetTraceIdent

func (x *SpanIdent) GetTraceIdent() int32

func (*SpanIdent) ProtoMessage

func (*SpanIdent) ProtoMessage()

func (*SpanIdent) ProtoReflect

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

func (*SpanIdent) Reset

func (x *SpanIdent) Reset()

func (*SpanIdent) String

func (x *SpanIdent) String() string

type TraceRecord

type TraceRecord struct {
	TraceIdent      int32        `protobuf:"varint,1,opt,name=trace_ident,json=traceIdent,proto3" json:"trace_ident,omitempty"`
	SpanIdent       int32        `protobuf:"varint,2,opt,name=span_ident,json=spanIdent,proto3" json:"span_ident,omitempty"`
	ParentSpanIdent int32        `protobuf:"varint,3,opt,name=parent_span_ident,json=parentSpanIdent,proto3" json:"parent_span_ident,omitempty"`
	TraceType       int32        `protobuf:"varint,4,opt,name=trace_type,json=traceType,proto3" json:"trace_type,omitempty"`
	EmitAt          int64        `protobuf:"varint,5,opt,name=emit_at,json=emitAt,proto3" json:"emit_at,omitempty"`
	MessageText     string       `protobuf:"bytes,6,opt,name=message_text,json=messageText,proto3" json:"message_text,omitempty"`
	LinkedSpans     []*SpanIdent `protobuf:"bytes,7,rep,name=linked_spans,json=linkedSpans,proto3" json:"linked_spans,omitempty"`
	ServiceName     string       `protobuf:"bytes,8,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	OperationName   string       `protobuf:"bytes,9,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	IsSuccess       bool         `protobuf:"varint,10,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceRecord) Descriptor deprecated

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

Deprecated: Use TraceRecord.ProtoReflect.Descriptor instead.

func (*TraceRecord) GetEmitAt

func (x *TraceRecord) GetEmitAt() int64

func (*TraceRecord) GetIsSuccess added in v0.0.14

func (x *TraceRecord) GetIsSuccess() bool

func (*TraceRecord) GetLinkedSpans

func (x *TraceRecord) GetLinkedSpans() []*SpanIdent

func (*TraceRecord) GetMessageText

func (x *TraceRecord) GetMessageText() string

func (*TraceRecord) GetOperationName added in v0.0.14

func (x *TraceRecord) GetOperationName() string

func (*TraceRecord) GetParentSpanIdent

func (x *TraceRecord) GetParentSpanIdent() int32

func (*TraceRecord) GetServiceName added in v0.0.14

func (x *TraceRecord) GetServiceName() string

func (*TraceRecord) GetSpanIdent

func (x *TraceRecord) GetSpanIdent() int32

func (*TraceRecord) GetTraceIdent

func (x *TraceRecord) GetTraceIdent() int32

func (*TraceRecord) GetTraceType

func (x *TraceRecord) GetTraceType() int32

func (*TraceRecord) ProtoMessage

func (*TraceRecord) ProtoMessage()

func (*TraceRecord) ProtoReflect

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

func (*TraceRecord) Reset

func (x *TraceRecord) Reset()

func (*TraceRecord) String

func (x *TraceRecord) String() string

type UnimplementedQabalwrap1DiagnosisGRPCServer

type UnimplementedQabalwrap1DiagnosisGRPCServer struct {
}

UnimplementedQabalwrap1DiagnosisGRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedQabalwrap1DiagnosisGRPCServer) Ping

func (UnimplementedQabalwrap1DiagnosisGRPCServer) ReadTrace

type UnsafeQabalwrap1DiagnosisGRPCServer

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

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

Jump to

Keyboard shortcuts

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