The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExplorerAgent ¶ added in v1.0.0
type ExplorerAgent struct {
// contains filtered or unexported fields
}
func NewExplorerAgent ¶ added in v1.0.0
func NewExplorerAgent(explorerClient synchronization.ExplorerClient) *ExplorerAgent
NewExplorerAgent returns a Agent which is just a thin wrapper over the explorerClient for now
func (*ExplorerAgent) GenMonitoringEndpoint ¶ added in v1.0.0
func (t *ExplorerAgent) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint
GenMonitoringEndpoint creates a monitoring endpoint for telemetry
func (*ExplorerAgent) SendLog ¶ added in v1.0.0
func (t *ExplorerAgent) SendLog(log []byte)
SendLog sends a telemetry log to the explorer
type IngressAgent ¶ added in v1.0.0
type IngressAgent struct {
// contains filtered or unexported fields
}
func NewIngressAgent ¶ added in v1.0.0
func NewIngressAgent(telemetryIngressClient synchronization.TelemetryIngressClient, contractID string) *IngressAgent
func (*IngressAgent) SendLog ¶ added in v1.0.0
func (t *IngressAgent) SendLog(telemetry []byte)
SendLog sends a telemetry log to the ingress server
type IngressAgentBatch ¶ added in v1.2.0
type IngressAgentBatch struct {
// contains filtered or unexported fields
}
IngressAgentBatch allows for sending batch telemetry for a given contractID
func NewIngressAgentBatch ¶ added in v1.2.0
func NewIngressAgentBatch(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient, contractID string) *IngressAgentBatch
NewIngressAgentBatch creates a new IngressAgentBatch with the given batch client and contractID
func (*IngressAgentBatch) SendLog ¶ added in v1.2.0
func (t *IngressAgentBatch) SendLog(telemetry []byte)
SendLog sends a telemetry log to the ingress server
type IngressAgentBatchWrapper ¶ added in v1.2.0
type IngressAgentBatchWrapper struct {
// contains filtered or unexported fields
}
IngressAgentBatchWrapper provides monitoring endpoint generation for the telemetry batch client
func NewIngressAgentBatchWrapper ¶ added in v1.2.0
func NewIngressAgentBatchWrapper(telemetryIngressBatchClient synchronization.TelemetryIngressBatchClient) *IngressAgentBatchWrapper
NewIngressAgentBatchWrapper creates a new IngressAgentBatchWrapper with the provided telemetry batch client
func (*IngressAgentBatchWrapper) GenMonitoringEndpoint ¶ added in v1.2.0
func (t *IngressAgentBatchWrapper) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint
GenMonitoringEndpoint returns a new ingress batch agent instantiated with the batch client and a contractID
type IngressAgentWrapper ¶ added in v1.0.0
type IngressAgentWrapper struct {
// contains filtered or unexported fields
}
func NewIngressAgentWrapper ¶ added in v1.0.0
func NewIngressAgentWrapper(telemetryIngressClient synchronization.TelemetryIngressClient) *IngressAgentWrapper
func (*IngressAgentWrapper) GenMonitoringEndpoint ¶ added in v1.0.0
func (t *IngressAgentWrapper) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint
type MonitoringEndpointGenerator ¶ added in v1.0.0
type MonitoringEndpointGenerator interface {
GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint
}
type NoopAgent ¶
type NoopAgent struct {
}
func (*NoopAgent) GenMonitoringEndpoint ¶ added in v1.0.0
func (t *NoopAgent) GenMonitoringEndpoint(contractID string) ocrtypes.MonitoringEndpoint
GenMonitoringEndpoint creates a monitoring endpoint for telemetry
Source Files