manager

Documentation

Index

• Constants
• type AgentDaemonSet
  • func (a *AgentDaemonSet) Cleanup() error
  • func (a *AgentDaemonSet) Create(image string, managerURL string) 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) 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 {
	GetSupportBundle(namespace, supportbundle string) (*types.SupportBundle, error)
	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

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

func (*SupportBundleManager) Run

func (m *SupportBundleManager) Run() error