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
Source Files