net

Documentation

Index

• Constants
• func Server(srv *context.T)
• type GitchainApp
  • func (app *GitchainApp) OnDeliver(msg wendy.Message)
  • func (app *GitchainApp) OnError(err error)
  • func (app *GitchainApp) OnForward(msg *wendy.Message, next wendy.NodeID) bool
  • func (app *GitchainApp) OnHeartbeat(node wendy.Node)
  • func (app *GitchainApp) OnNewLeaves(leaves []*wendy.Node)
  • func (app *GitchainApp) OnNodeExit(node wendy.Node)
  • func (app *GitchainApp) OnNodeJoin(node wendy.Node)
• type HashableEncodable
• type KeyAuth
  • func (a *KeyAuth) Marshal() []byte
  • func (*KeyAuth) Valid(b []byte) bool

Constants

const (
	MSG_BROADCAST   byte = 0x80
	MSG_REGULAR     byte = 0x40
	MSG_REPLY       byte = MSG_BROADCAST | MSG_REGULAR
	MSG_TRANSACTION byte = 0x01
	MSG_OBJECT      byte = 0x02
)

Functions

func Server

func Server(srv *context.T)

Types

type GitchainApp

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

func (*GitchainApp) OnDeliver

func (app *GitchainApp) OnDeliver(msg wendy.Message)

func (*GitchainApp) OnError

func (app *GitchainApp) OnError(err error)

func (*GitchainApp) OnForward

func (app *GitchainApp) OnForward(msg *wendy.Message, next wendy.NodeID) bool

func (*GitchainApp) OnHeartbeat

func (app *GitchainApp) OnHeartbeat(node wendy.Node)

func (*GitchainApp) OnNewLeaves

func (app *GitchainApp) OnNewLeaves(leaves []*wendy.Node)

func (*GitchainApp) OnNodeExit

func (app *GitchainApp) OnNodeExit(node wendy.Node)

func (*GitchainApp) OnNodeJoin

func (app *GitchainApp) OnNodeJoin(node wendy.Node)

type HashableEncodable

type HashableEncodable interface {
	Hash() types.Hash
	Encode() ([]byte, error)
}

type KeyAuth

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

func (*KeyAuth) Marshal

func (a *KeyAuth) Marshal() []byte

func (*KeyAuth) Valid

func (*KeyAuth) Valid(b []byte) bool