gather

Documentation

Index

• type Addon
• type AgentPod
  • func NewAgentPod(name string, client *kubernetes.Clientset, log *zap.SugaredLogger) *AgentPod
  • func (a *AgentPod) Create() error
  • func (a *AgentPod) Delete()
  • func (a AgentPod) String() string
  • func (a *AgentPod) WaitUntilRunning() error
• type Gatherer
  • func New(config *rest.Config, directory string, opts Options) (*Gatherer, error)
  • func (g *Gatherer) Count() int32
  • func (g *Gatherer) Gather() error
• type LogsAddon
  • func NewLogsAddon(config *rest.Config, httpClient *http.Client, out *OutputDirectory, ...) (*LogsAddon, error)
  • func (g *LogsAddon) Inspect(pod *unstructured.Unstructured) error
• type Options
• type OutputDirectory
  • func (o *OutputDirectory) CreateAddonDir(name string, more ...string) (string, error)
  • func (o *OutputDirectory) CreateClusterResource(resource string, name string) (io.WriteCloser, error)
  • func (o *OutputDirectory) CreateContainerLog(namespace string, pod string, container string, name string) (io.WriteCloser, error)
  • func (o *OutputDirectory) CreateNamespacedResource(namespace string, resource string, name string) (io.WriteCloser, error)
• type Queuer
• type RemoteCommand
  • func NewRemoteCommand(pod *corev1.Pod, opts *Options, log *zap.SugaredLogger, directroy string) *RemoteCommand
  • func (c *RemoteCommand) Filename(command ...string) string
  • func (c *RemoteCommand) Gather(command ...string) error
• type RemoteDirectory
  • func NewRemoteDirectory(pod *corev1.Pod, opts *Options, log *zap.SugaredLogger) *RemoteDirectory
  • func (d *RemoteDirectory) Gather(src string, dst string) error
• type RookAddon
  • func NewRookCephAddon(config *rest.Config, client *http.Client, out *OutputDirectory, opts *Options, ...) (*RookAddon, error)
  • func (a *RookAddon) Inspect(cephcluster *unstructured.Unstructured) error
• type WorkFunc
• type WorkQueue
  • func NewWorkQueue(workers int, size int) *WorkQueue
  • func (q *WorkQueue) Queue(work WorkFunc)
  • func (q *WorkQueue) Start()
  • func (q *WorkQueue) Wait() error

Types

type Addon

type Addon interface {
	// Inspect a resource and gather related data.
	Inspect(*unstructured.Unstructured) error
}

type AgentPod

type AgentPod struct {
	Client *kubernetes.Clientset
	Log    *zap.SugaredLogger
	Pod    *corev1.Pod
}

func NewAgentPod

func NewAgentPod(name string, client *kubernetes.Clientset, log *zap.SugaredLogger) *AgentPod

func (*AgentPod) Create

func (a *AgentPod) Create() error

func (*AgentPod) Delete

func (a *AgentPod) Delete()

func (AgentPod) String

func (a AgentPod) String() string

func (*AgentPod) WaitUntilRunning

func (a *AgentPod) WaitUntilRunning() error

type Gatherer

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

func New

func New(config *rest.Config, directory string, opts Options) (*Gatherer, error)

func (*Gatherer) Count

func (g *Gatherer) Count() int32

func (*Gatherer) Gather

func (g *Gatherer) Gather() error

type LogsAddon

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

func NewLogsAddon

func NewLogsAddon(config *rest.Config, httpClient *http.Client, out *OutputDirectory, opts *Options, q Queuer) (*LogsAddon, error)

func (*LogsAddon) Inspect

func (g *LogsAddon) Inspect(pod *unstructured.Unstructured) error

type Options

type Options struct {
	Kubeconfig string
	Context    string
	Namespaces []string
	Addons     []string
	Log        *zap.SugaredLogger
}

type OutputDirectory

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

func (*OutputDirectory) CreateAddonDir

func (o *OutputDirectory) CreateAddonDir(name string, more ...string) (string, error)

func (*OutputDirectory) CreateClusterResource

func (o *OutputDirectory) CreateClusterResource(resource string, name string) (io.WriteCloser, error)

func (*OutputDirectory) CreateContainerLog

func (o *OutputDirectory) CreateContainerLog(namespace string, pod string, container string, name string) (io.WriteCloser, error)

func (*OutputDirectory) CreateNamespacedResource

func (o *OutputDirectory) CreateNamespacedResource(namespace string, resource string, name string) (io.WriteCloser, error)

type Queuer

type Queuer interface {
	Queue(WorkFunc)
}

type RemoteCommand

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

func NewRemoteCommand

func NewRemoteCommand(pod *corev1.Pod, opts *Options, log *zap.SugaredLogger, directroy string) *RemoteCommand

func (*RemoteCommand) Filename

func (c *RemoteCommand) Filename(command ...string) string

func (*RemoteCommand) Gather

func (c *RemoteCommand) Gather(command ...string) error

type RemoteDirectory

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

func NewRemoteDirectory

func NewRemoteDirectory(pod *corev1.Pod, opts *Options, log *zap.SugaredLogger) *RemoteDirectory

func (*RemoteDirectory) Gather

func (d *RemoteDirectory) Gather(src string, dst string) error

type RookAddon

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

func NewRookCephAddon

func NewRookCephAddon(config *rest.Config, client *http.Client, out *OutputDirectory, opts *Options, q Queuer) (*RookAddon, error)

func (*RookAddon) Inspect

func (a *RookAddon) Inspect(cephcluster *unstructured.Unstructured) error

type WorkFunc

type WorkFunc func() error

type WorkQueue

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

func NewWorkQueue

func NewWorkQueue(workers int, size int) *WorkQueue

func (*WorkQueue) Queue

func (q *WorkQueue) Queue(work WorkFunc)

func (*WorkQueue) Start

func (q *WorkQueue) Start()

func (*WorkQueue) Wait

func (q *WorkQueue) Wait() error