clustering

type Broadcast struct {
	Envelope *Envelope
}

type Cluster struct {
	Memberlist *memberlist.Memberlist
	// Members are all welcomed members of the cluster from this node's point of view
	Members map[string]*ClusterMember
	// ServiceUpdates published the configuration any time it's updated
	ServicesUpdates chan []*configuration.ServiceConfiguration
	// Store is a state store for the cluster
	Store *storage.Store
	// contains filtered or unexported fields
}

type ClusterMember struct {
	// ServicesVersion is the current (incremental) version of the configured services
	ServicesVersion int
	// Services are the services configured for the cluster member
	Services []*configuration.ServiceConfiguration
}

type ClusterStatus int

type ConfigUpdateMessage struct {
	// Version is the incremental version of the configuration
	Version int
	// Node is the node for which this configuration is for
	Node     string
	Services []*configuration.ServiceConfiguration
}

type Envelope struct {
	// Sender is the node from which the message was sent
	Sender      string
	MessageType MessageType
	Message     Message
}

type Message interface {
	// Invalidates specifies whether the message invalidates the other message
	Invalidates(other Message) bool
}

type MessageType int

type StatusUpdateMessage struct {
	// Timestamp is the Unix timestamp of when the update occured
	Timestamp int64
	// Node is the node observing the status change
	Node string
	// Origin is the node which requested the monitoring
	Origin string
	// ServiceId is the id of the service which received an update
	ServiceId string
	// MonitorId is the id of the monitor which received an update
	MonitorId string
	// Status is the observed status
	Status monitoring.Status
}