telemetry

package
v2.2.1-mercury-20230627 Latest Latest
Warning

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

Go to latest
Published: Jun 28, 2023 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

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

func NewExplorerAgent

func NewExplorerAgent(explorerClient synchronization.ExplorerClient) *ExplorerAgent

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

func (*ExplorerAgent) GenMonitoringEndpoint

func (t *ExplorerAgent) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint

GenMonitoringEndpoint creates a monitoring endpoint for telemetry

func (*ExplorerAgent) SendLog

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

SendLog sends a telemetry log to the explorer

type IngressAgent

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

func NewIngressAgent

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

func (*IngressAgent) SendLog

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

SendLog sends a telemetry log to the ingress server

type IngressAgentBatch

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

IngressAgentBatch allows for sending batch telemetry for a given contractID

func NewIngressAgentBatch

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

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

func (*IngressAgentBatch) SendLog

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

SendLog sends a telemetry log to the ingress server

type IngressAgentBatchWrapper

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

IngressAgentBatchWrapper provides monitoring endpoint generation for the telemetry batch client

func NewIngressAgentBatchWrapper

func NewIngressAgentBatchWrapper(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient) *IngressAgentBatchWrapper

NewIngressAgentBatchWrapper creates a new IngressAgentBatchWrapper with the provided telemetry batch client

func (*IngressAgentBatchWrapper) GenMonitoringEndpoint

func (t *IngressAgentBatchWrapper) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint

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

type IngressAgentWrapper

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

func NewIngressAgentWrapper

func NewIngressAgentWrapper(telemetryIngressClient synchronization.TelemetryIngressClient) *IngressAgentWrapper

func (*IngressAgentWrapper) GenMonitoringEndpoint

func (t *IngressAgentWrapper) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint

type MonitoringEndpointGenerator

type MonitoringEndpointGenerator interface {
	GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint
}

type NoopAgent

type NoopAgent struct {
}

func (*NoopAgent) GenMonitoringEndpoint

func (t *NoopAgent) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) 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