conduit_proxy_telemetry

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 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
ResponseScope
ResponseCtx
EosScope
EosCtx
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 uint32  `protobuf:"varint,2,opt,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() uint32

func (*EosScope) ProtoMessage 

func (*EosScope) ProtoMessage()

func (*EosScope) Reset 

func (m *EosScope) Reset()

func (*EosScope) String 

func (m *EosScope) 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"`
	// The inclusive upper bound of each bucket in the response latency histogram,
	// in tenths of a millisecond.
	//
	// Each ResponseScope message will contain an array of numbers representing
	// the number of observed response latencies in each bucket of the latency
	// histogram. Since the structure of the latency histogram will be the same
	// across all ResponseScopes, we only need to report the max values for these
	// buckets a single time.
	HistogramBucketBoundsTenthMs []uint32 `` /* 152-byte string literal not displayed */
}

func (*ReportRequest) Descriptor 

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

func (*ReportRequest) GetClientTransports 

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

func (*ReportRequest) GetHistogramBucketBoundsTenthMs added in v0.3.0 

func (m *ReportRequest) GetHistogramBucketBoundsTenthMs() []uint32

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"`
}

func (*RequestCtx) Descriptor 

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

func (*RequestCtx) GetAuthority 

func (m *RequestCtx) GetAuthority() 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 a histogram with buckets whose inclusive
	// upper bounds are given in the `histogram_bucket_bounds_tenths_ms` array in
	// `ReportRequest`. Each number in this array represents the number of times a
	// latency falling into that bucket was observed.
	ResponseLatencyCounts []uint32    `` /* 127-byte string literal not displayed */
	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) GetResponseLatencyCounts added in v0.3.0 

func (m *ResponseScope) GetResponseLatencyCounts() []uint32

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 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.