synchronization

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
  • func NewTelemetryIngressBatchClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, ...) TelemetryService
  • func NewTelemetryIngressClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, ...) TelemetryService
• type TelemetryType

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

func (NoopTelemetryIngressBatchClient) Start

func (NoopTelemetryIngressBatchClient) Start(context.Context) error

Start 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

func (NoopTelemetryIngressClient) Start

func (NoopTelemetryIngressClient) Start(context.Context) error

Start is a no-op

type TelemPayload

type TelemPayload struct {
	Telemetry  []byte
	TelemType  TelemetryType
	ContractID string
}

type TelemetryService

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) 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) 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"
)