conduit_proxy_telemetry

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package conduit_proxy_telemetry is a generated protocol buffer package.

It is generated from these files: 

proxy/telemetry/telemetry.proto

It has these top-level messages: 

ReportRequest
Process
ServerTransport
ClientTransport
TransportSummary
RequestScope
RequestCtx
Latency
ResponseScope
ResponseCtx
EosScope
EosCtx
StreamSummary
ReportResponse

Index

Constants

This section is empty.

Variables

View Source 
var ReportRequest_Proxy_name = map[int32]string{
	0: "INBOUND",
	1: "OUTBOUND",
}
View Source 
var ReportRequest_Proxy_value = map[string]int32{
	"INBOUND":  0,
	"OUTBOUND": 1,
}

Functions

func RegisterTelemetryServer 

func RegisterTelemetryServer(s *grpc.Server, srv TelemetryServer)

Types

type ClientTransport 

type ClientTransport struct {
	TargetAddr  *conduit_common.TcpAddress `protobuf:"bytes,1,opt,name=target_addr,json=targetAddr" json:"target_addr,omitempty"`
	Connects    uint32                     `protobuf:"varint,2,opt,name=connects" json:"connects,omitempty"`
	Disconnects []*TransportSummary        `protobuf:"bytes,3,rep,name=disconnects" json:"disconnects,omitempty"`
	Protocol    conduit_common.Protocol    `protobuf:"varint,4,opt,name=protocol,enum=conduit.common.Protocol" json:"protocol,omitempty"`
}

func (*ClientTransport) Descriptor 

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

func (*ClientTransport) GetConnects 

func (m *ClientTransport) GetConnects() uint32

func (*ClientTransport) GetDisconnects 

func (m *ClientTransport) GetDisconnects() []*TransportSummary

func (*ClientTransport) GetProtocol added in v0.1.2 

func (m *ClientTransport) GetProtocol() conduit_common.Protocol

func (*ClientTransport) GetTargetAddr 

func (m *ClientTransport) GetTargetAddr() *conduit_common.TcpAddress

func (*ClientTransport) ProtoMessage 

func (*ClientTransport) ProtoMessage()

func (*ClientTransport) Reset 

func (m *ClientTransport) Reset()

func (*ClientTransport) String 

func (m *ClientTransport) String() string

type EosCtx 

type EosCtx struct {
	// Types that are valid to be assigned to End:
	//	*EosCtx_GrpcStatusCode
	//	*EosCtx_ResetErrorCode
	//	*EosCtx_Other
	End isEosCtx_End `protobuf_oneof:"end"`
}

func (*EosCtx) Descriptor 

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

func (*EosCtx) GetEnd 

func (m *EosCtx) GetEnd() isEosCtx_End

func (*EosCtx) GetGrpcStatusCode 

func (m *EosCtx) GetGrpcStatusCode() uint32

func (*EosCtx) GetOther 

func (m *EosCtx) GetOther() bool

func (*EosCtx) GetResetErrorCode 

func (m *EosCtx) GetResetErrorCode() uint32

func (*EosCtx) ProtoMessage 

func (*EosCtx) ProtoMessage()

func (*EosCtx) Reset 

func (m *EosCtx) Reset()

func (*EosCtx) String 

func (m *EosCtx) String() string

func (*EosCtx) XXX_OneofFuncs 

func (*EosCtx) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type EosCtx_GrpcStatusCode 

type EosCtx_GrpcStatusCode struct {
	GrpcStatusCode uint32 `protobuf:"varint,1,opt,name=grpc_status_code,json=grpcStatusCode,oneof"`
}

type EosCtx_Other 

type EosCtx_Other struct {
	Other bool `protobuf:"varint,3,opt,name=other,oneof"`
}

type EosCtx_ResetErrorCode 

type EosCtx_ResetErrorCode struct {
	ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,oneof"`
}

type EosScope 

type EosScope struct {
	Ctx     *EosCtx          `protobuf:"bytes,1,opt,name=ctx" json:"ctx,omitempty"`
	Streams []*StreamSummary `protobuf:"bytes,2,rep,name=streams" json:"streams,omitempty"`
}

