Versions in this module Expand all Collapse all v0 v0.1.1 Dec 20, 2017 v0.1.0 Dec 5, 2017 Changes in this version + var ReportRequest_Proxy_name = map[int32]string + var ReportRequest_Proxy_value = map[string]int32 + func RegisterTelemetryServer(s *grpc.Server, srv TelemetryServer) + type ClientTransport struct + Connects uint32 + Disconnects []*TransportSummary + TargetAddr *conduit_common.TcpAddress + func (*ClientTransport) Descriptor() ([]byte, []int) + func (*ClientTransport) ProtoMessage() + func (m *ClientTransport) GetConnects() uint32 + func (m *ClientTransport) GetDisconnects() []*TransportSummary + func (m *ClientTransport) GetTargetAddr() *conduit_common.TcpAddress + func (m *ClientTransport) Reset() + func (m *ClientTransport) String() string + type EosCtx struct + End isEosCtx_End + func (*EosCtx) Descriptor() ([]byte, []int) + func (*EosCtx) ProtoMessage() + func (*EosCtx) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *EosCtx) GetEnd() isEosCtx_End + func (m *EosCtx) GetGrpcStatusCode() uint32 + func (m *EosCtx) GetOther() bool + func (m *EosCtx) GetResetErrorCode() uint32 + func (m *EosCtx) Reset() + func (m *EosCtx) String() string + type EosCtx_GrpcStatusCode struct + GrpcStatusCode uint32 + type EosCtx_Other struct + Other bool + type EosCtx_ResetErrorCode struct + ResetErrorCode uint32 + type EosScope struct + Ctx *EosCtx + Streams []*StreamSummary + func (*EosScope) Descriptor() ([]byte, []int) + func (*EosScope) ProtoMessage() + func (m *EosScope) GetCtx() *EosCtx + func (m *EosScope) GetStreams() []*StreamSummary + func (m *EosScope) Reset() + func (m *EosScope) String() string + type Latency struct + Count uint32 + Latency uint32 + func (*Latency) Descriptor() ([]byte, []int) + func (*Latency) ProtoMessage() + func (m *Latency) GetCount() uint32 + func (m *Latency) GetLatency() uint32 + func (m *Latency) Reset() + func (m *Latency) String() string + type Process struct + Node string + ScheduledInstance string + ScheduledNamespace string + func (*Process) Descriptor() ([]byte, []int) + func (*Process) ProtoMessage() + func (m *Process) GetNode() string + func (m *Process) GetScheduledInstance() string + func (m *Process) GetScheduledNamespace() string + func (m *Process) Reset() + func (m *Process) String() string + type ReportRequest struct + ClientTransports []*ClientTransport + Process *Process + Proxy ReportRequest_Proxy + Requests []*RequestScope + ServerTransports []*ServerTransport + func (*ReportRequest) Descriptor() ([]byte, []int) + func (*ReportRequest) ProtoMessage() + func (m *ReportRequest) GetClientTransports() []*ClientTransport + func (m *ReportRequest) GetProcess() *Process + func (m *ReportRequest) GetProxy() ReportRequest_Proxy + func (m *ReportRequest) GetRequests() []*RequestScope + func (m *ReportRequest) GetServerTransports() []*ServerTransport + func (m *ReportRequest) Reset() + func (m *ReportRequest) String() string + type ReportRequest_Proxy int32 + const ReportRequest_INBOUND + const ReportRequest_OUTBOUND + func (ReportRequest_Proxy) EnumDescriptor() ([]byte, []int) + func (x ReportRequest_Proxy) String() string + type ReportResponse struct + func (*ReportResponse) Descriptor() ([]byte, []int) + func (*ReportResponse) ProtoMessage() + func (m *ReportResponse) Reset() + func (m *ReportResponse) String() string + type RequestCtx struct + Authority string + Method *conduit_common.HttpMethod + Path string + SourceIp *conduit_common.IPAddress + TargetAddr *conduit_common.TcpAddress + func (*RequestCtx) Descriptor() ([]byte, []int) + func (*RequestCtx) ProtoMessage() + func (m *RequestCtx) GetAuthority() string + func (m *RequestCtx) GetMethod() *conduit_common.HttpMethod + func (m *RequestCtx) GetPath() string + func (m *RequestCtx) GetSourceIp() *conduit_common.IPAddress + func (m *RequestCtx) GetTargetAddr() *conduit_common.TcpAddress + func (m *RequestCtx) Reset() + func (m *RequestCtx) String() string + type RequestScope struct + Count uint32 + Ctx *RequestCtx + Responses []*ResponseScope + func (*RequestScope) Descriptor() ([]byte, []int) + func (*RequestScope) ProtoMessage() + func (m *RequestScope) GetCount() uint32 + func (m *RequestScope) GetCtx() *RequestCtx + func (m *RequestScope) GetResponses() []*ResponseScope + func (m *RequestScope) Reset() + func (m *RequestScope) String() string + type ResponseCtx struct + HttpStatusCode uint32 + func (*ResponseCtx) Descriptor() ([]byte, []int) + func (*ResponseCtx) ProtoMessage() + func (m *ResponseCtx) GetHttpStatusCode() uint32 + func (m *ResponseCtx) Reset() + func (m *ResponseCtx) String() string + type ResponseScope struct + Ctx *ResponseCtx + Ends []*EosScope + ResponseLatencies []*Latency + func (*ResponseScope) Descriptor() ([]byte, []int) + func (*ResponseScope) ProtoMessage() + func (m *ResponseScope) GetCtx() *ResponseCtx + func (m *ResponseScope) GetEnds() []*EosScope + func (m *ResponseScope) GetResponseLatencies() []*Latency + func (m *ResponseScope) Reset() + func (m *ResponseScope) String() string + type ServerTransport struct + Connects uint32 + Disconnects []*TransportSummary + SourceIp *conduit_common.IPAddress + func (*ServerTransport) Descriptor() ([]byte, []int) + func (*ServerTransport) ProtoMessage() + func (m *ServerTransport) GetConnects() uint32 + func (m *ServerTransport) GetDisconnects() []*TransportSummary + func (m *ServerTransport) GetSourceIp() *conduit_common.IPAddress + func (m *ServerTransport) Reset() + func (m *ServerTransport) String() string + type StreamSummary struct + BytesSent uint64 + DurationMs uint64 + FramesSent uint32 + func (*StreamSummary) Descriptor() ([]byte, []int) + func (*StreamSummary) ProtoMessage() + func (m *StreamSummary) GetBytesSent() uint64 + func (m *StreamSummary) GetDurationMs() uint64 + func (m *StreamSummary) GetFramesSent() uint32 + func (m *StreamSummary) Reset() + func (m *StreamSummary) String() string + type TelemetryClient interface + Report func(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error) + func NewTelemetryClient(cc *grpc.ClientConn) TelemetryClient + type TelemetryServer interface + Report func(context.Context, *ReportRequest) (*ReportResponse, error) + type TransportSummary struct + BytesSent uint64 + DurationMs uint64 + func (*TransportSummary) Descriptor() ([]byte, []int) + func (*TransportSummary) ProtoMessage() + func (m *TransportSummary) GetBytesSent() uint64 + func (m *TransportSummary) GetDurationMs() uint64 + func (m *TransportSummary) Reset() + func (m *TransportSummary) String() string
Go to main page