telemetry

Documentation

Index

• type ExplorerAgent
  • func NewExplorerAgent(explorerClient synchronization.ExplorerClient) *ExplorerAgent
  • func (t *ExplorerAgent) GenMonitoringEndpoint(addr common.Address) ocrtypes.MonitoringEndpoint
  • func (t *ExplorerAgent) SendLog(log []byte)
• type IngressAgent
  • func NewIngressAgent(telemetryIngressClient synchronization.TelemetryIngressClient, ...) *IngressAgent
  • func (t *IngressAgent) SendLog(telemetry []byte)
• type IngressAgentWrapper
  • func NewIngressAgentWrapper(telemetryIngressClient synchronization.TelemetryIngressClient) *IngressAgentWrapper
  • func (t *IngressAgentWrapper) GenMonitoringEndpoint(addr common.Address) ocrtypes.MonitoringEndpoint
• type MonitoringEndpointGenerator
• type NoopAgent
  • func (t *NoopAgent) GenMonitoringEndpoint(addr common.Address) ocrtypes.MonitoringEndpoint
  • func (t *NoopAgent) SendLog(log []byte)

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(addr common.Address) 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, contractAddress common.Address) *IngressAgent

func (*IngressAgent) SendLog

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

SendLog sends a telemetry log to the ingress server

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(addr common.Address) ocrtypes.MonitoringEndpoint

type MonitoringEndpointGenerator

type MonitoringEndpointGenerator interface {
	GenMonitoringEndpoint(addr common.Address) ocrtypes.MonitoringEndpoint
}

type NoopAgent

type NoopAgent struct {
}

func (*NoopAgent) GenMonitoringEndpoint

func (t *NoopAgent) GenMonitoringEndpoint(addr common.Address) 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