func (*EosScope) Descriptor 

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

func (*EosScope) GetCtx 

func (m *EosScope) GetCtx() *EosCtx

func (*EosScope) GetStreams 

func (m *EosScope) GetStreams() []*StreamSummary

func (*EosScope) ProtoMessage 

func (*EosScope) ProtoMessage()

func (*EosScope) Reset 

func (m *EosScope) Reset()

func (*EosScope) String 

func (m *EosScope) String() string

type Latency 

type Latency struct {
	// Latency value in tenths of a millisecond.
	Latency uint32 `protobuf:"varint,1,opt,name=latency" json:"latency,omitempty"`
	// Count of occurences of this latency value.
	Count uint32 `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

A latency value in tenths of a millisecond and a count of the times that latency was observed.

func (*Latency) Descriptor 

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

func (*Latency) GetCount 

func (m *Latency) GetCount() uint32

func (*Latency) GetLatency 

func (m *Latency) GetLatency() uint32

func (*Latency) ProtoMessage 

func (*Latency) ProtoMessage()

func (*Latency) Reset 

func (m *Latency) Reset()

func (*Latency) String 

func (m *Latency) String() string

type Process 

type Process struct {
	Node               string `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
	ScheduledInstance  string `protobuf:"bytes,2,opt,name=scheduled_instance,json=scheduledInstance" json:"scheduled_instance,omitempty"`
	ScheduledNamespace string `protobuf:"bytes,3,opt,name=scheduled_namespace,json=scheduledNamespace" json:"scheduled_namespace,omitempty"`
}

func (*Process) Descriptor 

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

func (*Process) GetNode 

func (m *Process) GetNode() string

func (*Process) GetScheduledInstance 

func (m *Process) GetScheduledInstance() string

func (*Process) GetScheduledNamespace 

func (m *Process) GetScheduledNamespace() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

type ReportRequest 

type ReportRequest struct {
	Process          *Process            `protobuf:"bytes,1,opt,name=process" json:"process,omitempty"`
	Proxy            ReportRequest_Proxy `protobuf:"varint,2,opt,name=proxy,enum=conduit.proxy.telemetry.ReportRequest_Proxy" json:"proxy,omitempty"`
	ServerTransports []*ServerTransport  `protobuf:"bytes,3,rep,name=server_transports,json=serverTransports" json:"server_transports,omitempty"`
	ClientTransports []*ClientTransport  `protobuf:"bytes,4,rep,name=client_transports,json=clientTransports" json:"client_transports,omitempty"`
	Requests         []*RequestScope     `protobuf:"bytes,5,rep,name=requests" json:"requests,omitempty"`
}

func (*ReportRequest) Descriptor 

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

func (*ReportRequest) GetClientTransports 

func (m *ReportRequest) GetClientTransports() []*ClientTransport

func (*ReportRequest) GetProcess 

func (m *ReportRequest) GetProcess() *Process

func (*ReportRequest) GetProxy 

func (m *ReportRequest) GetProxy() ReportRequest_Proxy

func (*ReportRequest) GetRequests 

func (m *ReportRequest) GetRequests() []*RequestScope

func (*ReportRequest) GetServerTransports 

func (m *ReportRequest) GetServerTransports() []*ServerTransport

func (*ReportRequest) ProtoMessage 

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) Reset 

func (m *ReportRequest) Reset()

func (*ReportRequest) String 

func (m *ReportRequest) String() string

type ReportRequest_Proxy 

type ReportRequest_Proxy int32
const (
	ReportRequest_INBOUND  ReportRequest_Proxy = 0
	ReportRequest_OUTBOUND ReportRequest_Proxy = 1
)

func (ReportRequest_Proxy) EnumDescriptor 

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

func (ReportRequest_Proxy) String 

func (x ReportRequest_Proxy) String() string

type ReportResponse 

type ReportResponse struct {
}

func (*ReportResponse) Descriptor 

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

func (*ReportResponse) ProtoMessage 

func (*ReportResponse) ProtoMessage()

func (*ReportResponse) Reset 

