conduit_proxy_telemetry

package

Go to main page

Versions in this module

v0

v0.3.1

Mar 15, 2018 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

v0.3.0

Feb 21, 2018 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

Changes in this version

type ReportRequest

+ HistogramBucketBoundsTenthMs []uint32

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

type ResponseScope

+ ResponseLatencyCounts []uint32

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

v0.2.0

Jan 31, 2018 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

v0.1.3

Jan 19, 2018 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

v0.1.2

Jan 19, 2018 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

Changes in this version

type ClientTransport

+ Protocol conduit_common.Protocol

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

type ServerTransport

+ Protocol conduit_common.Protocol

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

v0.1.1

Dec 20, 2017 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

v0.1.0

Dec 5, 2017 GO-2024-2984 +1 more

GO-2024-2984: Linkerd potential access to the shutdown endpoint in github.com/linkerd/linkerd2

GO-2025-3664: Linkerd resource exhaustion vulnerability in github.com/linkerd/linkerd2

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

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