federation

type BootingInfo struct {
	Leader NodeID
	Time   common.StopwatchTime
}

type Dialer func(addr string) (*transport.Client, error)

type FederationPartnerNodeHeader struct {
	PartnerNodeInfo
	Flags int32
}

type GlobalLease struct {
	Tickets  []VoteTicket
	Delta    common.TimeSpan
	BaseTime common.StopwatchTime
}

type NodeID uint128

type NodeIdRange struct {
	Begin NodeID
	End   NodeID
}

type NodeInstance struct {
	Id         NodeID
	InstanceId uint64
}

type NodePhase int64

type PToPActor int64

type PToPHeader struct {
	From          NodeInstance
	To            NodeInstance
	Actor         PToPActor
	FromRing      string
	ToRing        string
	ExactInstance bool
}

type PartnerNodeInfo struct {
	Instance             NodeInstance // The node instance of the node which this information is of.
	Phase                NodePhase    // The phase of the node.
	Address              string       // The address of the node.
	Token                RoutingToken // The token owned by this node.
	LeaseAgentAddress    string       // The address of the lease agent for this node.
	LeaseAgentInstanceId int64        // Instance of the lease agent.
	EndToEnd             bool
	NodeFaultDomainId    common.Uri // The fault domain setting of this node.
	RingName             string
}

type RoutingHeader struct {
	From NodeInstance
	To   NodeInstance
	transport.MessageId
	UseExactRouting bool
	ExpectsReply    bool
	Expiration      common.TimeSpan
	RetryTimeout    common.TimeSpan
	FromRing        string
	ToRing          string
}

type RoutingToken struct {
	Range   NodeIdRange
	Version uint64
}

type SeedNodeInfo struct {
	Id      NodeID
	Address string
}

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

type SiteNodeConfig struct {
	ClientTLS       *tls.Config
	ClientDialer    Dialer
	TransportServer *transport.Server
	LeaseAgent      *lease.Agent
	Instance        NodeInstance
	SeedNodes       []SeedNodeInfo
}

type TicketGap struct {
	Range    NodeIdRange
	Interval TimeRange
}

type TimeRange struct {
	Begin common.StopwatchTime
	End   common.StopwatchTime
}

type VoteTicket struct {
	VoteId     NodeID
	ExpireTime common.StopwatchTime
	Gaps       []TicketGap
}