network

Feb 22, 2019

Changes in this version

type BootstrapResult

+ DiscoveryCount int

+ type Rules interface

+ CheckMajorityRule func() (bool, int)

+ CheckMinRole func() bool

Feb 20, 2019

Changes in this version

+ type BootstrapResult struct

+ Host *host.Host

+ ReconnectRequired bool

type ConsensusNetwork

+ RegisterPacketHandler func(t consensus.PacketType, handler ConsensusPacketHandler)

+ SignAndSendPacket func(packet consensus.ConsensusPacket, receiver core.RecordRef, ...) error

+ type ConsensusPacketHandler func(incomingPacket consensus.ConsensusPacket, sender core.RecordRef)

+ type MergedListCopy struct

+ ActiveList map[core.RecordRef]core.Node

+ NodesJoinedDuringPrevPulse bool

type NodeKeeper

+ AddTemporaryMapping func(nodeID core.RecordRef, shortID core.ShortNodeID, address string) error

+ GetActiveNode func(ref core.RecordRef) core.Node

+ GetActiveNodes func() []core.Node

+ GetCloudHash func() []byte

+ GetOriginAnnounceClaim func(mapper consensus.BitSetMapper) (*consensus.NodeAnnounceClaim, error)

+ GetOriginJoinClaim func() (*consensus.NodeJoinClaim, error)

+ ResolveConsensus func(shortID core.ShortNodeID) *host.Host

+ ResolveConsensusRef func(nodeID core.RecordRef) *host.Host

type RoutingTable

+ ResolveConsensus func(core.ShortNodeID) (*host.Host, error)

+ ResolveConsensusRef func(core.RecordRef) (*host.Host, error)

type UnsyncList

+ AddNode func(node core.Node, bitsetIndex uint16)

+ AddProof func(nodeID core.RecordRef, proof *consensus.NodePulseProof)

+ ApproveSync func([]core.RecordRef)

+ GetClaims func(nodeID core.RecordRef) []consensus.ReferendumClaim

+ GetGlobuleHashSignature func(ref core.RecordRef) (consensus.GlobuleHashSignature, bool)

+ GetMergedCopy func() (*MergedListCopy, error)

+ GetProof func(nodeID core.RecordRef) *consensus.NodePulseProof

+ RemoveNode func(nodeID core.RecordRef)

+ SetGlobuleHashSignature func(core.RecordRef, consensus.GlobuleHashSignature)

Jan 29, 2019

Changes in this version

type Controller

+ GetLastIgnoredPulse func() core.PulseNumber

+ SetLastIgnoredPulse func(number core.PulseNumber)

type Packet

+ GetRequestID func() RequestID

+ type RequestID uint64

type UnsyncList

+ GetActiveNode func(ref core.RecordRef) core.Node

+ GetActiveNodes func() []core.Node

Nov 30, 2018

Changes in this version

+ type ClaimQueue interface

+ Front func() consensus.ReferendumClaim

+ Length func() int

+ Pop func() consensus.ReferendumClaim

+ type ConsensusNetwork interface

+ GetNodeID func() core.RecordRef

+ NewRequestBuilder func() RequestBuilder

+ PublicAddress func() string

+ RegisterRequestHandler func(t types.PacketType, handler ConsensusRequestHandler)

+ SendRequest func(request Request, receiver core.RecordRef) error

+ Start func(ctx context.Context)

+ Stop func()

+ type ConsensusRequestHandler func(Request)

type HostNetwork

+ GetNodeID func() core.RecordRef

+ type InternalTransport interface

+ BuildResponse func(request Request, responseData interface{}) Response

+ GetNodeID func() core.RecordRef

+ NewRequestBuilder func() RequestBuilder

+ PublicAddress func() string

+ RegisterPacketHandler func(t types.PacketType, handler RequestHandler)

+ SendRequestPacket func(request Request, receiver *host.Host) (Future, error)

+ Start func(ctx context.Context)

+ Stop func()

type NodeKeeper

+ AddPendingClaim func(consensus.ReferendumClaim) bool

+ GetActiveNodeByShortID func(shortID core.ShortNodeID) core.Node

+ GetClaimQueue func() ClaimQueue

