kubernetes

Documentation

Index

• Variables
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) GetLogs(podName, namespace string) (string, error)
  • func (c *Client) WatchPods(ctx context.Context, succeeded, failed NotifyFunc) error
• type Container
• type Log
• type NotifyFunc
• type PodEvent

Variables

var (
	ErrWatcherClosed = errors.New("channel closed")
)

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

func (*Client) GetLogs

func (c *Client) GetLogs(podName, namespace string) (string, error)

func (*Client) WatchPods

func (c *Client) WatchPods(ctx context.Context, succeeded, failed NotifyFunc) error

type Container

type Container struct {
	Name         string `json:"name"`
	State        string `json:"state"`
	Reason       string `json:"reason"`
	Message      string `json:"message"`
	Ready        bool   `json:"ready"`
	RestartCount int32  `json:"restartCount"`
}

type Log

type Log struct {
	Level   string
	Message string
}

type NotifyFunc

type NotifyFunc = func(event *PodEvent) error

NotifyFunc represents callback function for Pod event

type PodEvent

type PodEvent struct {
	Namespace  string      `json:"namespace"`
	Name       string      `json:"name"`
	State      string      `json:"state"`
	Reason     string      `json:"reason"`
	Message    string      `json:"message"`
	Containers []Container `json:"containers"`
	ArtifactID string      `json:"artifactId"`
}

PodEvent represents Pod termination event