Documentation ¶
Index ¶
Constants ¶
View Source
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 ¶
View Source
var (
ProviderShuttingDownError = fmt.Errorf("kubernetes cluster provider is being shut down")
)
Functions ¶
func SetLogLevel ¶
SetLogLevel sets the log level for the logger SetLogLevel is safe to be called concurrently
Types ¶
type DeregisterMember ¶
type DeregisterMember struct{}
Empty struct used to deregister a member from k8s
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
func (*Provider) StartMember ¶
StartMember registers the member in the cluster and start it
func (*Provider) UpdateClusterState ¶
func (p *Provider) UpdateClusterState(state cluster.ClusterState) error
type StartWatchingCluster ¶
type StartWatchingCluster struct {
ClusterName string
}
Message used to start watching a k8s cluster
Click to show internal directories.
Click to hide internal directories.