k8s

Documentation

Index

• Constants
• Variables
• func HasOwnerReference(object metav1.Object, reference metav1.OwnerReference) bool
• func HasSameRevision(obj1 metav1.Object, obj2 metav1.Object) bool
• func NewControllerRef(owner object) (*metav1.OwnerReference, error)
• type Client
  • func New(namespace string, config *rest.Config) (*Client, error)
  • func (c *Client) GetDeployment(ctx context.Context, name string) (*v1.Deployment, error)
  • func (c *Client) GetDeploymentPods(ctx context.Context, d *v1.Deployment) ([]v1Core.Pod, error)
  • func (c *Client) GetObjectEvents(ctx context.Context, object metav1.Object) ([]v1Core.Event, error)
  • func (c *Client) StreamPodLogs(ctx context.Context, name string) error

Constants

const (
	AnnotationDeploymentRevision = "deployment.kubernetes.io/revision"
)

Variables

var ErrTooManyKinds = errors.New("too many kinds")

Functions

func HasOwnerReference

func HasOwnerReference(object metav1.Object, reference metav1.OwnerReference) bool

func HasSameRevision

func HasSameRevision(obj1 metav1.Object, obj2 metav1.Object) bool

func NewControllerRef

func NewControllerRef(owner object) (*metav1.OwnerReference, error)

Types

type Client

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

func New

func New(namespace string, config *rest.Config) (*Client, error)

func (*Client) GetDeployment

func (c *Client) GetDeployment(ctx context.Context, name string) (*v1.Deployment, error)

func (*Client) GetDeploymentPods

func (c *Client) GetDeploymentPods(ctx context.Context, d *v1.Deployment) ([]v1Core.Pod, error)

func (*Client) GetObjectEvents

func (c *Client) GetObjectEvents(ctx context.Context, object metav1.Object) ([]v1Core.Event, error)

func (*Client) StreamPodLogs

func (c *Client) StreamPodLogs(ctx context.Context, name string) error