synchronization

Jan 24, 2024

Changes in this version

type TelemetryType

+ const OCR3Automation

Nov 14, 2023

Changes in this version

+ type TelemetryService interface

+ Send func(ctx context.Context, telemetry []byte, contractID string, ...)

Aug 21, 2023

Changes in this version

type TelemetryType

+ const AutomationCustom

+ const OCR2S4

+ const OCR2Threshold

Jul 28, 2023

Changes in this version

type TelemetryType

+ const OCR3Mercury

Jun 12, 2023

Changes in this version

type TelemetryType

+ const EnhancedEAMercury

+ const FunctionsRequests

Apr 21, 2023

Changes in this version

+ const ConnectionStatusConnected

+ const ConnectionStatusDisconnected

+ const ConnectionStatusError

+ const ExplorerBinaryMessage

+ const ExplorerTextMessage

+ const SendBufferSize

+ var ErrReceiveTimeout = errors.New("timeout waiting for message")

+ func NewTelemetryIngressBatchWorker(telemMaxBatchSize uint, telemSendInterval time.Duration, ...) *telemetryIngressBatchWorker

+ type ConnectionStatus string

+ type ExplorerClient interface

+ Receive func(context.Context, ...time.Duration) ([]byte, error)

+ Send func(context.Context, []byte, ...int)

+ Status func() ConnectionStatus

+ Url func() url.URL

+ func NewExplorerClient(url *url.URL, accessKey, secret string, lggr logger.Logger) ExplorerClient

+ type NoopExplorerClient struct

+ func (NoopExplorerClient) Close() error

+ func (NoopExplorerClient) HealthReport() map[string]error

+ func (NoopExplorerClient) Name() string

+ func (NoopExplorerClient) Ready() error

+ func (NoopExplorerClient) Receive(context.Context, ...time.Duration) ([]byte, error)

+ func (NoopExplorerClient) Send(context.Context, []byte, ...int)

+ func (NoopExplorerClient) Start(context.Context) error

+ func (NoopExplorerClient) Status() ConnectionStatus

+ func (NoopExplorerClient) Url() url.URL

+ type NoopTelemetryIngressBatchClient struct

+ 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 struct

+ func (NoopTelemetryIngressClient) Close() error

+ func (NoopTelemetryIngressClient) HealthReport() map[string]error

+ func (NoopTelemetryIngressClient) Name() string

+ func (NoopTelemetryIngressClient) Ready() error

+ func (NoopTelemetryIngressClient) Send(TelemPayload)

+ func (NoopTelemetryIngressClient) Start(context.Context) error

+ type TelemPayload struct

+ ContractID string

+ Ctx context.Context

+ TelemType TelemetryType

+ Telemetry []byte

+ type TelemetryIngressBatchClient interface

+ Send func(TelemPayload)

+ func NewTelemetryIngressBatchClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, ...) TelemetryIngressBatchClient

+ type TelemetryIngressClient interface

+ Send func(TelemPayload)

+ func NewTelemetryIngressClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, ...) TelemetryIngressClient

+ type TelemetryType string

+ const EnhancedEA

+ const OCR

+ const OCR2Automation

+ const OCR2Functions

+ const OCR2Median

+ const OCR2Mercury

+ const OCR2VRF