passfd

Documentation

Index

• func GetFdAddress(ctx context.Context, upgradeUUID string) (string, error)
• func GetFuseFd(path string, close bool) (int, []byte)
• func InitGlobalFds(ctx context.Context, client *k8s.K8sClient, basePath string) error
• func InitTestFds()
• type Fds
  • func (fs *Fds) CloseFd(pod *corev1.Pod)
  • func (fs *Fds) GetSid(pod *corev1.Pod) uint64
  • func (fs *Fds) ParseFuseFds(ctx context.Context) error
  • func (fs *Fds) ServeFuseFd(ctx context.Context, pod *corev1.Pod) error
  • func (fs *Fds) StopFd(ctx context.Context, pod *corev1.Pod)
  • func (fs *Fds) UpdateSid(pod *corev1.Pod, sid uint64)

Functions

func GetFdAddress

func GetFdAddress(ctx context.Context, upgradeUUID string) (string, error)

func GetFuseFd

func GetFuseFd(path string, close bool) (int, []byte)

func InitGlobalFds

func InitGlobalFds(ctx context.Context, client *k8s.K8sClient, basePath string) error

func InitTestFds

func InitTestFds()

Types

type Fds

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

var GlobalFds *Fds

func (*Fds) CloseFd

func (fs *Fds) CloseFd(pod *corev1.Pod)

func (*Fds) GetSid

func (fs *Fds) GetSid(pod *corev1.Pod) uint64

func (*Fds) ParseFuseFds

func (fs *Fds) ParseFuseFds(ctx context.Context) error

func (*Fds) ServeFuseFd

func (fs *Fds) ServeFuseFd(ctx context.Context, pod *corev1.Pod) error

func (*Fds) StopFd

func (fs *Fds) StopFd(ctx context.Context, pod *corev1.Pod)

func (*Fds) UpdateSid

func (fs *Fds) UpdateSid(pod *corev1.Pod, sid uint64)