k8s

Documentation

Index

• Constants
• Variables
• func SetLogLevel(level log.Level)
• type DeregisterMember
• type Labels
• type Option
• type Provider
  • func New(opts ...Option) (*Provider, error)
  • func NewWithConfig(config *rest.Config, opts ...Option) (*Provider, error)
  • func (p *Provider) Shutdown(graceful bool) error
  • func (p *Provider) StartClient(c *cluster.Cluster) error
  • func (p *Provider) StartMember(c *cluster.Cluster) error
• type RegisterMember
• type StartWatchingCluster

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

func SetLogLevel

func SetLogLevel(level log.Level)

SetLogLevel sets the log level for the logger SetLogLevel is safe to be called concurrently

Types

type DeregisterMember

type DeregisterMember struct{}

DeregisterMember Empty struct used to deregister a member from k8s

type Labels

type Labels map[string]string

Convenience type to store cluster labels

type Option

type Option func(p *Provider)

Convenience type to refer to Option callables

type Provider

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

This data structure provides of k8s as cluster provider for Proto.Actor

func New

func New(opts ...Option) (*Provider, error)

New crates a new k8s Provider in the heap and return back a reference to its memory address

func NewWithConfig

func NewWithConfig(config *rest.Config, opts ...Option) (*Provider, error)

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) Shutdown

func (p *Provider) Shutdown(graceful bool) error

func (*Provider) StartClient

func (p *Provider) StartClient(c *cluster.Cluster) error

StartClient starts the k8s client and monitor watch

func (*Provider) StartMember

func (p *Provider) StartMember(c *cluster.Cluster) error

StartMember registers the member in the cluster and start it

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