announce

Documentation

Overview

network announcements

Index

• Constants
• func AddPeer(publicKey []byte, broadcasts []byte, listeners []byte) bool
• func AddRPC(fingerprint []byte, rpcs []byte) bool
• func Finalise() error
• func GetNext(publicKey []byte) ([]byte, []byte, []byte, error)
• func Initialise(nodesDomain string) error
• func SendRegistration(client *zmqutil.Client, fn string) error
• func SetPeer(publicKey []byte, broadcasts []byte, listeners []byte) error
• func SetRPC(fingerprint fingerprintType, rpcs []byte) error
• 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, broadcasts []byte, listeners []byte) 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) 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, []byte, error)

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

func Initialise

func Initialise(nodesDomain string) error

initialise the announcement system pass a fuklly 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, broadcasts []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 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