subnet

Documentation

Index

• Constants
• Variables
• type MemberStatus
• type Offline
• type SubNet
  • func NewSubNet(acc *account.Account, seeds *utils.HostsResolver, gov utils.GovNodeResolver, ...) *SubNet
  • func (self *SubNet) Broadcast(net p2p.P2P, msg types.Message)
  • func (self *SubNet) GetMaskAddrFilter() p2p.AddressFilter
  • func (self *SubNet) GetMembersInfo() []common.SubnetMemberInfo
  • func (self *SubNet) GetOfflineVotes() []*types.OfflineWitnessMsg
  • func (self *SubNet) GetReservedAddrFilter(staticFilterEnabled bool) p2p.AddressFilter
  • func (self *SubNet) IpInMembers(ip string) bool
  • func (self *SubNet) IsSeedNode() bool
  • func (self *SubNet) OnAddPeer(net p2p.P2P, info *peer.PeerInfo)
  • func (self *SubNet) OnDelPeer(info *peer.PeerInfo)
  • func (self *SubNet) OnHostAddrDetected(listenAddr string)
  • func (self *SubNet) OnMembersRequest(ctx *p2p.Context, msg *types.SubnetMembersRequest)
  • func (self *SubNet) OnMembersResponse(ctx *p2p.Context, msg *types.SubnetMembers)
  • func (self *SubNet) OnOfflineWitnessMsg(ctx *p2p.Context, msg *types.OfflineWitnessMsg)
  • func (self *SubNet) ProposeOffline(nodes []string) error
  • func (self *SubNet) Start(net p2p.P2P)
  • func (self *SubNet) Stop()
• type SubNetMaskAddrFilter
  • func (self *SubNetMaskAddrFilter) Contains(addr string) bool
• type SubNetReservedAddrFilter
  • func (self *SubNetReservedAddrFilter) Contains(addr string) bool
• type WitnessStatus

Constants

const DelayUpdateMsgTime = 5 * time.Second

const ExpireOfflineMsgTime = uint32(2 * time.Hour / time.Second)

const MIN_VERSION_FOR_SUBNET = "2.0.0-0"

const MaxInactiveTime = 10 * time.Minute

const MaxMemberRequests = 3

const MinProposeDuration = uint32(1 * time.Hour / time.Second)

Variables

var RefreshDuration = 1 * time.Minute

Types

type MemberStatus

type MemberStatus struct {
	PubKey string
	Alive  time.Time
}

type Offline

type Offline struct {
	Status WitnessStatus
	Msg    *types.OfflineWitnessMsg
}

type SubNet

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

func NewSubNet

func NewSubNet(acc *account.Account, seeds *utils.HostsResolver,
	gov utils.GovNodeResolver, logger common.Logger) *SubNet

func (*SubNet) Broadcast

func (self *SubNet) Broadcast(net p2p.P2P, msg types.Message)

func (*SubNet) GetMaskAddrFilter

func (self *SubNet) GetMaskAddrFilter() p2p.AddressFilter

func (*SubNet) GetMembersInfo

func (self *SubNet) GetMembersInfo() []common.SubnetMemberInfo

restful api

func (*SubNet) GetOfflineVotes

func (self *SubNet) GetOfflineVotes() []*types.OfflineWitnessMsg

func (*SubNet) GetReservedAddrFilter

func (self *SubNet) GetReservedAddrFilter(staticFilterEnabled bool) p2p.AddressFilter

func (*SubNet) IpInMembers

func (self *SubNet) IpInMembers(ip string) bool

func (*SubNet) IsSeedNode

func (self *SubNet) IsSeedNode() bool

func (*SubNet) OnAddPeer

func (self *SubNet) OnAddPeer(net p2p.P2P, info *peer.PeerInfo)

func (*SubNet) OnDelPeer

func (self *SubNet) OnDelPeer(info *peer.PeerInfo)

func (*SubNet) OnHostAddrDetected

func (self *SubNet) OnHostAddrDetected(listenAddr string)

func (*SubNet) OnMembersRequest

func (self *SubNet) OnMembersRequest(ctx *p2p.Context, msg *types.SubnetMembersRequest)

func (*SubNet) OnMembersResponse

func (self *SubNet) OnMembersResponse(ctx *p2p.Context, msg *types.SubnetMembers)

func (*SubNet) OnOfflineWitnessMsg

func (self *SubNet) OnOfflineWitnessMsg(ctx *p2p.Context, msg *types.OfflineWitnessMsg)

func (*SubNet) ProposeOffline

func (self *SubNet) ProposeOffline(nodes []string) error

func (*SubNet) Start

func (self *SubNet) Start(net p2p.P2P)

func (*SubNet) Stop

func (self *SubNet) Stop()

type SubNetMaskAddrFilter

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

func (*SubNetMaskAddrFilter) Contains

func (self *SubNetMaskAddrFilter) Contains(addr string) bool

type SubNetReservedAddrFilter

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

func (*SubNetReservedAddrFilter) Contains

func (self *SubNetReservedAddrFilter) Contains(addr string) bool

type WitnessStatus

type WitnessStatus = byte

const NewStatus WitnessStatus = 0

const UnchangedStatus WitnessStatus = 2

const UpdatedStatus WitnessStatus = 1