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

Jump to

Keyboard shortcuts

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