datasync

package

v0.0.15 Latest Latest Go to latest Published: Aug 7, 2019 License: MPL-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/status-im/status-protocol-go

Links

Open Source Insights

Documentation ¶

Index ¶

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 *DataSyncNodeTransport, sendingEnabled bool, ...) *DataSync
type DataSyncNodeTransport
- func NewDataSyncNodeTransport() *DataSyncNodeTransport

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CalculateSendTime ¶

func CalculateSendTime(count uint64, time int64) int64

CalculateSendTime calculates the next epoch at which a message should be sent.

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
	// DataSyncNodeTransport is the implemntation of the datasync transport interface
	*DataSyncNodeTransport
	// contains filtered or unexported fields
}

func New ¶

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

func (*DataSync) Add ¶

func (d *DataSync) Add(publicKey *ecdsa.PublicKey, datasyncMessage datasyncproto.Payload)

func (*DataSync) Handle ¶

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

func (*DataSync) Stop ¶

func (d *DataSync) Stop()

type DataSyncNodeTransport ¶

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

func NewDataSyncNodeTransport ¶

func NewDataSyncNodeTransport() *DataSyncNodeTransport

func (*DataSyncNodeTransport) AddPacket ¶

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

func (*DataSyncNodeTransport) Init ¶

func (t *DataSyncNodeTransport) Init(dispatch func(context.Context, *ecdsa.PublicKey, []byte, *protobuf.Payload) error)

func (*DataSyncNodeTransport) Send ¶

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

func (*DataSyncNodeTransport) Watch ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
peer

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL