proto

package
v0.0.0-...-3736fb9 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SamplerType_name = map[int32]string{
		0: "STUnknown",
		1: "STNever",
		2: "STAlways",
		3: "STFloat",
	}
	SamplerType_value = map[string]int32{
		"STUnknown": 0,
		"STNever":   1,
		"STAlways":  2,
		"STFloat":   3,
	}
)

Enum value maps for SamplerType.

View Source 
var File_ops_proto protoreflect.FileDescriptor
View Source 
var Ops_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ops.Ops",
	HandlerType: (*OpsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTraces",
			Handler:    _Ops_ListTraces_Handler,
		},
		{
			MethodName: "ShowTrace",
			Handler:    _Ops_ShowTrace_Handler,
		},
		{
			MethodName: "ShowLogs",
			Handler:    _Ops_ShowLogs_Handler,
		},
		{
			MethodName: "ChangeSampling",
			Handler:    _Ops_ChangeSampling_Handler,
		},
		{
			MethodName: "DeployedVersion",
			Handler:    _Ops_DeployedVersion_Handler,
		},
		{
			MethodName: "Alerts",
			Handler:    _Ops_Alerts_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ops.proto",
}

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

Functions

func RegisterOpsServer 

func RegisterOpsServer(s grpc.ServiceRegistrar, srv OpsServer)

Types

type Alert 

type Alert struct {

	// This is the current state of the alert.
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// This is the current value of the alert.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// This is how long it has been active in unix nanoseconds.
	ActiveAt int64 `protobuf:"varint,3,opt,name=active_at,json=activeAt,proto3" json:"active_at,omitempty"`
	// contains filtered or unexported fields
}

Alert describes a Prometheus alert.

func (*Alert) Descriptor deprecated 

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

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetActiveAt 

func (x *Alert) GetActiveAt() int64

func (*Alert) GetState 

func (x *Alert) GetState() string

func (*Alert) GetValue 

func (x *Alert) GetValue() string

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect 

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

func (*Alert) Reset 

func (x *Alert) Reset()

func (*Alert) String 

func (x *Alert) String() string

type AlertsReq 

