collect

Documentation

Index

• Constants
• Variables
• func Ceph(c *Collector, cephCollector *troubleshootv1beta2.Ceph) (map[string][]byte, error)
• func ClusterInfo(c *Collector) (map[string][]byte, error)
• func ClusterResources(c *Collector) (map[string][]byte, error)
• func Collectd(c *Collector, collectdCollector *troubleshootv1beta2.Collectd) (map[string][]byte, error)
• func Copy(c *Collector, copyCollector *troubleshootv1beta2.Copy) (map[string][]byte, error)
• func CreateCollector(client client.Client, scheme *runtime.Scheme, ownerRef metav1.Object, ...) (*corev1.ConfigMap, *corev1.Pod, error)
• func Data(c *Collector, dataCollector *troubleshootv1beta2.Data) (map[string][]byte, error)
• func DeterministicIDForCollector(collector *troubleshootv1beta2.Collect) string
• func Exec(c *Collector, execCollector *troubleshootv1beta2.Exec) (map[string][]byte, error)
• func GetCephCollectorFilepath(name, namespace string) string
• func HTTP(c *Collector, httpCollector *troubleshootv1beta2.HTTP) (map[string][]byte, error)
• func IsRBACError(err error) bool
• func Logs(c *Collector, logsCollector *troubleshootv1beta2.Logs) (map[string][]byte, error)
• func Mysql(c *Collector, databaseCollector *troubleshootv1beta2.Database) (map[string][]byte, error)
• func Postgres(c *Collector, databaseCollector *troubleshootv1beta2.Database) (map[string][]byte, error)
• func Redis(c *Collector, databaseCollector *troubleshootv1beta2.Database) (map[string][]byte, error)
• func Run(c *Collector, runCollector *troubleshootv1beta2.Run) (map[string][]byte, error)
• func Secret(c *Collector, secretCollector *troubleshootv1beta2.Secret) (map[string][]byte, error)
• type CephCommand
• type ClusterVersion
• type Collector
  • func (c *Collector) CheckRBAC(ctx context.Context) error
  • func (c *Collector) GetDisplayName() string
  • func (c *Collector) IsExcluded() bool
  • func (c *Collector) RunCollectorSync(globalRedactors []*troubleshootv1beta2.Redact) (result map[string][]byte, err error)
• type Collectors
  • func (cs Collectors) CheckRBAC(ctx context.Context) error
• type DatabaseConnection
• type FoundSecret
• type RBACError
  • func (e RBACError) Error() string

Constants

const (
	DefaultCephNamespace = "rook-ceph"
)

Variables

var CephCommands = []CephCommand{
	{
		ID:      "status",
		Command: []string{"ceph", "status"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
	{
		ID:      "fs",
		Command: []string{"ceph", "fs", "status"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
	{
		ID:      "fs-ls",
		Command: []string{"ceph", "fs", "ls"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
	{
		ID:      "osd-status",
		Command: []string{"ceph", "osd", "status"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "txt",
	},
	{
		ID:      "osd-tree",
		Command: []string{"ceph", "osd", "tree"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
	{
		ID:      "osd-pool",
		Command: []string{"ceph", "osd", "pool", "ls", "detail"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
	{
		ID:      "health",
		Command: []string{"ceph", "health", "detail"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
	{
		ID:      "auth",
		Command: []string{"ceph", "auth", "ls"},
		Args:    []string{"-f", "json-pretty"},
		Format:  "json",
	},
}

Functions

func Ceph

func Ceph(c *Collector, cephCollector *troubleshootv1beta2.Ceph) (map[string][]byte, error)

func ClusterInfo

func ClusterInfo(c *Collector) (map[string][]byte, error)

func ClusterResources

func ClusterResources(c *Collector) (map[string][]byte, error)

func Collectd

func Collectd(c *Collector, collectdCollector *troubleshootv1beta2.Collectd) (map[string][]byte, error)

func Copy

func Copy(c *Collector, copyCollector *troubleshootv1beta2.Copy) (map[string][]byte, error)

Copy function gets a file or folder from a container specified in the specs.

func CreateCollector

func CreateCollector(client client.Client, scheme *runtime.Scheme, ownerRef metav1.Object, jobName string, jobNamespace string, serviceAccountName string, jobType string, collect *troubleshootv1beta2.Collect, image string, pullPolicy string) (*corev1.ConfigMap, *corev1.Pod, error)

func Data

func Data(c *Collector, dataCollector *troubleshootv1beta2.Data) (map[string][]byte, error)

func DeterministicIDForCollector

func DeterministicIDForCollector(collector *troubleshootv1beta2.Collect) string

func Exec

func Exec(c *Collector, execCollector *troubleshootv1beta2.Exec) (map[string][]byte, error)

func GetCephCollectorFilepath

func GetCephCollectorFilepath(name, namespace string) string

func HTTP

func HTTP(c *Collector, httpCollector *troubleshootv1beta2.HTTP) (map[string][]byte, error)

func IsRBACError

func IsRBACError(err error) bool

func Logs

func Logs(c *Collector, logsCollector *troubleshootv1beta2.Logs) (map[string][]byte, error)

func Mysql

func Mysql(c *Collector, databaseCollector *troubleshootv1beta2.Database) (map[string][]byte, error)

func Postgres

func Postgres(c *Collector, databaseCollector *troubleshootv1beta2.Database) (map[string][]byte, error)

func Redis

func Redis(c *Collector, databaseCollector *troubleshootv1beta2.Database) (map[string][]byte, error)

func Run

func Run(c *Collector, runCollector *troubleshootv1beta2.Run) (map[string][]byte, error)

func Secret

func Secret(c *Collector, secretCollector *troubleshootv1beta2.Secret) (map[string][]byte, error)

Types

type CephCommand

type CephCommand struct {
	ID      string
	Command []string
	Args    []string
	Format  string
}

type ClusterVersion

type ClusterVersion struct {
	Info   *version.Info `json:"info"`
	String string        `json:"string"`
}

type Collector

type Collector struct {
	Collect      *troubleshootv1beta2.Collect
	Redact       bool
	RBACErrors   []error
	ClientConfig *rest.Config
	Namespace    string
	PathPrefix   string
}

func (*Collector) CheckRBAC

func (c *Collector) CheckRBAC(ctx context.Context) error

func (*Collector) GetDisplayName

func (c *Collector) GetDisplayName() string

func (*Collector) IsExcluded

func (c *Collector) IsExcluded() bool

checks if a given collector has a spec with 'exclude' that evaluates to true.

func (*Collector) RunCollectorSync

func (c *Collector) RunCollectorSync(globalRedactors []*troubleshootv1beta2.Redact) (result map[string][]byte, err error)

type Collectors

type Collectors []*Collector

func (Collectors) CheckRBAC

func (cs Collectors) CheckRBAC(ctx context.Context) error

type DatabaseConnection

type DatabaseConnection struct {
	IsConnected bool   `json:"isConnected"`
	Error       string `json:"error,omitempty"`
	Version     string `json:"version,omitempty"`
}

type FoundSecret

type FoundSecret struct {
	Namespace    string `json:"namespace"`
	Name         string `json:"name"`
	Key          string `json:"key"`
	SecretExists bool   `json:"secretExists"`
	KeyExists    bool   `json:"keyExists"`
	Value        string `json:"value,omitempty"`
}

type RBACError

type RBACError struct {
	DisplayName string
	Namespace   string
	Resource    string
	Verb        string
}

func (RBACError) Error

func (e RBACError) Error() string