+ GetOriginClaim func() *consensus.NodeJoinClaim

+ GetSparseUnsyncList func(length int) UnsyncList

+ GetState func() NodeKeeperState

+ GetUnsyncList func() UnsyncList

+ MoveSyncToActive func()

+ NodesJoinedDuringPreviousPulse func() bool

+ SetCloudHash func([]byte)

+ SetOriginClaim func(*consensus.NodeJoinClaim)

+ SetState func(NodeKeeperState)

+ type NodeKeeperState uint8

+ const Ready

+ const Undefined

+ const Waiting

+ type PartitionPolicy interface

+ ShardsCount func() int

+ type PulseHandler interface

+ HandlePulse func(ctx context.Context, pulse core.Pulse)

+ type RoutingTable interface

+ AddToKnownHosts func(*host.Host)

+ GetRandomNodes func(count int) []host.Host

+ Inject func(nodeKeeper NodeKeeper)

+ Rebalance func(PartitionPolicy)

+ Resolve func(core.RecordRef) (*host.Host, error)

+ ResolveS func(core.ShortNodeID) (*host.Host, error)

type UnsyncList

+ AddClaims func(from core.RecordRef, claims []consensus.ReferendumClaim)

+ CalculateHash func() ([]byte, error)

+ RemoveClaims func(from core.RecordRef)

Nov 1, 2018

Changes in this version

+ type Controller interface

+ AnalyzeNetwork func() error

+ Authorize func() error

+ Bootstrap func() error

+ GetNodeID func() core.RecordRef

+ Inject func(components core.Components)

+ RemoteProcedureRegister func(name string, method core.RemoteProcedure)

+ ResendPulseToKnownHosts func(pulse core.Pulse)

+ SendCascadeMessage func(data core.Cascade, method string, msg core.SignedMessage) error

+ SendMessage func(nodeID core.RecordRef, name string, msg core.SignedMessage) ([]byte, error)

+ type Future interface

+ GetRequest func() Request

+ GetResponse func(duration time.Duration) (Response, error)

+ Response func() <-chan Response

+ type HostNetwork interface

+ BuildResponse func(request Request, responseData interface{}) Response

+ NewRequestBuilder func() RequestBuilder

+ PublicAddress func() string

+ RegisterRequestHandler func(t types.PacketType, handler RequestHandler)

+ SendRequest func(request Request, receiver core.RecordRef) (Future, error)

+ Start func()

+ Stop func()

+ type NodeKeeper interface

+ AddActiveNodes func([]*core.Node)

+ AddUnsync func(nodeID core.RecordRef, roles []core.NodeRole, address string, version string) (chan *core.Node, error)

+ GetUnsyncHolder func(pulse core.PulseNumber, duration time.Duration) (UnsyncList, error)

+ SetPulse func(number core.PulseNumber) (bool, UnsyncList)

+ Sync func(syncCandidates []*core.Node, number core.PulseNumber)

+ type NodeUnsyncHash struct

+ Hash []byte

+ NodeID core.RecordRef

+ type OnPulse func(pulse core.Pulse)

+ type Packet interface

+ GetData func() interface{}

+ GetSender func() core.RecordRef

+ GetSenderHost func() *host.Host

+ GetType func() types.PacketType

+ type Request Packet

+ type RequestBuilder interface

+ Build func() Request

+ Data func(data interface{}) RequestBuilder

+ Type func(packetType types.PacketType) RequestBuilder

+ type RequestHandler func(Request) (Response, error)

+ type Response Packet

+ type UnsyncList interface

+ AddUnsyncHash func(ref core.RecordRef, hash []*NodeUnsyncHash)

+ AddUnsyncList func(ref core.RecordRef, unsync []*core.Node)

+ GetHash func(blockTimeout time.Duration) ([]*NodeUnsyncHash, error)

+ GetPulse func() core.PulseNumber

+ GetUnsync func() []*core.Node

+ GetUnsyncHash func(ref core.RecordRef) ([]*NodeUnsyncHash, bool)

+ GetUnsyncList func(ref core.RecordRef) ([]*core.Node, bool)

+ SetHash func([]*NodeUnsyncHash)