type AlertsReq struct {

	// Labels that the alert must match. Must have all labels. None indicates all alerts.
	Labels []string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// It must be an alert that is active since this time in unix nanoseconds. 0 indicates any alive alert.
	ActiveAt int64 `protobuf:"varint,2,opt,name=active_at,json=activeAt,proto3" json:"active_at,omitempty"`
	// It must have one of these states. None indicates all states.
	States []string `protobuf:"bytes,3,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

This requests an set of active alerts in the system.

func (*AlertsReq) Descriptor deprecated 

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

Deprecated: Use AlertsReq.ProtoReflect.Descriptor instead.

func (*AlertsReq) GetActiveAt 

func (x *AlertsReq) GetActiveAt() int64

func (*AlertsReq) GetLabels 

func (x *AlertsReq) GetLabels() []string

func (*AlertsReq) GetStates 

func (x *AlertsReq) GetStates() []string

func (*AlertsReq) ProtoMessage 

func (*AlertsReq) ProtoMessage()

func (*AlertsReq) ProtoReflect 

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

func (*AlertsReq) Reset 

func (x *AlertsReq) Reset()

func (*AlertsReq) String 

func (x *AlertsReq) String() string

type AlertsResp 

type AlertsResp struct {

	// A list of alerts that matched the filter.
	Alerts []*Alert `protobuf:"bytes,1,rep,name=alerts,proto3" json:"alerts,omitempty"`
	// contains filtered or unexported fields
}

The response to Alerts().

func (*AlertsResp) Descriptor deprecated 

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

Deprecated: Use AlertsResp.ProtoReflect.Descriptor instead.

func (*AlertsResp) GetAlerts 

func (x *AlertsResp) GetAlerts() []*Alert

func (*AlertsResp) ProtoMessage 

func (*AlertsResp) ProtoMessage()

func (*AlertsResp) ProtoReflect 

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

func (*AlertsResp) Reset 

func (x *AlertsResp) Reset()

func (*AlertsResp) String 

func (x *AlertsResp) String() string

type ChangeSamplingReq 

type ChangeSamplingReq struct {

	// The type of sampling to change to.
	Type SamplerType `protobuf:"varint,1,opt,name=type,proto3,enum=ops.SamplerType" json:"type,omitempty"`
	// This is the sampling rate if type == STFloat. Values must be
	// > 0 and <= 1.0 .
	FloatValue float64 `protobuf:"fixed64,2,opt,name=float_value,json=floatValue,proto3" json:"float_value,omitempty"`
	// contains filtered or unexported fields
}

Used to request we change the OTEL sampling.

func (*ChangeSamplingReq) Descriptor deprecated 

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

Deprecated: Use ChangeSamplingReq.ProtoReflect.Descriptor instead.

func (*ChangeSamplingReq) GetFloatValue 

func (x *ChangeSamplingReq) GetFloatValue() float64

func (*ChangeSamplingReq) GetType 

func (x *ChangeSamplingReq) GetType() SamplerType

func (*ChangeSamplingReq) ProtoMessage 

func (*ChangeSamplingReq) ProtoMessage()

func (*ChangeSamplingReq) ProtoReflect 

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

func (*ChangeSamplingReq) Reset 

func (x *ChangeSamplingReq) Reset()

func (*ChangeSamplingReq) String 

func (x *ChangeSamplingReq) String() string

type ChangeSamplingResp 

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

The response to a sampling change.

func (*ChangeSamplingResp) Descriptor deprecated 

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

Deprecated: Use ChangeSamplingResp.ProtoReflect.Descriptor instead.

func (*ChangeSamplingResp) ProtoMessage 

func (*ChangeSamplingResp) ProtoMessage()

func (*ChangeSamplingResp) ProtoReflect 

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

func (*ChangeSamplingResp) Reset 

func (x *ChangeSamplingResp) Reset()

func (*ChangeSamplingResp) String 

func (x *ChangeSamplingResp) String() string

type DeployedVersionReq 

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

The request to get the deployed version of the service.

func (*DeployedVersionReq) Descriptor deprecated 

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

Deprecated: Use DeployedVersionReq.ProtoReflect.Descriptor instead.

func (*DeployedVersionReq) ProtoMessage 

func (*DeployedVersionReq) ProtoMessage()

func (*DeployedVersionReq) ProtoReflect 

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

func (*DeployedVersionReq) Reset 

func (x *DeployedVersionReq) Reset()

func (*DeployedVersionReq) String 

func (x *DeployedVersionReq) String() string

type DeployedVersionResp 

type DeployedVersionResp struct {

	// The version running according to prometheus metrics.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

The response to DeployedVersion().

func (*DeployedVersionResp) Descriptor deprecated 

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

Deprecated: Use DeployedVersionResp.ProtoReflect.Descriptor instead.

func (*DeployedVersionResp) GetVersion 

func (x *DeployedVersionResp) GetVersion() string

func (*DeployedVersionResp) ProtoMessage 

func (*DeployedVersionResp) ProtoMessage()

func (*DeployedVersionResp) ProtoReflect 

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

func (*DeployedVersionResp) Reset 

func (x *DeployedVersionResp) Reset()

func (*DeployedVersionResp) String 

func (x *DeployedVersionResp) String() string

type ListTracesReq 

type ListTracesReq struct {

	// The name of the service to find traces for.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Filter the traces for this operation.
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// Filter the traces for only traces with these all these tags.
	Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// Traces must start after the time in unix nanoseconds.
	Start int64 `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	// Traces must end before this time in unix nanoseconds.
	End int64 `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty"`
	// The minimum duration of a matched trace.
	DurationMin int64 `protobuf:"varint,6,opt,name=duration_min,json=durationMin,proto3" json:"duration_min,omitempty"`
	// The maximum duration of a matched trace.
	DurationMax int64 `protobuf:"varint,7,opt,name=duration_max,json=durationMax,proto3" json:"duration_max,omitempty"`
	// The number of traces to return.
	SearchDepth int32 `protobuf:"varint,8,opt,name=search_depth,json=searchDepth,proto3" json:"search_depth,omitempty"`
	// contains filtered or unexported fields
}

The request to get traces from Jaeger.

func (*ListTracesReq) Descriptor deprecated 

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

Deprecated: Use ListTracesReq.ProtoReflect.Descriptor instead.

func (*ListTracesReq) GetDurationMax 

func (x *ListTracesReq) GetDurationMax() int64

func (*ListTracesReq) GetDurationMin 

func (x *ListTracesReq) GetDurationMin() int64

func (*ListTracesReq) GetEnd 

func (x *ListTracesReq) GetEnd() int64

func (*ListTracesReq) GetOperation 

func (x *ListTracesReq) GetOperation() string

func (*ListTracesReq) GetSearchDepth 

func (x *ListTracesReq) GetSearchDepth() int32

func (*ListTracesReq) GetService 

func (x *ListTracesReq) GetService() string

func (*ListTracesReq) GetStart 

func (x *ListTracesReq) GetStart() int64

func (*ListTracesReq) GetTags 

func (x *ListTracesReq) GetTags() []string

func (*ListTracesReq) ProtoMessage 

func (*ListTracesReq) ProtoMessage()

func (*ListTracesReq) ProtoReflect 

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

func (*ListTracesReq) Reset 

func (x *ListTracesReq) Reset()

func (*ListTracesReq) String 

