swarm

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

type EntryPoint interface {
	Nodes() []*NodeInfo
}

type KubernetesOptions struct {
	KubernetesInCluster  bool
	KubernetesAPIBaseURL string
	Namespace            string
	LabelSelectorKey     string
	LabelSelectorValue   string
}

type Message struct {
	Source string
	Value  interface{}
}

type NodeInfo struct {
	Name string
	Addr net.IP
	Port uint16
}

type NodeState int

type Options struct {

	// MaxMessageBuffer is the maximum size of the exchange
	// packets send out to peers.
	MaxMessageBuffer int

	// LeaveTimeout is the timeout to wait for responses for a
	// leave message send by this instance to other peers.
	LeaveTimeout time.Duration

	// SwarmPort port to listen for incoming swarm packets.
	SwarmPort uint16

	// KubernetesOptions are options required to find your peers in Kubernetes
	KubernetesOptions *KubernetesOptions

	StaticSwarm *StaticSwarm

	// FakeSwarm enable a test swarm
	FakeSwarm bool

	// FakeSwarmLocalNode is the node name of the local node
	// joining a fakeSwarm to have better log output
	FakeSwarmLocalNode string

	// Debug enables swarm debug logs and also enables memberlist logs
	Debug bool
	// contains filtered or unexported fields
}

type Self interface {
	Node() *NodeInfo
}

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

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