blockrsync

Documentation

Index

• Constants
• func NewTransfer(t transport.Transport, e endpoint.Endpoint, src client.Client, ...) (transfer.Transfer, error)
• type BlockrsyncTransfer
  • func (r *BlockrsyncTransfer) CreateClient(c client.Client) error
  • func (r *BlockrsyncTransfer) CreateServer(c client.Client) error
  • func (r *BlockrsyncTransfer) Destination() client.Client
  • func (r *BlockrsyncTransfer) Endpoint() endpoint.Endpoint
  • func (r *BlockrsyncTransfer) IsServerHealthy(c client.Client) (bool, error)
  • func (r *BlockrsyncTransfer) PVCs() transfer.PVCPairList
  • func (r *BlockrsyncTransfer) Password() string
  • func (r *BlockrsyncTransfer) Source() client.Client
  • func (r *BlockrsyncTransfer) Transport() transport.Transport
  • func (r *BlockrsyncTransfer) Username() string
• type RsyncClientImage
  • func (r RsyncClientImage) ApplyTo(opts *TransferOptions) error
• type RsyncServerImage
  • func (r RsyncServerImage) ApplyTo(opts *TransferOptions) error
• type TransferOptions
  • func (t *TransferOptions) GetBlockrsyncClientImage() string
  • func (t *TransferOptions) GetBlockrsyncServerImage() string

Constants

const (
	BlockRsyncContainer = "blockrsync"
	Proxy               = "proxy"
)

Functions

func NewTransfer

func NewTransfer(t transport.Transport, e endpoint.Endpoint, src client.Client,
	dest client.Client, pvcList transfer.PVCPairList, log logr.Logger, options *TransferOptions) (transfer.Transfer, error)

Types

type BlockrsyncTransfer

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

func (*BlockrsyncTransfer) CreateClient

func (r *BlockrsyncTransfer) CreateClient(c client.Client) error

func (*BlockrsyncTransfer) CreateServer

func (r *BlockrsyncTransfer) CreateServer(c client.Client) error

func (*BlockrsyncTransfer) Destination

func (r *BlockrsyncTransfer) Destination() client.Client

func (*BlockrsyncTransfer) Endpoint

func (r *BlockrsyncTransfer) Endpoint() endpoint.Endpoint

func (*BlockrsyncTransfer) IsServerHealthy

func (r *BlockrsyncTransfer) IsServerHealthy(c client.Client) (bool, error)

func (*BlockrsyncTransfer) PVCs

func (r *BlockrsyncTransfer) PVCs() transfer.PVCPairList

func (*BlockrsyncTransfer) Password

func (r *BlockrsyncTransfer) Password() string

func (*BlockrsyncTransfer) Source

func (r *BlockrsyncTransfer) Source() client.Client

func (*BlockrsyncTransfer) Transport

func (r *BlockrsyncTransfer) Transport() transport.Transport

func (*BlockrsyncTransfer) Username

func (r *BlockrsyncTransfer) Username() string

type RsyncClientImage

type RsyncClientImage string

func (RsyncClientImage) ApplyTo

func (r RsyncClientImage) ApplyTo(opts *TransferOptions) error

type RsyncServerImage

type RsyncServerImage string

func (RsyncServerImage) ApplyTo

func (r RsyncServerImage) ApplyTo(opts *TransferOptions) error

type TransferOptions

type TransferOptions struct {
	SourcePodMeta      transfer.ResourceMetadata
	DestinationPodMeta transfer.ResourceMetadata
	// contains filtered or unexported fields
}

func (*TransferOptions) GetBlockrsyncClientImage

func (t *TransferOptions) GetBlockrsyncClientImage() string

func (*TransferOptions) GetBlockrsyncServerImage

func (t *TransferOptions) GetBlockrsyncServerImage() string