func (x *ListTracesReq) String() string

type ListTracesResp 

type ListTracesResp struct {

	// A list of traces that met the search criteria.
	Traces []*TraceItem `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

A response to ListTraces().

func (*ListTracesResp) Descriptor deprecated 

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

Deprecated: Use ListTracesResp.ProtoReflect.Descriptor instead.

func (*ListTracesResp) GetTraces 

func (x *ListTracesResp) GetTraces() []*TraceItem

func (*ListTracesResp) ProtoMessage 

func (*ListTracesResp) ProtoMessage()

func (*ListTracesResp) ProtoReflect 

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

func (*ListTracesResp) Reset 

func (x *ListTracesResp) Reset()

func (*ListTracesResp) String 

func (x *ListTracesResp) String() string

type OpsClient 

type OpsClient interface {
	// ListTraces that the Jaeger has for our application.
	ListTraces(ctx context.Context, in *ListTracesReq, opts ...grpc.CallOption) (*ListTracesResp, error)
	// ShowTrace returns the URL of a trace you ask for.
	ShowTrace(ctx context.Context, in *ShowTraceReq, opts ...grpc.CallOption) (*ShowTraceResp, error)
	// ShowLogs extracts the logs from a trace.
	ShowLogs(ctx context.Context, in *ShowLogsReq, opts ...grpc.CallOption) (*ShowLogsResp, error)
	// ChangeSampling changes the sampling the service is currently using for its traces.
	ChangeSampling(ctx context.Context, in *ChangeSamplingReq, opts ...grpc.CallOption) (*ChangeSamplingResp, error)
	// DeployedVersion returns the currently deployed version of the application.
	DeployedVersion(ctx context.Context, in *DeployedVersionReq, opts ...grpc.CallOption) (*DeployedVersionResp, error)
	// Alerts returns the currently firing alerts.
	Alerts(ctx context.Context, in *AlertsReq, opts ...grpc.CallOption) (*AlertsResp, error)
}

OpsClient is the client API for Ops 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 NewOpsClient 

func NewOpsClient(cc grpc.ClientConnInterface) OpsClient

type OpsServer 

type OpsServer interface {
	// ListTraces that the Jaeger has for our application.
	ListTraces(context.Context, *ListTracesReq) (*ListTracesResp, error)
	// ShowTrace returns the URL of a trace you ask for.
	ShowTrace(context.Context, *ShowTraceReq) (*ShowTraceResp, error)
	// ShowLogs extracts the logs from a trace.
	ShowLogs(context.Context, *ShowLogsReq) (*ShowLogsResp, error)
	// ChangeSampling changes the sampling the service is currently using for its traces.
	ChangeSampling(context.Context, *ChangeSamplingReq) (*ChangeSamplingResp, error)
	// DeployedVersion returns the currently deployed version of the application.
	DeployedVersion(context.Context, *DeployedVersionReq) (*DeployedVersionResp, error)
	// Alerts returns the currently firing alerts.
	Alerts(context.Context, *AlertsReq) (*AlertsResp, error)
	// contains filtered or unexported methods
}

OpsServer is the server API for Ops service. All implementations must embed UnimplementedOpsServer for forward compatibility

type SamplerType 

type SamplerType int32
const (
	SamplerType_STUnknown SamplerType = 0
	SamplerType_STNever   SamplerType = 1
	SamplerType_STAlways  SamplerType = 2
	SamplerType_STFloat   SamplerType = 3
)

func (SamplerType) Descriptor 

func (SamplerType) Descriptor() protoreflect.EnumDescriptor

func (SamplerType) Enum 

func (x SamplerType) Enum() *SamplerType

func (SamplerType) EnumDescriptor deprecated 

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

Deprecated: Use SamplerType.Descriptor instead.

func (SamplerType) Number 

func (x SamplerType) Number() protoreflect.EnumNumber

func (SamplerType) String 

func (x SamplerType) String() string

func (SamplerType) Type 

func (SamplerType) Type() protoreflect.EnumType

type ShowLogsReq 

type ShowLogsReq struct {

	// The hex ID of the trace.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowLogsReq) Descriptor deprecated 

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

Deprecated: Use ShowLogsReq.ProtoReflect.Descriptor instead.

func (*ShowLogsReq) GetId 

func (x *ShowLogsReq) GetId() string

func (*ShowLogsReq) ProtoMessage 

func (*ShowLogsReq) ProtoMessage()

func (*ShowLogsReq) ProtoReflect 

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

func (*ShowLogsReq) Reset 

func (x *ShowLogsReq) Reset()

func (*ShowLogsReq) String 

func (x *ShowLogsReq) String() string

type ShowLogsResp 

type ShowLogsResp struct {
	Id   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Logs []*model.Log `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowLogsResp) Descriptor deprecated 

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

Deprecated: Use ShowLogsResp.ProtoReflect.Descriptor instead.

func (*ShowLogsResp) GetId 

func (x *ShowLogsResp) GetId() string

func (*ShowLogsResp) GetLogs 

func (x *ShowLogsResp) GetLogs() []*model.Log

func (*ShowLogsResp) ProtoMessage 

func (*ShowLogsResp) ProtoMessage()

func (*ShowLogsResp) ProtoReflect 

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

func (*ShowLogsResp) Reset 

func (x *ShowLogsResp) Reset()

func (*ShowLogsResp) String 

func (x *ShowLogsResp) String() string

type ShowTraceReq 

type ShowTraceReq struct {

	// The ID of the trace in hex.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

The request to get a URL showing the trace information for a trace id.

func (*ShowTraceReq) Descriptor deprecated 

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

Deprecated: Use ShowTraceReq.ProtoReflect.Descriptor instead.

func (*ShowTraceReq) GetId 

func (x *ShowTraceReq) GetId() string

func (*ShowTraceReq) ProtoMessage 

func (*ShowTraceReq) ProtoMessage()

func (*ShowTraceReq) ProtoReflect 

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

func (*ShowTraceReq) Reset 

func (x *ShowTraceReq) Reset()

func (*ShowTraceReq) String 

func (x *ShowTraceReq) String() string

type ShowTraceResp 

type ShowTraceResp struct {

	// The URL to view the trace.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the operations being performed.
	Operations []string `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// A list of tag values in spans labelled "error".
	Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// A list of all tags in the spans.
	Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// The longest duration found in any span.
	Duration *durationpb.Duration `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

The resonse to ShowTrace().

func (*ShowTraceResp) Descriptor deprecated 

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

Deprecated: Use ShowTraceResp.ProtoReflect.Descriptor instead.

func (*ShowTraceResp) GetDuration 

func (x *ShowTraceResp) GetDuration() *durationpb.Duration

func (*ShowTraceResp) GetErrors 

func (x *ShowTraceResp) GetErrors() []string

func (*ShowTraceResp) GetId 

func (x *ShowTraceResp) GetId() string

func (*ShowTraceResp) GetOperations 

func (x *ShowTraceResp) GetOperations() []string

func (*ShowTraceResp) GetTags 

func (x *ShowTraceResp) GetTags() []string

func (*ShowTraceResp) ProtoMessage 

func (*ShowTraceResp) ProtoMessage()

func (*ShowTraceResp) ProtoReflect 

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

func (*ShowTraceResp) Reset 

func (x *ShowTraceResp) Reset()

func (*ShowTraceResp) String 

func (x *ShowTraceResp) String() string

type TraceItem 

type TraceItem struct {

	// The trace identifier in hex form.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The time the trace started in unix nanosecods.
	Start int64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	// contains filtered or unexported fields
}

This represents a trace identifier and when the trace started.

func (*TraceItem) Descriptor deprecated 

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

Deprecated: Use TraceItem.ProtoReflect.Descriptor instead.

func (*TraceItem) GetId 

func (x *TraceItem) GetId() string

func (*TraceItem) GetStart 

func (x *TraceItem) GetStart() int64

func (*TraceItem) ProtoMessage 

func (*TraceItem) ProtoMessage()

func (*TraceItem) ProtoReflect 

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

func (*TraceItem) Reset 

func (x *TraceItem) Reset()

func (*TraceItem) String 

func (x *TraceItem) String() string

type UnimplementedOpsServer 

type UnimplementedOpsServer struct {
}

UnimplementedOpsServer must be embedded to have forward compatible implementations.

func (UnimplementedOpsServer) Alerts 

func (UnimplementedOpsServer) Alerts(context.Context, *AlertsReq) (*AlertsResp, error)

func (UnimplementedOpsServer) ChangeSampling 

func (UnimplementedOpsServer) ChangeSampling(context.Context, *ChangeSamplingReq) (*ChangeSamplingResp, error)

func (UnimplementedOpsServer) DeployedVersion 

func (UnimplementedOpsServer) DeployedVersion(context.Context, *DeployedVersionReq) (*DeployedVersionResp, error)

func (UnimplementedOpsServer) ListTraces 

func (UnimplementedOpsServer) ListTraces(context.Context, *ListTracesReq) (*ListTracesResp, error)

func (UnimplementedOpsServer) ShowLogs 

func (UnimplementedOpsServer) ShowLogs(context.Context, *ShowLogsReq) (*ShowLogsResp, error)

func (UnimplementedOpsServer) ShowTrace 

func (UnimplementedOpsServer) ShowTrace(context.Context, *ShowTraceReq) (*ShowTraceResp, error)

type UnsafeOpsServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
model

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.