Documentation
¶
Index ¶
Constants ¶
const ( LabelPrefix = "cluster.proto.actor/" LabelPort = LabelPrefix + "port" LabelKind = LabelPrefix + "kind" LabelCluster = LabelPrefix + "cluster" LabelStatusValue = LabelPrefix + "status-value" LabelMemberID = LabelPrefix + "member-id" )
Label keys that will be used to update the Pods metadata
Variables ¶
var ProviderShuttingDownError = fmt.Errorf("kubernetes cluster provider is being shut down")
Functions ¶
This section is empty.
Types ¶
type DeregisterMember ¶
type DeregisterMember struct{}
DeregisterMember Empty struct used to deregister a member from k8s
type DeregisterMemberResponse ¶
type DeregisterMemberResponse struct{}
DeregisterMemberResponse sent back from cluster monitor when deregistering completes or fails
type Provider ¶
type Provider struct {
// contains filtered or unexported fields
}
This data structure provides of k8s as cluster provider for Proto.Actor
func New ¶
New crates a new k8s Provider in the heap and return back a reference to its memory address
func NewWithConfig ¶
NewWithConfig creates a new k8s Provider in the heap using the given configuration and options, it returns a reference to its memory address or an error
func (*Provider) StartClient ¶
StartClient starts the k8s client and monitor watch
type RegisterMember ¶
type RegisterMember struct{}
RegisterMember message used to register a new member in k8s
type StartWatchingCluster ¶
type StartWatchingCluster struct {
ClusterName string
}
StartWatchingCluster message used to start watching a k8s cluster
type StopWatchingCluster ¶
type StopWatchingCluster struct{}
StopWatchingCluster message used to stop watching a k8s cluster
type StopWatchingClusterResponse ¶
type StopWatchingClusterResponse struct{}
StopWatchingClusterResponse sent back from cluster monitor when stop watching completes