connector

Documentation

Index

• type ConnectorConfig
• type ConnectorGatewayConfig
• type GatewayConnector
  • func NewGatewayConnector(config *ConnectorConfig, signer Signer, handler GatewayConnectorHandler, ...) (GatewayConnector, error)
• type GatewayConnectorHandler
• type Signer

Types

type ConnectorConfig

type ConnectorConfig struct {
	NodeAddress              string
	DonId                    string
	Gateways                 []ConnectorGatewayConfig
	WsClientConfig           network.WebSocketClientConfig
	MinHandshakeChallengeLen int
}

type ConnectorGatewayConfig

type ConnectorGatewayConfig struct {
	Id  string
	URL string
}

type GatewayConnector

type GatewayConnector interface {
	job.ServiceCtx
	network.ConnectionInitiator

	SendToGateway(ctx context.Context, gatewayId string, msg *api.Message) error
}

GatewayConnector is a component run by Nodes to connect to a set of Gateways.

func NewGatewayConnector

func NewGatewayConnector(config *ConnectorConfig, signer Signer, handler GatewayConnectorHandler, clock utils.Clock, lggr logger.Logger) (GatewayConnector, error)

type GatewayConnectorHandler

type GatewayConnectorHandler interface {
	job.ServiceCtx

	HandleGatewayMessage(gatewayId string, msg *api.Message)
}

type Signer

type Signer interface {
	// Sign keccak256 hash of data.
	Sign(data ...[]byte) ([]byte, error)
}