datasync

Documentation

Index

• Variables
• func CalculateSendTime(count uint64, time int64) int64
• func ToGroupID(data []byte) state.GroupID
• func ToOneToOneGroupID(key1 *ecdsa.PublicKey, key2 *ecdsa.PublicKey) state.GroupID
• type DataSync
  • func New(node *datasyncnode.Node, transport *NodeTransport, sendingEnabled bool, ...) *DataSync
  • func (d *DataSync) Stop()
  • func (d *DataSync) UnwrapPayloadsAndAcks(sender *ecdsa.PublicKey, payload []byte) ([][]byte, [][]byte, error)
• type NodeTransport
  • func NewNodeTransport() *NodeTransport
  • func (t *NodeTransport) AddPacket(p transport.Packet)
  • func (t *NodeTransport) Init(...)
  • func (t *NodeTransport) Send(_ state.PeerID, peer state.PeerID, payload protobuf.Payload) error
  • func (t *NodeTransport) Watch() transport.Packet

Variables

var DatasyncTicker = 300 * time.Millisecond

Functions

func CalculateSendTime

func CalculateSendTime(count uint64, time int64) int64

CalculateSendTime calculates the next epoch at which a message should be sent. We randomize it a bit so that not all messages are sent on the same epoch

func ToGroupID

func ToGroupID(data []byte) state.GroupID

func ToOneToOneGroupID

func ToOneToOneGroupID(key1 *ecdsa.PublicKey, key2 *ecdsa.PublicKey) state.GroupID

ToOneToOneGroupID returns a groupID for a onetoonechat, which is taken by concatenating the bytes of the compressed keys, in ascending order by X

Types

type DataSync

type DataSync struct {
	*datasyncnode.Node
	// NodeTransport is the implementation of the datasync transport interface.
	*NodeTransport
	// contains filtered or unexported fields
}

func New

func New(node *datasyncnode.Node, transport *NodeTransport, sendingEnabled bool, logger *zap.Logger) *DataSync

func (*DataSync) Stop

func (d *DataSync) Stop()

func (*DataSync) UnwrapPayloadsAndAcks

func (d *DataSync) UnwrapPayloadsAndAcks(sender *ecdsa.PublicKey, payload []byte) ([][]byte, [][]byte, error)

UnwrapPayloadsAndAcks tries to unwrap datasync message and return messages payloads and acknowledgements for previously sent messages

type NodeTransport

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

func NewNodeTransport

func NewNodeTransport() *NodeTransport

func (*NodeTransport) AddPacket

func (t *NodeTransport) AddPacket(p transport.Packet)

func (*NodeTransport) Init

func (t *NodeTransport) Init(dispatch func(context.Context, *ecdsa.PublicKey, []byte, *protobuf.Payload) error, maxMessageSize uint32, logger *zap.Logger)

func (*NodeTransport) Send

func (t *NodeTransport) Send(_ state.PeerID, peer state.PeerID, payload protobuf.Payload) error

func (*NodeTransport) Watch

func (t *NodeTransport) Watch() transport.Packet