rclone

Documentation

Index

• Variables
• func GetK8sClient() (*kubernetes.Clientset, error)
• func Mount(remote string, remotePath string, targetPath string, configData string, ...) (rcPort int, err error)
• func NewControllerServer(d *Driver) *controllerServer
• func NewNodeServer(d *Driver) *nodeServer
• func RcloneRPC(host string, method string, input string) (output string, err error)
• type Driver
  • func NewDriver(nodeID, endpoint string) *Driver
  • func (d *Driver) Run()

Variables

var (
	DriverName    = "csi-rclone"
	DriverVersion = "latest"
)

Functions

func GetK8sClient

func GetK8sClient() (*kubernetes.Clientset, error)

func Mount

func Mount(remote string, remotePath string, targetPath string, configData string, flags map[string]string) (rcPort int, err error)

Mount routine.

func NewControllerServer

func NewControllerServer(d *Driver) *controllerServer

func NewNodeServer

func NewNodeServer(d *Driver) *nodeServer

func RcloneRPC

func RcloneRPC(host string, method string, input string) (output string, err error)

RcloneRPC is a helper function to call rclone rc server

Types

type Driver

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

func NewDriver

func NewDriver(nodeID, endpoint string) *Driver

func (*Driver) Run

func (d *Driver) Run()