podnetworkchaosmanager

Documentation

Index

• Variables
• type Append
  • func (a *Append) Apply(chaos *v1alpha1.PodNetworkChaos) error
• type Clear
  • func (s *Clear) Apply(chaos *v1alpha1.PodNetworkChaos) error
• type CommitResponse
• type PodNetworkManager
  • func New(source string, logger logr.Logger, client client.Client) *PodNetworkManager
  • func (m *PodNetworkManager) Commit(ctx context.Context) []CommitResponse
  • func (m *PodNetworkManager) WithInit(key types.NamespacedName) *PodNetworkTransaction
• type PodNetworkTransaction
  • func (t *PodNetworkTransaction) Append(item interface{}) error
  • func (t *PodNetworkTransaction) Apply(chaos *v1alpha1.PodNetworkChaos) error
  • func (t *PodNetworkTransaction) 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 podnetworkchaos

func (*Append) Apply

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

Apply runs this action

type Clear

type Clear struct {
	Source string
}

Clear removes all resources with the same source

func (*Clear) Apply

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

Apply runs this action

type CommitResponse

type CommitResponse struct {
	Key types.NamespacedName
	Err error
}

CommitResponse is a tuple (Key, Err)

type PodNetworkManager

type PodNetworkManager struct {
	Source string
	Log    logr.Logger
	client.Client

	Modifications map[types.NamespacedName]*PodNetworkTransaction
}

PodNetworkManager will save all the related podnetworkchaos

func New

func New(source string, logger logr.Logger, client client.Client) *PodNetworkManager

New creates a new PodNetworkMap

func (*PodNetworkManager) Commit

func (m *PodNetworkManager) Commit(ctx context.Context) []CommitResponse

Commit will update all modifications to the cluster

func (*PodNetworkManager) WithInit

func (m *PodNetworkManager) WithInit(key types.NamespacedName) *PodNetworkTransaction

WithInit will get a transaction or start a transaction with initially clear

type PodNetworkTransaction

type PodNetworkTransaction struct {
	Steps []Step
}

PodNetworkTransaction represents a modification on podnetwork

func (*PodNetworkTransaction) Append

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

Append adds an item to corresponding list in podnetworkchaos

func (*PodNetworkTransaction) Apply

func (t *PodNetworkTransaction) Apply(chaos *v1alpha1.PodNetworkChaos) error

Apply runs every step on the chaos

func (*PodNetworkTransaction) Clear

func (t *PodNetworkTransaction) Clear(source string)

Clear will clear all related items in podnetworkchaos

type Step

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

Step represents a step of PodNetworkTransaction