Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + type SerializingEndpoint struct + func NewSerializingEndpoint(chTelemetry chan<- *protobuf.TelemetryWrapper, configDigest types.ConfigDigest, ...) *SerializingEndpoint + func (n *SerializingEndpoint) Broadcast(msg protocol.Message) + func (n *SerializingEndpoint) Close() error + func (n *SerializingEndpoint) Receive() <-chan protocol.MessageWithSender + func (n *SerializingEndpoint) SendTo(msg protocol.Message, to commontypes.OracleID) + func (n *SerializingEndpoint) Start() error + type TelemetrySender struct + func MakeTelemetrySender(chTelemetry chan<- *protobuf.TelemetryWrapper, logger commontypes.Logger) TelemetrySender + func (ts TelemetrySender) RoundStarted(configDigest types.ConfigDigest, epoch uint32, round uint8, ...)
Go to main page