announce

Documentation

Overview

network announcements

Index

• Constants
• func AddPeer(publicKey []byte, listeners []byte, timestamp uint64) bool
• func AddRPC(fingerprint []byte, rpcs []byte, timestamp uint64) bool
• func Finalise() error
• func GetNext(publicKey []byte) ([]byte, []byte, time.Time, error)
• func Initialise(nodesDomain, peerFile string) error
• func SendRegistration(client *zmqutil.Client, fn string) error
• func SetPeer(publicKey []byte, listeners []byte) error
• func SetRPC(fingerprint fingerprintType, rpcs []byte) error
• type PeerItem
  • func NewPeerItem(peer *peerEntry) *PeerItem
  • func (item PeerItem) MarshalText() ([]byte, error)
  • func (item *PeerItem) UnmarshalText(data []byte) error
• type PeerList
• type RPCEntry
  • func FetchRPCs(start uint64, count int) ([]RPCEntry, uint64, error)

Constants

const (
	TypeRPC  = iota
	TypePeer = iota
)

type of listener

Functions

func AddPeer

func AddPeer(publicKey []byte, listeners []byte, timestamp uint64) bool

add a peer announcement to the in-memory tree returns:

true  if this was a new/updated entry
false if the update was within the limits (to prevent continuous relaying)

func AddRPC

func AddRPC(fingerprint []byte, rpcs []byte, timestamp uint64) bool

add an remote RPC listener returns:

true  if this was a new/updated entry
false if the update was within the limits (to prevent continuous relaying)

func Finalise

func Finalise() error

finialise - stop all background tasks

func GetNext

func GetNext(publicKey []byte) ([]byte, []byte, time.Time, error)

fetch the data for the next node in the ring for a given public key

func Initialise

func Initialise(nodesDomain, peerFile string) error

initialise the announcement system pass a fully qualified domain for root node list or empty string for no root nodes

func SendRegistration

func SendRegistration(client *zmqutil.Client, fn string) error

send a peer registration request to a client channel

func SetPeer

func SetPeer(publicKey []byte, listeners []byte) error

called by the peering initialisation to set up this node's announcement data

func SetRPC

func SetRPC(fingerprint fingerprintType, rpcs []byte) error

set this node's rpc announcement data

Types

type PeerItem

type PeerItem struct {
	PublicKey  []byte
	Broadcasts []byte
	Listeners  []byte
	Timestamp  uint64
}

PeerItem is the basic structure for backup and restore peers

func NewPeerItem

func NewPeerItem(peer *peerEntry) *PeerItem

NewPeerItem is to create a PeerItem from peerEntry

func (PeerItem) MarshalText

func (item PeerItem) MarshalText() ([]byte, error)

MarshalText is the json marshal function for PeerItem

func (*PeerItem) UnmarshalText

func (item *PeerItem) UnmarshalText(data []byte) error

UnmarshalText is the json unmarshal function for PeerItem

type PeerList

type PeerList []PeerItem

PeerList is a list of PeerItem

type RPCEntry

type RPCEntry struct {
	Fingerprint fingerprintType    `json:"fingerprint"`
	Connections []*util.Connection `json:"connections"`
}

type of returned data

func FetchRPCs

func FetchRPCs(start uint64, count int) ([]RPCEntry, uint64, error)

fetch some records