telemetry

package
v1.8.0-debug-keepers-o... Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2022 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExplorerAgent added in v1.0.0

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

func NewExplorerAgent added in v1.0.0

func NewExplorerAgent(explorerClient synchronization.ExplorerClient) *ExplorerAgent

NewExplorerAgent returns a Agent which is just a thin wrapper over the explorerClient for now

func (*ExplorerAgent) GenMonitoringEndpoint added in v1.0.0

func (t *ExplorerAgent) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint

GenMonitoringEndpoint creates a monitoring endpoint for telemetry

func (*ExplorerAgent) SendLog added in v1.0.0

func (t *ExplorerAgent) SendLog(log []byte)

SendLog sends a telemetry log to the explorer

type IngressAgent added in v1.0.0

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

func NewIngressAgent added in v1.0.0

func NewIngressAgent(telemetryIngressClient synchronization.TelemetryIngressClient, contractID string) *IngressAgent

func (*IngressAgent) SendLog added in v1.0.0

func (t *IngressAgent) SendLog(telemetry []byte)

SendLog sends a telemetry log to the ingress server

type IngressAgentBatch added in v1.2.0

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

IngressAgentBatch allows for sending batch telemetry for a given contractID

func NewIngressAgentBatch added in v1.2.0

func NewIngressAgentBatch(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient, contractID string) *IngressAgentBatch

NewIngressAgentBatch creates a new IngressAgentBatch with the given batch client and contractID

func (*IngressAgentBatch) SendLog added in v1.2.0

func (t *IngressAgentBatch) SendLog(telemetry []byte)

SendLog sends a telemetry log to the ingress server

type IngressAgentBatchWrapper added in v1.2.0

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

IngressAgentBatchWrapper provides monitoring endpoint generation for the telemetry batch client

func NewIngressAgentBatchWrapper added in v1.2.0

func NewIngressAgentBatchWrapper(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient) *IngressAgentBatchWrapper

NewIngressAgentBatchWrapper creates a new IngressAgentBatchWrapper with the provided telemetry batch client

func (*IngressAgentBatchWrapper) GenMonitoringEndpoint added in v1.2.0

func (t *IngressAgentBatchWrapper) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint

GenMonitoringEndpoint returns a new ingress batch agent instantiated with the batch client and a contractID

type IngressAgentWrapper added in v1.0.0

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

func NewIngressAgentWrapper added in v1.0.0

func NewIngressAgentWrapper(telemetryIngressClient synchronization.TelemetryIngressClient) *IngressAgentWrapper

func (*IngressAgentWrapper) GenMonitoringEndpoint added in v1.0.0

func (t *IngressAgentWrapper) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint

type MonitoringEndpointGenerator added in v1.0.0

type MonitoringEndpointGenerator interface {
	GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint
}

type NoopAgent

type NoopAgent struct {
}

func (*NoopAgent) GenMonitoringEndpoint added in v1.0.0

func (t *NoopAgent) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint

GenMonitoringEndpoint creates a monitoring endpoint for telemetry

func (*NoopAgent) SendLog

func (t *NoopAgent) SendLog(log []byte)

SendLog sends a telemetry log to the explorer

Jump to

Keyboard shortcuts

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