istio: istio.io/istio/pkg/mcp/monitoring Index | Files

package monitoring

import "istio.io/istio/pkg/mcp/monitoring"

Index

Package Files

monitoring.go

type Reporter Uses

type Reporter interface {
    io.Closer

    RecordSendError(err error, code codes.Code)
    RecordRecvError(err error, code codes.Code)
    RecordRequestSize(collection string, connectionID int64, size int)
    RecordRequestAck(collection string, connectionID int64)
    RecordRequestNack(collection string, connectionID int64, code codes.Code)

    SetStreamCount(clients int64)
    RecordStreamCreateSuccess()
}

Reporter is used to report metrics for an MCP server.

type StatsContext Uses

type StatsContext struct {
    // contains filtered or unexported fields
}

StatsContext enables metric collection backed by OpenCensus.

func NewStatsContext Uses

func NewStatsContext(componentName string) *StatsContext

NewStatsContext creates a new context for recording MCP-related metrics.

func (*StatsContext) Close Uses

func (s *StatsContext) Close() error

func (*StatsContext) RecordRecvError Uses

func (s *StatsContext) RecordRecvError(err error, code codes.Code)

RecordRecvError records an error during a network recv with its error string and code.

func (*StatsContext) RecordRequestAck Uses

func (s *StatsContext) RecordRequestAck(collection string, connectionID int64)

RecordRequestAck records an ACK message for a collection on a connection.

func (*StatsContext) RecordRequestNack Uses

func (s *StatsContext) RecordRequestNack(collection string, connectionID int64, code codes.Code)

RecordRequestNack records a NACK message for a collection on a connection.

func (*StatsContext) RecordRequestSize Uses

func (s *StatsContext) RecordRequestSize(collection string, connectionID int64, size int)

RecordRequestSize records the size of a request from a connection for a specific type URL.

func (*StatsContext) RecordSendError Uses

func (s *StatsContext) RecordSendError(err error, code codes.Code)

RecordSendError records an error during a network send with its error string and code.

func (*StatsContext) RecordStreamCreateSuccess Uses

func (s *StatsContext) RecordStreamCreateSuccess()

RecordStreamCreateSuccess records a successful stream connection.

func (*StatsContext) SetStreamCount Uses

func (s *StatsContext) SetStreamCount(clients int64)

SetStreamCount updates the current client count to the given argument.

Package monitoring imports 5 packages (graph) and is imported by 10 packages. Updated 2019-08-06. Refresh now. Tools for package owners.