cli

Documentation

Index

• Constants
• type Executer
  • func NewExecuter(client client.Client, newRecorder record.EventRecorder) (*Executer, error)
  • func NewFakeExecuter(client client.Client, fn runnerFunc, fakeRecorder *record.FakeRecorder) *Executer
  • func (e *Executer) AsyncExecute(ctx context.Context, uid types.UID, command []string, retryCount int, ...)
  • func (e *Executer) Exists(uid types.UID) bool
  • func (e *Executer) Remove(uid types.UID)

Constants

const (
	FenceAgentContextCanceledMessage = "fence agent context canceled. Nothing to do"
	FenceAgentContextTimedOutMessage = "fence agent context timed out"
	FenceAgentRetryErrorMessage      = "fence agent retry error"
	FenceAgentFailedCommandMessage   = "command failed"
)

Types

type Executer

type Executer struct {
	client.Client
	// contains filtered or unexported fields
}

func NewExecuter

func NewExecuter(client client.Client, newRecorder record.EventRecorder) (*Executer, error)

NewExecuter builds the Executer

func NewFakeExecuter

func NewFakeExecuter(client client.Client, fn runnerFunc, fakeRecorder *record.FakeRecorder) *Executer

NewFakeExecuter builds an Executer with configurable runnerFunc for testing

func (*Executer) AsyncExecute

func (e *Executer) AsyncExecute(ctx context.Context, uid types.UID, command []string, retryCount int, retryInterval, timeout time.Duration)

AsyncExecute runs the command in a goroutine mapped to the UID

func (*Executer) Exists

func (e *Executer) Exists(uid types.UID) bool

Exists checks if there is already a running Fence Agent command mapped to the UID

func (*Executer) Remove

func (e *Executer) Remove(uid types.UID)