func (m *ReportResponse) Reset()

func (*ReportResponse) String 

func (m *ReportResponse) String() string

type RequestCtx 

type RequestCtx struct {
	SourceIp   *conduit_common.IPAddress  `protobuf:"bytes,1,opt,name=source_ip,json=sourceIp" json:"source_ip,omitempty"`
	TargetAddr *conduit_common.TcpAddress `protobuf:"bytes,2,opt,name=target_addr,json=targetAddr" json:"target_addr,omitempty"`
	Authority  string                     `protobuf:"bytes,3,opt,name=authority" json:"authority,omitempty"`
	Method     *conduit_common.HttpMethod `protobuf:"bytes,4,opt,name=method" json:"method,omitempty"`
	Path       string                     `protobuf:"bytes,5,opt,name=path" json:"path,omitempty"`
}

func (*RequestCtx) Descriptor 

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

func (*RequestCtx) GetAuthority 

func (m *RequestCtx) GetAuthority() string

func (*RequestCtx) GetMethod 

func (m *RequestCtx) GetMethod() *conduit_common.HttpMethod

func (*RequestCtx) GetPath 

func (m *RequestCtx) GetPath() string

func (*RequestCtx) GetSourceIp 

func (m *RequestCtx) GetSourceIp() *conduit_common.IPAddress

func (*RequestCtx) GetTargetAddr 

func (m *RequestCtx) GetTargetAddr() *conduit_common.TcpAddress

func (*RequestCtx) ProtoMessage 

func (*RequestCtx) ProtoMessage()

func (*RequestCtx) Reset 

func (m *RequestCtx) Reset()

func (*RequestCtx) String 

func (m *RequestCtx) String() string

type RequestScope 

