synchronization

package
v2.2.1-mercury-20230622 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 22, 2023 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ConnectionStatusDisconnected is the default state
	ConnectionStatusDisconnected = ConnectionStatus("disconnected")
	// ConnectionStatusConnected is used when the client is successfully connected
	ConnectionStatusConnected = ConnectionStatus("connected")
	// ConnectionStatusError is used when there is an error
	ConnectionStatusError = ConnectionStatus("error")
)
View Source
const (
	ExplorerTextMessage   = websocket.TextMessage
	ExplorerBinaryMessage = websocket.BinaryMessage
)
View Source
const SendBufferSize = 100

SendBufferSize is the number of messages to keep in the buffer before dropping additional ones

Variables

View Source
var (
	// ErrReceiveTimeout is returned when no message is received after a
	// specified duration in Receive
	ErrReceiveTimeout = errors.New("timeout waiting for message")
)

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 ConnectionStatus

type ConnectionStatus string

type ExplorerClient

type ExplorerClient interface {
	services.ServiceCtx
	Url() url.URL
	Status() ConnectionStatus
	Send(context.Context, []byte, ...int)
	Receive(context.Context, ...time.Duration) ([]byte, error)
}

ExplorerClient encapsulates all the functionality needed to push run information to explorer.

func NewExplorerClient

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

NewExplorerClient returns a stats pusher using a websocket for delivery.

type NoopExplorerClient

type NoopExplorerClient struct{}

func (NoopExplorerClient) Close

func (NoopExplorerClient) Close() error

Close is a no-op

func (NoopExplorerClient) HealthReport

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

func (NoopExplorerClient) Name

func (NoopExplorerClient) Name() string

func (NoopExplorerClient) Ready

func (NoopExplorerClient) Ready() error

Ready is a no-op

func (NoopExplorerClient) Receive

Receive is a no-op

func (NoopExplorerClient) Send

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

Send is a no-op

func (NoopExplorerClient) Start

Start is a no-op

func (NoopExplorerClient) Status

Status always returns ConnectionStatusDisconnected.

func (NoopExplorerClient) Url

func (NoopExplorerClient) Url() url.URL

Url always returns underlying url.

type NoopTelemetryIngressBatchClient

type NoopTelemetryIngressBatchClient struct{}

NoopTelemetryIngressBatchClient is a no-op interface for TelemetryIngressBatchClient

func (NoopTelemetryIngressBatchClient) Close

Close is a no-op

func (NoopTelemetryIngressBatchClient) HealthReport

func (NoopTelemetryIngressBatchClient) HealthReport() map[string]error

Healthy is a no-op

func (NoopTelemetryIngressBatchClient) Name

func (NoopTelemetryIngressBatchClient) Ready

Ready is a no-op

func (NoopTelemetryIngressBatchClient) Send

Send is a no-op

func (NoopTelemetryIngressBatchClient) Start

Start is a no-op

type NoopTelemetryIngressClient

type NoopTelemetryIngressClient struct{}

func (NoopTelemetryIngressClient) Close

Close is a no-op

func (NoopTelemetryIngressClient) HealthReport

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

func (NoopTelemetryIngressClient) Name

func (NoopTelemetryIngressClient) Ready

Ready is a no-op

func (NoopTelemetryIngressClient) Send

Send is a no-op

func (NoopTelemetryIngressClient) Start

Start is a no-op

type TelemPayload

type TelemPayload struct {
	Ctx        context.Context
	Telemetry  []byte
	TelemType  TelemetryType
	ContractID string
}

type TelemetryIngressBatchClient

type TelemetryIngressBatchClient interface {
	services.ServiceCtx
	Send(TelemPayload)
}

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

NewTelemetryIngressBatchClient returns a client backed by wsrpc that can send telemetry to the telemetry ingress server

type TelemetryIngressClient

type TelemetryIngressClient interface {
	services.ServiceCtx
	Send(TelemPayload)
}

TelemetryIngressClient encapsulates all the functionality needed to send telemetry to the ingress server using wsrpc

func NewTelemetryIngressClient

func NewTelemetryIngressClient(url *url.URL, serverPubKeyHex string, ks keystore.CSA, logging bool, lggr logger.Logger, telemBufferSize uint) TelemetryIngressClient

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"
	OCR2Median        TelemetryType = "ocr2-median"
	OCR3Mercury       TelemetryType = "ocr3-mercury"
	OCR2VRF           TelemetryType = "ocr2-vrf"
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL