shim

Documentation

Overview

Package shim contains implementations of internal types in terms of the external types

Index

• type SerializingEndpoint
  • 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
  • func MakeTelemetrySender(chTelemetry chan<- *protobuf.TelemetryWrapper, logger commontypes.Logger) TelemetrySender
  • func (ts TelemetrySender) RoundStarted(configDigest types.ConfigDigest, epoch uint32, round uint8, ...)

Types

type SerializingEndpoint

type SerializingEndpoint struct {
	// contains filtered or unexported fields
}

func NewSerializingEndpoint

func NewSerializingEndpoint(
	chTelemetry chan<- *protobuf.TelemetryWrapper,
	configDigest types.ConfigDigest,
	endpoint commontypes.BinaryNetworkEndpoint,
	logger commontypes.Logger,
) *SerializingEndpoint

func (*SerializingEndpoint) Broadcast

func (n *SerializingEndpoint) Broadcast(msg protocol.Message)

func (*SerializingEndpoint) Close

func (n *SerializingEndpoint) Close() error

Close closes the SerializingEndpoint. It will also close the underlying endpoint.

func (*SerializingEndpoint) Receive

func (n *SerializingEndpoint) Receive() <-chan protocol.MessageWithSender

func (*SerializingEndpoint) SendTo

func (n *SerializingEndpoint) SendTo(msg protocol.Message, to commontypes.OracleID)

func (*SerializingEndpoint) Start

func (n *SerializingEndpoint) Start() error

Start starts the SerializingEndpoint. It will also start the underlying endpoint.

type TelemetrySender

type TelemetrySender struct {
	// contains filtered or unexported fields
}

func MakeTelemetrySender

func MakeTelemetrySender(chTelemetry chan<- *protobuf.TelemetryWrapper, logger commontypes.Logger) TelemetrySender

func (TelemetrySender) RoundStarted

func (ts TelemetrySender) RoundStarted(
	configDigest types.ConfigDigest,
	epoch uint32,
	round uint8,
	leader commontypes.OracleID,
)