orchestrator

Oct 13, 2022

Changes in this version

+ type CorruptedConnector struct

+ func NewCorruptedConnector(logger zerolog.Logger, corruptedNodeIds flow.IdentityList, ...) *CorruptedConnector

+ func (c *CorruptedConnector) Connect(ctx irrecoverable.SignalerContext, targetId flow.Identifier) (insecure.CorruptedNodeConnection, error)

+ func (c *CorruptedConnector) WithIncomingMessageHandler(handler func(*insecure.Message))

+ type CorruptedNodeConnection struct

+ func NewCorruptedNodeConnection(logger zerolog.Logger, inboundHandler func(message *insecure.Message), ...) *CorruptedNodeConnection

+ func (c *CorruptedNodeConnection) CloseConnection() error

+ func (c *CorruptedNodeConnection) SendMessage(message *insecure.Message) error

+ type Network struct

+ func NewOrchestratorNetwork(logger zerolog.Logger, codec network.Codec, ...) (*Network, error)

+ func (on *Network) Observe(message *insecure.Message)

+ func (on *Network) SendEgress(event *insecure.EgressEvent) error

+ func (on *Network) SendIngress(event *insecure.IngressEvent) error