Documentation
¶
Index ¶
- func NewTelemetryIngressBatchWorker(telemMaxBatchSize uint, telemSendInterval time.Duration, ...) *telemetryIngressBatchWorker
- type NoopTelemetryIngressBatchClient
- func (NoopTelemetryIngressBatchClient) Close() error
- func (NoopTelemetryIngressBatchClient) HealthReport() map[string]error
- func (NoopTelemetryIngressBatchClient) Name() string
- func (NoopTelemetryIngressBatchClient) Ready() error
- func (NoopTelemetryIngressBatchClient) Send(TelemPayload)
- func (NoopTelemetryIngressBatchClient) Start(context.Context) error
- type NoopTelemetryIngressClient
- func (NoopTelemetryIngressClient) Close() error
- func (NoopTelemetryIngressClient) HealthReport() map[string]error
- func (NoopTelemetryIngressClient) Name() string
- func (NoopTelemetryIngressClient) Ready() error
- func (NoopTelemetryIngressClient) Send(context.Context, TelemPayload)
- func (NoopTelemetryIngressClient) Start(context.Context) error
- type TelemPayload
- type TelemetryService
- type TelemetryType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTelemetryIngressBatchWorker ¶
func NewTelemetryIngressBatchWorker( telemMaxBatchSize uint, telemSendInterval time.Duration, telemSendTimeout time.Duration, telemClient telemPb.TelemClient, wgDone *sync.WaitGroup, chDone chan struct{}, chTelemetry chan TelemPayload, contractID string, telemType TelemetryType, globalLogger logger.Logger, logging bool, ) *telemetryIngressBatchWorker
NewTelemetryIngressBatchWorker returns a worker for a given contractID that can send telemetry to the ingress server via WSRPC
Types ¶
type NoopTelemetryIngressBatchClient ¶
type NoopTelemetryIngressBatchClient struct{}
NoopTelemetryIngressBatchClient is a no-op interface for TelemetryIngressBatchClient
func (NoopTelemetryIngressBatchClient) Close ¶
func (NoopTelemetryIngressBatchClient) Close() error
Close is a no-op
func (NoopTelemetryIngressBatchClient) HealthReport ¶
func (NoopTelemetryIngressBatchClient) HealthReport() map[string]error
func (NoopTelemetryIngressBatchClient) Name ¶
func (NoopTelemetryIngressBatchClient) Name() string
func (NoopTelemetryIngressBatchClient) Ready ¶
func (NoopTelemetryIngressBatchClient) Ready() error
Ready is a no-op
func (NoopTelemetryIngressBatchClient) Send ¶
func (NoopTelemetryIngressBatchClient) Send(TelemPayload)
Send is a no-op
type NoopTelemetryIngressClient ¶
type NoopTelemetryIngressClient struct{}
func (NoopTelemetryIngressClient) Close ¶
func (NoopTelemetryIngressClient) Close() error
Close is a no-op
func (NoopTelemetryIngressClient) HealthReport ¶
func (NoopTelemetryIngressClient) HealthReport() map[string]error
func (NoopTelemetryIngressClient) Name ¶
func (NoopTelemetryIngressClient) Name() string
func (NoopTelemetryIngressClient) Ready ¶
func (NoopTelemetryIngressClient) Ready() error
Ready is a no-op
func (NoopTelemetryIngressClient) Send ¶
func (NoopTelemetryIngressClient) Send(context.Context, TelemPayload)
Send is a no-op
type TelemPayload ¶
type TelemPayload struct {
Telemetry []byte
TelemType TelemetryType
ContractID string
}
type TelemetryService ¶ added in v2.7.0
type TelemetryService interface {
services.ServiceCtx
Send(ctx context.Context, telemetry []byte, contractID string, telemType TelemetryType)
}
TelemetryService encapsulates all the functionality needed to send telemetry to the ingress server using wsrpc
func NewTelemetryIngressBatchClient ¶
func NewTelemetryIngressBatchClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, lggr logger.Logger, telemBufferSize uint, telemMaxBatchSize uint, telemSendInterval time.Duration, telemSendTimeout time.Duration, useUniconn bool, network string, chainID string) TelemetryService
NewTelemetryIngressBatchClient returns a client backed by wsrpc that can send telemetry to the telemetry ingress server
func NewTelemetryIngressClient ¶
func NewTelemetryIngressClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, lggr logger.Logger, telemBufferSize uint, network string, chainID string) TelemetryService
NewTelemetryIngressClient returns a client backed by wsrpc that can send telemetry to the telemetry ingress server
type TelemetryType ¶
type TelemetryType string
TelemetryType defines supported telemetry types
const ( EnhancedEA TelemetryType = "enhanced-ea" FunctionsRequests TelemetryType = "functions-requests" EnhancedEAMercury TelemetryType = "enhanced-ea-mercury" OCR TelemetryType = "ocr" OCR2Automation TelemetryType = "ocr2-automation" OCR2Functions TelemetryType = "ocr2-functions" OCR2Threshold TelemetryType = "ocr2-threshold" OCR2S4 TelemetryType = "ocr2-s4" OCR2Median TelemetryType = "ocr2-median" OCR3Mercury TelemetryType = "ocr3-mercury" OCR2VRF TelemetryType = "ocr2-vrf" AutomationCustom TelemetryType = "automation-custom" OCR3Automation TelemetryType = "ocr3-automation" )
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.