telemetry

Documentation

Index

• type IngressAgent
  • func NewIngressAgent(telemetryIngressClient synchronization.TelemetryIngressClient, ...) *IngressAgent
  • func (t *IngressAgent) SendLog(telemetry []byte)
• type IngressAgentBatch
  • func NewIngressAgentBatch(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient, ...) *IngressAgentBatch
  • func (t *IngressAgentBatch) SendLog(telemetry []byte)
• type IngressAgentBatchWrapper
  • func NewIngressAgentBatchWrapper(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient) *IngressAgentBatchWrapper
  • func (t *IngressAgentBatchWrapper) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint
• type IngressAgentWrapper
  • func NewIngressAgentWrapper(telemetryIngressClient synchronization.TelemetryIngressClient) *IngressAgentWrapper
  • func (t *IngressAgentWrapper) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint
• type MonitoringEndpointGenerator
• type NoopAgent
  • func (t *NoopAgent) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint
  • func (t *NoopAgent) SendLog(log []byte)

Types

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 ingress service