podhttpchaosmanager

Documentation

Index

• Variables
• type Append
  • func (a *Append) Apply(chaos *v1alpha1.PodHttpChaos) error
• type Builder
  • func NewBuilder(params Params) *Builder
  • func (b *Builder) WithInit(source string, key types.NamespacedName) *PodHttpManager
• type Clear
  • func (s *Clear) Apply(chaos *v1alpha1.PodHttpChaos) error
• type CommitResponse
• type Params
• type PodHttpManager
  • func (m *PodHttpManager) Commit(ctx context.Context) (int64, error)
  • func (m *PodHttpManager) CreateNewPodHttpChaos(ctx context.Context) error
• type PodHttpTransaction
  • func (t *PodHttpTransaction) Append(item interface{}) error
  • func (t *PodHttpTransaction) Apply(chaos *v1alpha1.PodHttpChaos) error
  • func (t *PodHttpTransaction) Clear(source string)
• type Step

Variables

var (
	// ErrPodNotFound means operate pod may be deleted(almostly)
	ErrPodNotFound = errors.New("pod not found")

	// ErrPodNotRunning means operate pod may be not working
	// and it's non-sense to make changes on it.
	ErrPodNotRunning = errors.New("pod not running")
)

Types

type Append

type Append struct {
	Item interface{}
}

Append adds an item to corresponding list in podhttpchaos

func (*Append) Apply

func (a *Append) Apply(chaos *v1alpha1.PodHttpChaos) error

Apply runs this action

type Builder

type Builder struct {
	Log logr.Logger
	client.Client
	client.Reader
	// contains filtered or unexported fields
}

func NewBuilder

func NewBuilder(params Params) *Builder

func (*Builder) WithInit

func (b *Builder) WithInit(source string, key types.NamespacedName) *PodHttpManager

type Clear

type Clear struct {
	Source string
}

Clear removes all resources with the same source

func (*Clear) Apply

func (s *Clear) Apply(chaos *v1alpha1.PodHttpChaos) error

Apply runs this action

type CommitResponse

type CommitResponse struct {
	Key types.NamespacedName
	Err error
}

CommitResponse is a tuple (Key, Err)

type Params

type Params struct {
	fx.In

	Logger logr.Logger
	Client client.Client
	Reader client.Reader `name:"no-cache"`
	Scheme *runtime.Scheme
}

type PodHttpManager

type PodHttpManager struct {
	Source string

	Log logr.Logger
	client.Client
	client.Reader

	Key types.NamespacedName
	T   *PodHttpTransaction
	// contains filtered or unexported fields
}

PodHttpManager will save all the related podhttpchaos

func (*PodHttpManager) Commit

func (m *PodHttpManager) Commit(ctx context.Context) (int64, error)

Commit will update all modifications to the cluster

func (*PodHttpManager) CreateNewPodHttpChaos

func (m *PodHttpManager) CreateNewPodHttpChaos(ctx context.Context) error

type PodHttpTransaction

type PodHttpTransaction struct {
	Steps []Step
}

PodHttpTransaction represents a modification on podhttpchaos

func (*PodHttpTransaction) Append

func (t *PodHttpTransaction) Append(item interface{}) error

Append adds an item to corresponding list in podnetworkchaos

func (*PodHttpTransaction) Apply

func (t *PodHttpTransaction) Apply(chaos *v1alpha1.PodHttpChaos) error

Apply runs every step on the chaos

func (*PodHttpTransaction) Clear

func (t *PodHttpTransaction) Clear(source string)

Clear will clear all related items in podhttpchaos

type Step

type Step interface {
	// Apply will apply an action on podnetworkchaos
	Apply(chaos *v1alpha1.PodHttpChaos) error
}

Step represents a step of PodHttpTransaction