upstream

Documentation

Overview

maintain REQ/REP connection to clients this allow for push of blocks, transactions... as well as polling for out of sync conditions

Index

• type Upstream
  • func New(privateKey []byte, publicKey []byte, timeout time.Duration) (*Upstream, error)
  • func (u *Upstream) Connect(address *util.Connection, serverPublicKey []byte) error
  • func (u *Upstream) ConnectedTo() *zmqutil.Connected
  • func (u *Upstream) Destroy()
  • func (u *Upstream) GetBlockData(blockNumber uint64) ([]byte, error)
  • func (u *Upstream) GetBlockDigest(blockNumber uint64) (blockdigest.Digest, error)
  • func (u *Upstream) GetHeight() uint64
  • func (u *Upstream) IsConnectedTo(serverPublicKey []byte) bool
  • func (u *Upstream) IsOK() bool

Types

type Upstream

type Upstream struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(privateKey []byte, publicKey []byte, timeout time.Duration) (*Upstream, error)

func (*Upstream) Connect

func (u *Upstream) Connect(address *util.Connection, serverPublicKey []byte) error

connect (or reconnect) to a specific server

func (*Upstream) ConnectedTo

func (u *Upstream) ConnectedTo() *zmqutil.Connected

if registered the have avalid connection

func (*Upstream) Destroy

func (u *Upstream) Destroy()

func (*Upstream) GetBlockData

func (u *Upstream) GetBlockData(blockNumber uint64) ([]byte, error)

fetch block data

func (*Upstream) GetBlockDigest

func (u *Upstream) GetBlockDigest(blockNumber uint64) (blockdigest.Digest, error)

fetch block digest

func (*Upstream) GetHeight

func (u *Upstream) GetHeight() uint64

fetch height from last polled value

func (*Upstream) IsConnectedTo

func (u *Upstream) IsConnectedTo(serverPublicKey []byte) bool

check the current destination

does not mean actually connected, as could be in a timeout and reconnect state

func (*Upstream) IsOK

func (u *Upstream) IsOK() bool

if registered the have avalid connection