cluster

Documentation

Index

• type ClusterState
  • func NewClusterState() *ClusterState
  • func (cs *ClusterState) DelDiscovery(d *types.Discovery)
  • func (cs *ClusterState) DelIngress(i *types.Ingress)
  • func (cs *ClusterState) DelNode(n *types.Node)
  • func (cs *ClusterState) DelRoute(r *types.Route)
  • func (cs *ClusterState) DelVolume(v *types.Volume)
  • func (cs *ClusterState) IPAM() ipam.IPAM
  • func (cs *ClusterState) Loop() error
  • func (cs *ClusterState) Observe()
  • func (cs *ClusterState) PodLease(p *types.Pod) (*types.Node, error)
  • func (cs *ClusterState) PodRelease(p *types.Pod) (*types.Node, error)
  • func (cs *ClusterState) SetDiscovery(d *types.Discovery)
  • func (cs *ClusterState) SetIngress(i *types.Ingress)
  • func (cs *ClusterState) SetNode(n *types.Node)
  • func (cs *ClusterState) SetRoute(r *types.Route)
  • func (cs *ClusterState) SetVolume(v *types.Volume)
  • func (cs *ClusterState) VolumeLease(v *types.Volume) (*types.Node, error)
  • func (cs *ClusterState) VolumeRelease(v *types.Volume) (*types.Node, error)
• type NodeLease
  • func (nl *NodeLease) Wait()
• type NodeLeaseOptions

Types

type ClusterState

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

ClusterState is cluster current state struct

func NewClusterState

func NewClusterState() *ClusterState

NewClusterState returns new cluster state instance

func (*ClusterState) DelDiscovery

func (cs *ClusterState) DelDiscovery(d *types.Discovery)

func (*ClusterState) DelIngress

func (cs *ClusterState) DelIngress(i *types.Ingress)

func (*ClusterState) DelNode

func (cs *ClusterState) DelNode(n *types.Node)

func (*ClusterState) DelRoute

func (cs *ClusterState) DelRoute(r *types.Route)

func (*ClusterState) DelVolume

func (cs *ClusterState) DelVolume(v *types.Volume)

func (*ClusterState) IPAM

func (cs *ClusterState) IPAM() ipam.IPAM

IPAM management

func (*ClusterState) Loop

func (cs *ClusterState) Loop() error

Loop cluster state from storage

func (*ClusterState) Observe

func (cs *ClusterState) Observe()

Runtime cluster describes main cluster state loop

func (*ClusterState) PodLease

func (cs *ClusterState) PodLease(p *types.Pod) (*types.Node, error)

func (*ClusterState) PodRelease

func (cs *ClusterState) PodRelease(p *types.Pod) (*types.Node, error)

func (*ClusterState) SetDiscovery

func (cs *ClusterState) SetDiscovery(d *types.Discovery)

func (*ClusterState) SetIngress

func (cs *ClusterState) SetIngress(i *types.Ingress)

func (*ClusterState) SetNode

func (cs *ClusterState) SetNode(n *types.Node)

func (*ClusterState) SetRoute

func (cs *ClusterState) SetRoute(r *types.Route)

func (*ClusterState) SetVolume

func (cs *ClusterState) SetVolume(v *types.Volume)

func (*ClusterState) VolumeLease

func (cs *ClusterState) VolumeLease(v *types.Volume) (*types.Node, error)

func (*ClusterState) VolumeRelease

func (cs *ClusterState) VolumeRelease(v *types.Volume) (*types.Node, error)

type NodeLease

type NodeLease struct {
	Request  NodeLeaseOptions
	Response struct {
		Err  error
		Node *types.Node
	}
	// contains filtered or unexported fields
}

func (*NodeLease) Wait

func (nl *NodeLease) Wait()

type NodeLeaseOptions

type NodeLeaseOptions struct {
	Node     *string
	Memory   *int64
	Storage  *int64
	Selector types.SpecSelector
}