telemetry

Jun 5, 2024

Changes in this version

+ func GetDummyKeyString() string

+ func GetDummyKeyStringWithPrefix(prefix string) string

Nov 14, 2023

Changes in this version

+ type Manager struct

+ MonitoringEndpointGenerator MonitoringEndpointGenerator

+ func NewManager(cfg config.TelemetryIngress, csaKeyStore keystore.CSA, lggr logger.Logger) *Manager

+ func (m *Manager) Close() error

+ func (m *Manager) GenMonitoringEndpoint(contractID string, telemType synchronization.TelemetryType, network string, ...) commontypes.MonitoringEndpoint

+ func (m *Manager) HealthReport() map[string]error

+ func (m *Manager) Name() string

+ func (m *Manager) Start(ctx context.Context) error

Apr 21, 2023

Changes in this version

+ type ExplorerAgent struct

+ func NewExplorerAgent(explorerClient synchronization.ExplorerClient) *ExplorerAgent

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

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

+ type IngressAgent struct

+ func NewIngressAgent(telemetryIngressClient synchronization.TelemetryIngressClient, ...) *IngressAgent

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

+ type IngressAgentBatch struct

+ func NewIngressAgentBatch(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient, ...) *IngressAgentBatch

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

+ type IngressAgentBatchWrapper struct

+ func NewIngressAgentBatchWrapper(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient) *IngressAgentBatchWrapper

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

+ type IngressAgentWrapper struct

+ func NewIngressAgentWrapper(telemetryIngressClient synchronization.TelemetryIngressClient) *IngressAgentWrapper

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

+ type MonitoringEndpointGenerator interface

+ GenMonitoringEndpoint func(contractID string, telemType synchronization.TelemetryType) ocrtypes.MonitoringEndpoint

+ type NoopAgent struct

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

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