volume

Documentation

Index

• type Lock
  • func (s *Lock) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *Lock) Init(ctx context.Context) error
• type Protection
  • func (p *Protection) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (p *Protection) Init(ctx context.Context) error
  • func (p *Protection) PreCheck(ctx context.Context, req *operations.OpsRequest) error
• type Unlock
  • func (s *Unlock) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)
  • func (s *Unlock) Init(ctx context.Context) error

Types

type Lock

type Lock struct {
	operations.Base

	Timeout time.Duration
	Command []string
	// contains filtered or unexported fields
}

func (*Lock) Do

func (s *Lock) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)

func (*Lock) Init

func (s *Lock) Init(ctx context.Context) error

type Protection

type Protection struct {
	operations.Base

	Requester     volumeStatsRequester
	Pod           string
	HighWatermark int
	Volumes       map[string]volumeExt
	Readonly      bool
	SendEvent     bool // to disable event for testing
	Logger        logr.Logger
	// contains filtered or unexported fields
}

func (*Protection) Do

func (p *Protection) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)

func (*Protection) Init

func (p *Protection) Init(ctx context.Context) error

func (*Protection) PreCheck

func (p *Protection) PreCheck(ctx context.Context, req *operations.OpsRequest) error

type Unlock

type Unlock struct {
	operations.Base

	Timeout time.Duration
	Command []string
	// contains filtered or unexported fields
}

func (*Unlock) Do

func (s *Unlock) Do(ctx context.Context, req *operations.OpsRequest) (*operations.OpsResponse, error)

func (*Unlock) Init

func (s *Unlock) Init(ctx context.Context) error