type RequestScope struct {
	Ctx       *RequestCtx      `protobuf:"bytes,1,opt,name=ctx" json:"ctx,omitempty"`
	Count     uint32           `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
	Responses []*ResponseScope `protobuf:"bytes,3,rep,name=responses" json:"responses,omitempty"`
}

func (*RequestScope) Descriptor 

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

func (*RequestScope) GetCount 

func (m *RequestScope) GetCount() uint32

func (*RequestScope) GetCtx 

func (m *RequestScope) GetCtx() *RequestCtx

func (*RequestScope) GetResponses 

func (m *RequestScope) GetResponses() []*ResponseScope

func (*RequestScope) ProtoMessage 

func (*RequestScope) ProtoMessage()

func (*RequestScope) Reset 

func (m *RequestScope) Reset()

func (*RequestScope) String 

func (m *RequestScope) String() string

type ResponseCtx 

type ResponseCtx struct {
	HttpStatusCode uint32 `protobuf:"varint,1,opt,name=http_status_code,json=httpStatusCode" json:"http_status_code,omitempty"`
}

func (*ResponseCtx) Descriptor 

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

func (*ResponseCtx) GetHttpStatusCode 

func (m *ResponseCtx) GetHttpStatusCode() uint32

func (*ResponseCtx) ProtoMessage 

func (*ResponseCtx) ProtoMessage()

func (*ResponseCtx) Reset 

func (m *ResponseCtx) Reset()

func (*ResponseCtx) String 

func (m *ResponseCtx) String() string

type ResponseScope 

type ResponseScope struct {
	Ctx *ResponseCtx `protobuf:"bytes,1,opt,name=ctx" json:"ctx,omitempty"`
	// Response latencies (time from request headers sent to response headers received),
	// represented as an array of observed latency values with precision to 100µs and
	// the number of times those values were observed, ordered by the latency value.
	ResponseLatencies []*Latency  `protobuf:"bytes,2,rep,name=response_latencies,json=responseLatencies" json:"response_latencies,omitempty"`
	Ends              []*EosScope `protobuf:"bytes,3,rep,name=ends" json:"ends,omitempty"`
}

func (*ResponseScope) Descriptor 

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

func (*ResponseScope) GetCtx 

func (m *ResponseScope) GetCtx() *ResponseCtx

func (*ResponseScope) GetEnds 

func (m *ResponseScope) GetEnds() []*EosScope

func (*ResponseScope) GetResponseLatencies 

func (m *ResponseScope) GetResponseLatencies() []*Latency

func (*ResponseScope) ProtoMessage 

func (*ResponseScope) ProtoMessage()

func (*ResponseScope) Reset 

func (m *ResponseScope) Reset()

func (*ResponseScope) String 

func (m *ResponseScope) String() string

type ServerTransport 

type ServerTransport struct {
	SourceIp    *conduit_common.IPAddress `protobuf:"bytes,1,opt,name=source_ip,json=sourceIp" json:"source_ip,omitempty"`
	Connects    uint32                    `protobuf:"varint,2,opt,name=connects" json:"connects,omitempty"`
	Disconnects []*TransportSummary       `protobuf:"bytes,3,rep,name=disconnects" json:"disconnects,omitempty"`
	Protocol    conduit_common.Protocol   `protobuf:"varint,4,opt,name=protocol,enum=conduit.common.Protocol" json:"protocol,omitempty"`
}

func (*ServerTransport) Descriptor 

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

func (*ServerTransport) GetConnects 

func (m *ServerTransport) GetConnects() uint32

func (*ServerTransport) GetDisconnects 

func (m *ServerTransport) GetDisconnects() []*TransportSummary

func (*ServerTransport) GetProtocol added in v0.1.2 

func (m *ServerTransport) GetProtocol() conduit_common.Protocol

func (*ServerTransport) GetSourceIp 

func (m *ServerTransport) GetSourceIp() *conduit_common.IPAddress

func (*ServerTransport) ProtoMessage 

func (*ServerTransport) ProtoMessage()

func (*ServerTransport) Reset 

func (m *ServerTransport) Reset()

func (*ServerTransport) String 

func (m *ServerTransport) String() string

type StreamSummary 

type StreamSummary struct {
	DurationMs uint64 `protobuf:"varint,1,opt,name=duration_ms,json=durationMs" json:"duration_ms,omitempty"`
	BytesSent  uint64 `protobuf:"varint,2,opt,name=bytes_sent,json=bytesSent" json:"bytes_sent,omitempty"`
	FramesSent uint32 `protobuf:"varint,3,opt,name=frames_sent,json=framesSent" json:"frames_sent,omitempty"`
}

func (*StreamSummary) Descriptor 

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

func (*StreamSummary) GetBytesSent 

func (m *StreamSummary) GetBytesSent() uint64

func (*StreamSummary) GetDurationMs 

func (m *StreamSummary) GetDurationMs() uint64

func (*StreamSummary) GetFramesSent 

func (m *StreamSummary) GetFramesSent() uint32

func (*StreamSummary) ProtoMessage 

func (*StreamSummary) ProtoMessage()

func (*StreamSummary) Reset 

func (m *StreamSummary) Reset()

func (*StreamSummary) String 

func (m *StreamSummary) String() string

type TelemetryClient 

type TelemetryClient interface {
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error)
}

func NewTelemetryClient 

func NewTelemetryClient(cc *grpc.ClientConn) TelemetryClient

type TelemetryServer 

type TelemetryServer interface {
	Report(context.Context, *ReportRequest) (*ReportResponse, error)
}

type TransportSummary 

type TransportSummary struct {
	DurationMs uint64 `protobuf:"varint,1,opt,name=duration_ms,json=durationMs" json:"duration_ms,omitempty"`
	BytesSent  uint64 `protobuf:"varint,2,opt,name=bytes_sent,json=bytesSent" json:"bytes_sent,omitempty"`
}

func (*TransportSummary) Descriptor 

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

func (*TransportSummary) GetBytesSent 

func (m *TransportSummary) GetBytesSent() uint64

func (*TransportSummary) GetDurationMs 

func (m *TransportSummary) GetDurationMs() uint64

func (*TransportSummary) ProtoMessage 

func (*TransportSummary) ProtoMessage()

func (*TransportSummary) Reset 

func (m *TransportSummary) Reset()

func (*TransportSummary) String 

func (m *TransportSummary) String() string

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.