k8s

Documentation

Index

• func GetLatestDeploymentReplicaSetRevision(kubeClient *kubeclient.Clientset, namespace, name string) (int64, error)
• func NewClientConfig(config *ClientConfig) (*rest.Config, error)
• type ClientConfig
• type EventSource
  • func NewEventSource(client *kubeclient.Clientset, namespace string) *EventSource
  • func (source *EventSource) GetNewEvents() []*apiv1.Event
  • func (source *EventSource) Start(cancel <-chan interface{})

Functions

func GetLatestDeploymentReplicaSetRevision

func GetLatestDeploymentReplicaSetRevision(kubeClient *kubeclient.Clientset, namespace, name string) (int64, error)

GetLatestDeploymentReplicaSetRevision gets the latest revision of replica sets of a deployment

func NewClientConfig

func NewClientConfig(config *ClientConfig) (*rest.Config, error)

NewClientConfig returns a configuration object that can be used to configure a client in order to contact an API server with.

Types

type ClientConfig

type ClientConfig struct {
	CertificateAuthority string
	ClientCertificate    string
	ClientKey            string
	Cluster              string
	Context              string
	Insecure             bool
	Kubeconfig           string
	Password             string
	Server               string
	Token                string
	User                 string
	Username             string
}

ClientConfig holds configuration options for API server clients.

type EventSource

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

EventSource produces Kubernetes events.

func NewEventSource

func NewEventSource(client *kubeclient.Clientset, namespace string) *EventSource

NewEventSource listens to kubernetes events in namespace. Call GetNewEvents periodically to retrieve batches of events.

func (*EventSource) GetNewEvents

func (source *EventSource) GetNewEvents() []*apiv1.Event

GetNewEvents returns the Kubernetes events that have been fired since the previous invocation of the function.

func (*EventSource) Start

func (source *EventSource) Start(cancel <-chan interface{})

Start starts watching for Kubernetes event. The cancel channel can be used to terminate the operation.