inspector

Documentation

Index

• Constants
• type ExecOptions
  • func (p *ExecOptions) Run(retry int) (string, error)
  • func (p *ExecOptions) Validate() error
• type Inspector
  • func New(ctx context.Context, cluster *api.Cluster) (*Inspector, error)
  • func (i *Inspector) CheckDNSPod() error
  • func (i *Inspector) CheckHelthStatus() error
  • func (i *Inspector) DeleteNginx() error
  • func (i *Inspector) DeleteNginxService() error
  • func (i *Inspector) InstallNginx() ([]core.Pod, error)
  • func (i *Inspector) InstallNginxService() (string, error)
  • func (i *Inspector) NativeCheck() error
  • func (i *Inspector) NetworkCheck() error
• type RemoteBashExecutor
  • func (e *RemoteBashExecutor) Execute(config *rest.Config, method string, url *url.URL, cmds []string) (string, error)
• type RemoteExecutor

Constants

const (
	ENV    = ".env"
	Server = "pingserver"
)

Types

type ExecOptions

type ExecOptions struct {
	Namespace     string
	PodName       string
	ContainerName string
	Command       []string

	Executor RemoteExecutor
	Client   kubernetes.Interface
	Config   *rest.Config
}

func (*ExecOptions) Run

func (p *ExecOptions) Run(retry int) (string, error)

func (*ExecOptions) Validate

func (p *ExecOptions) Validate() error

type Inspector

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

func New

func New(ctx context.Context, cluster *api.Cluster) (*Inspector, error)

func (*Inspector) CheckDNSPod

func (i *Inspector) CheckDNSPod() error

func (*Inspector) CheckHelthStatus

func (i *Inspector) CheckHelthStatus() error

func (*Inspector) DeleteNginx

func (i *Inspector) DeleteNginx() error

func (*Inspector) DeleteNginxService

func (i *Inspector) DeleteNginxService() error

func (*Inspector) InstallNginx

func (i *Inspector) InstallNginx() ([]core.Pod, error)

func (*Inspector) InstallNginxService

func (i *Inspector) InstallNginxService() (string, error)

func (*Inspector) NativeCheck

func (i *Inspector) NativeCheck() error

func (*Inspector) NetworkCheck

func (i *Inspector) NetworkCheck() error

type RemoteBashExecutor

type RemoteBashExecutor struct{}

func (*RemoteBashExecutor) Execute

func (e *RemoteBashExecutor) Execute(config *rest.Config, method string, url *url.URL, cmds []string) (string, error)

type RemoteExecutor

type RemoteExecutor interface {
	Execute(*rest.Config, string, *url.URL, []string) (string, error)
}