kubernetes

Documentation

Index

• Constants
• Variables
• func GetChaosBladeByName(name, kubeconfig string) (result *v1alpha1.ChaosBlade, err error)
• func NewCommandModelSpec() spec.ExpModelCommandSpec
• func NewExecutor() spec.Executor
• func QueryStatus(ctx context.Context, operation, kubeconfig string) (*spec.Response, bool)
• func RemoveFinalizer(name, kubeconfig string) error
• type CommandModelSpec
  • func (*CommandModelSpec) Example() string
  • func (*CommandModelSpec) LongDesc() string
  • func (*CommandModelSpec) Name() string
  • func (*CommandModelSpec) ShortDesc() string
• type ComposeExecutor
  • func NewComposeExecutor() ComposeExecutor
• type ComposeExecutorForK8s
  • func (e *ComposeExecutorForK8s) Exec(uid string, ctx context.Context, model *spec.ExpModel) *spec.Response
  • func (*ComposeExecutorForK8s) Name() string
  • func (*ComposeExecutorForK8s) SetChannel(channel spec.Channel)
• type Executor
  • func (e *Executor) Exec(uid string, ctx context.Context, expModel *spec.ExpModel) *spec.Response
  • func (*Executor) Name() string
  • func (e *Executor) SetChannel(channel spec.Channel)
• type StatusResult
  • func CreateConfirmDestroyedStatusResult(uid string) StatusResult
  • func CreateConfirmFailedStatusResult(uid, errMsg string) StatusResult
  • func CreateStatusResult(uid string, success bool, errMsg string, expStatus []v1alpha1.ExperimentStatus) StatusResult

Constants

const (
	QueryCreate  = "create"
	QueryDestroy = "destroy"

	DefaultWaitingTime = "20s"
)

Variables

var KubeConfigFlag = &spec.ExpFlag{
	Name: "kubeconfig",
	Desc: "kubeconfig file",
}

var WaitingTimeFlag = &spec.ExpFlag{
	Name: "waiting-time",
	Desc: "Waiting time for invoking, default value is 20s",
}

Functions

func GetChaosBladeByName

func GetChaosBladeByName(name, kubeconfig string) (result *v1alpha1.ChaosBlade, err error)

func NewCommandModelSpec

func NewCommandModelSpec() spec.ExpModelCommandSpec

func NewExecutor

func NewExecutor() spec.Executor

func QueryStatus

func QueryStatus(ctx context.Context, operation, kubeconfig string) (*spec.Response, bool)

func RemoveFinalizer

func RemoveFinalizer(name, kubeconfig string) error

Types

type CommandModelSpec

type CommandModelSpec struct {
	spec.BaseExpModelCommandSpec
}

func (*CommandModelSpec) Example

func (*CommandModelSpec) Example() string

func (*CommandModelSpec) LongDesc

func (*CommandModelSpec) LongDesc() string

func (*CommandModelSpec) Name

func (*CommandModelSpec) Name() string

func (*CommandModelSpec) ShortDesc

func (*CommandModelSpec) ShortDesc() string

type ComposeExecutor

type ComposeExecutor interface {
	spec.Executor
}

func NewComposeExecutor

func NewComposeExecutor() ComposeExecutor

type ComposeExecutorForK8s

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

func (*ComposeExecutorForK8s) Exec

func (e *ComposeExecutorForK8s) Exec(uid string, ctx context.Context, model *spec.ExpModel) *spec.Response

func (*ComposeExecutorForK8s) Name

func (*ComposeExecutorForK8s) Name() string

func (*ComposeExecutorForK8s) SetChannel

func (*ComposeExecutorForK8s) SetChannel(channel spec.Channel)

type Executor

type Executor struct {
}

func (*Executor) Exec

func (e *Executor) Exec(uid string, ctx context.Context, expModel *spec.ExpModel) *spec.Response

func (*Executor) Name

func (*Executor) Name() string

func (*Executor) SetChannel

func (e *Executor) SetChannel(channel spec.Channel)

type StatusResult

type StatusResult struct {
	Uid      string                    `json:"uid"`
	Success  bool                      `json:"success"`
	Error    string                    `json:"error"`
	Statuses []v1alpha1.ResourceStatus `json:"statuses"`
}

func CreateConfirmDestroyedStatusResult

func CreateConfirmDestroyedStatusResult(uid string) StatusResult

func CreateConfirmFailedStatusResult

func CreateConfirmFailedStatusResult(uid, errMsg string) StatusResult

func CreateStatusResult

func CreateStatusResult(uid string, success bool, errMsg string, expStatus []v1alpha1.ExperimentStatus) StatusResult