Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectorConfig ¶
type ConnectorConfig struct {
NodeAddress string
DonId string
Gateways []ConnectorGatewayConfig
WsClientConfig network.WebSocketClientConfig
AuthMinChallengeLen int
AuthTimestampToleranceSec uint32
}
type ConnectorGatewayConfig ¶
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(ctx context.Context, gatewayId string, msg *api.Message)
}
GatewayConnector user (node) implements application logic in the Handler interface.
Click to show internal directories.
Click to hide internal directories.