manager

Documentation

Index

• Constants
• type AgentDaemonSet
  • func (a *AgentDaemonSet) Cleanup() error
  • func (a *AgentDaemonSet) Create(image string, managerURL string) (*appsv1.DaemonSet, error)
• type BundleMeta
• type Cluster
  • func NewCluster(ctx context.Context, sbm *SupportBundleManager) *Cluster
  • func (c *Cluster) GenerateClusterBundle(bundleDir string) (string, error)
• type GetRuntimeObjectListFunc
• type HttpServer
  • func (s *HttpServer) Run(m *SupportBundleManager)
• type LocalStore
  • func NewLocalStore(namespace, supportbundle string) *LocalStore
  • func (s *LocalStore) GetState(namespace, supportbundle string) (types.SupportBundleState, error)
  • func (s *LocalStore) GetSupportBundle(namespace, supportbundle string) (*types.SupportBundle, error)
• type ManagerStatus
  • func (s *ManagerStatus) SetError(message string)
  • func (s *ManagerStatus) SetFileinfo(filename string, filesize int64)
  • func (s *ManagerStatus) SetPhase(phase types.ManagerPhase)
  • func (s *ManagerStatus) SetProgress(progress int)
• type StateStoreInterface
• type SupportBundleManager
  • func (m *SupportBundleManager) Run() error

Constants

const (
	PhaseInit          = "start"
	PhaseClusterBundle = "cluster"
	PhaseNodeBundle    = "node"
	PhasePackaging     = "packaging"
	PhaseDone          = "done"

	BundleVersion = "0.1.0"
)

Types

type AgentDaemonSet

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

func (*AgentDaemonSet) Cleanup

func (a *AgentDaemonSet) Cleanup() error

func (*AgentDaemonSet) Create

func (a *AgentDaemonSet) Create(image string, managerURL string) (*appsv1.DaemonSet, error)

type BundleMeta

type BundleMeta struct {
	BundleName           string `json:"projectName"`
	BundleVersion        string `json:"bundleVersion"`
	KubernetesVersion    string `json:"kubernetesVersion"`
	ProjectNamespaceUUID string `json:"projectNamspaceUUID"`
	BundleCreatedAt      string `json:"bundleCreatedAt"`
	IssueURL             string `json:"issueURL"`
	IssueDescription     string `json:"issueDescription"`
}

type Cluster

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

func NewCluster

func NewCluster(ctx context.Context, sbm *SupportBundleManager) *Cluster

func (*Cluster) GenerateClusterBundle

func (c *Cluster) GenerateClusterBundle(bundleDir string) (string, error)

type GetRuntimeObjectListFunc

type GetRuntimeObjectListFunc func() (runtime.Object, error)

type HttpServer

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

func (*HttpServer) Run

func (s *HttpServer) Run(m *SupportBundleManager)

type LocalStore

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

func NewLocalStore

func NewLocalStore(namespace, supportbundle string) *LocalStore

NewLocalStore creates a local state store with one supportbundle

func (*LocalStore) GetState

func (s *LocalStore) GetState(namespace, supportbundle string) (types.SupportBundleState, error)

func (*LocalStore) GetSupportBundle

func (s *LocalStore) GetSupportBundle(namespace, supportbundle string) (*types.SupportBundle, error)

type ManagerStatus

type ManagerStatus struct {
	sync.RWMutex
	types.ManagerStatus
}

func (*ManagerStatus) SetError

func (s *ManagerStatus) SetError(message string)

func (*ManagerStatus) SetFileinfo

func (s *ManagerStatus) SetFileinfo(filename string, filesize int64)

func (*ManagerStatus) SetPhase

func (s *ManagerStatus) SetPhase(phase types.ManagerPhase)

func (*ManagerStatus) SetProgress

func (s *ManagerStatus) SetProgress(progress int)

type StateStoreInterface

type StateStoreInterface interface {
	GetState(namespace, supportbundle string) (types.SupportBundleState, error)
}

type SupportBundleManager

type SupportBundleManager struct {
	Namespaces []string
	BundleName string

	OutputDir       string
	WaitTimeout     time.Duration
	ManagerPodIP    string
	Standalone      bool
	ImageName       string
	ImagePullPolicy string
	KubeConfig      string
	PodNamespace    string
	NodeSelector    string
	TaintToleration string
	RegistrySecret  string
	IssueURL        string
	Description     string
	NodeTimeout     time.Duration

	ExcludeResources    []schema.GroupResource
	ExcludeResourceList []string
	BundleCollectors    []string
	SpecifyCollector    string
	// contains filtered or unexported fields
}

func (*SupportBundleManager) Run

func (m *SupportBundleManager) Run() error