telemetry

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2024 License: MPL-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

func NewClient 

func NewClient(logger *zap.Logger, serverURL string, keyUID string, nodeName string, version string, opts ...TelemetryClientOption) *Client

func (*Client) ProcessErrorSendingEnvelope added in v0.181.32 

func (c *Client) ProcessErrorSendingEnvelope(errorSendingEnvelope wakuv2.ErrorSendingEnvelope) *json.RawMessage

func (*Client) ProcessMessageCheckFailure added in v1.1.0 

func (c *Client) ProcessMessageCheckFailure(messageCheckFailure MessageCheckFailure) *json.RawMessage

func (*Client) ProcessMessageCheckSuccess added in v1.1.0 

func (c *Client) ProcessMessageCheckSuccess(messageCheckSuccess MessageCheckSuccess) *json.RawMessage

func (*Client) ProcessPeerConnFailure added in v0.182.41 

func (c *Client) ProcessPeerConnFailure(peerConnFailure PeerConnFailure) *json.RawMessage

func (*Client) ProcessPeerCount added in v0.182.35 

func (c *Client) ProcessPeerCount(peerCount PeerCount) *json.RawMessage

func (*Client) ProcessPeerCountByOrigin added in v1.1.0 

func (c *Client) ProcessPeerCountByOrigin(peerCountByOrigin PeerCountByOrigin) *json.RawMessage

func (*Client) ProcessPeerCountByShard added in v1.1.0 

func (c *Client) ProcessPeerCountByShard(peerCountByShard PeerCountByShard) *json.RawMessage

func (*Client) ProcessReceivedEnvelope added in v0.180.31 

func (c *Client) ProcessReceivedEnvelope(envelope *v2protocol.Envelope) *json.RawMessage

func (*Client) ProcessReceivedMessages added in v0.180.31 

func (c *Client) ProcessReceivedMessages(receivedMessages ReceivedMessages) *json.RawMessage

func (*Client) ProcessSentEnvelope added in v0.180.31 

func (c *Client) ProcessSentEnvelope(sentEnvelope wakuv2.SentEnvelope) *json.RawMessage

func (*Client) PushErrorSendingEnvelope added in v0.181.32 

func (c *Client) PushErrorSendingEnvelope(ctx context.Context, errorSendingEnvelope wakuv2.ErrorSendingEnvelope)

func (*Client) PushMessageCheckFailure added in v1.1.0 

func (c *Client) PushMessageCheckFailure(ctx context.Context, messageHash string)

func (*Client) PushMessageCheckSuccess added in v1.1.0 

func (c *Client) PushMessageCheckSuccess(ctx context.Context, messageHash string)

func (*Client) PushPeerConnFailures added in v0.182.41 

func (c *Client) PushPeerConnFailures(ctx context.Context, peerConnFailures map[string]int)

func (*Client) PushPeerCount added in v0.182.35 

func (c *Client) PushPeerCount(ctx context.Context, peerCount int)

func (*Client) PushPeerCountByOrigin added in v1.1.0 

func (c *Client) PushPeerCountByOrigin(ctx context.Context, peerCountByOrigin map[wps.Origin]uint)

func (*Client) PushPeerCountByShard added in v1.1.0 

func (c *Client) PushPeerCountByShard(ctx context.Context, peerCountByShard map[uint16]uint)

func (*Client) PushReceivedEnvelope added in v0.171.11 

func (c *Client) PushReceivedEnvelope(ctx context.Context, receivedEnvelope *v2protocol.Envelope)

func (*Client) PushReceivedMessages 

func (c *Client) PushReceivedMessages(ctx context.Context, receivedMessages ReceivedMessages)

func (*Client) PushSentEnvelope added in v0.180.31 

func (c *Client) PushSentEnvelope(ctx context.Context, sentEnvelope wakuv2.SentEnvelope)

func (*Client) SetDeviceType added in v0.184.52 

func (c *Client) SetDeviceType(deviceType string)

func (*Client) Start added in v0.180.31 

func (c *Client) Start(ctx context.Context)

func (*Client) UpdateEnvelopeProcessingError added in v0.171.11 

func (c *Client) UpdateEnvelopeProcessingError(shhMessage *types.Message, processingError error)

type MessageCheckFailure added in v1.1.0 

type MessageCheckFailure struct {
	MessageHash string
}

type MessageCheckSuccess added in v1.1.0 

type MessageCheckSuccess struct {
	MessageHash string
}

type PeerConnFailure added in v0.182.41 

type PeerConnFailure struct {
	FailedPeerId string
	FailureCount int
}

type PeerCount added in v0.182.35 

type PeerCount struct {
	PeerCount int
}

type PeerCountByOrigin added in v1.1.0 

type PeerCountByOrigin struct {
	Origin wps.Origin
	Count  uint
}

type PeerCountByShard added in v1.1.0 

type PeerCountByShard struct {
	Shard uint16
	Count uint
}

type ReceivedMessages added in v0.180.31 

type ReceivedMessages struct {
	Filter     transport.Filter
	SSHMessage *types.Message
	Messages   []*v1protocol.StatusMessage
}

type TelemetryClientOption added in v0.181.32 

type TelemetryClientOption func(*Client)

func WithPeerID added in v0.182.41 

func WithPeerID(peerId string) TelemetryClientOption

func WithSendPeriod added in v0.181.32 

func WithSendPeriod(sendPeriod time.Duration) TelemetryClientOption

type TelemetryRequest added in v0.180.31 

type TelemetryRequest struct {
	Id            int              `json:"id"`
	TelemetryType TelemetryType    `json:"telemetry_type"`
	TelemetryData *json.RawMessage `json:"telemetry_data"`
}

type TelemetryType added in v0.180.31 

type TelemetryType string
const (
	ProtocolStatsMetric        TelemetryType = "ProtocolStats"
	ReceivedEnvelopeMetric     TelemetryType = "ReceivedEnvelope"
	SentEnvelopeMetric         TelemetryType = "SentEnvelope"
	UpdateEnvelopeMetric       TelemetryType = "UpdateEnvelope"
	ReceivedMessagesMetric     TelemetryType = "ReceivedMessages"
	ErrorSendingEnvelopeMetric TelemetryType = "ErrorSendingEnvelope"
	PeerCountMetric            TelemetryType = "PeerCount"
	PeerConnFailuresMetric     TelemetryType = "PeerConnFailure"
	MessageCheckSuccessMetric  TelemetryType = "MessageCheckSuccess"
	MessageCheckFailureMetric  TelemetryType = "MessageCheckFailure"
	PeerCountByShardMetric     TelemetryType = "PeerCountByShard"
	PeerCountByOriginMetric    TelemetryType = "PeerCountByOrigin"
	MaxRetryCache                            = 5000
)

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.