util

Documentation

Index

• Constants
• func CheckAndDeleteStaleFile(dirPath, fileName string) error
• func ConvertLabelsStringToMap(labels string) (map[string]string, error)
• func GetSocketBasePath(targetPath, fuseSocketDir string) string
• func ParseEndpoint(endpoint string, cleanupSocket bool) (string, string, error)
• func ParsePodIDVolumeFromTargetpath(targetPath string) (string, string, error)
• func PrepareEmptyDir(targetPath string, createEmptyDir bool) (string, error)
• func RecvMsg(via net.Conn) (int, []byte, error)
• func SendMsg(via net.Conn, fd int, msg []byte) error
• type VolumeLocks
  • func NewVolumeLocks() *VolumeLocks
  • func (vl *VolumeLocks) Release(volumeID string)
  • func (vl *VolumeLocks) TryAcquire(volumeID string) bool
• type VolumeState
• type VolumeStateStore
  • func NewVolumeStateStore() *VolumeStateStore
  • func (vss *VolumeStateStore) Delete(volumeID string)
  • func (vss *VolumeStateStore) Load(volumeID string) (*VolumeState, bool)
  • func (vss *VolumeStateStore) Size() int32
  • func (vss *VolumeStateStore) Store(volumeID string, state *VolumeState)

Constants

const (
	Mb = 1024 * 1024

	TrueStr  = "true"
	FalseStr = "false"

	// mount options that both CSI mounter and sidecar mounter should understand.
	DisableMetricsForGKE = "disable-metrics-for-gke"
)

const (
	VolumeOperationAlreadyExistsFmt = "An operation with the given volume key %s already exists"
)

Functions

func CheckAndDeleteStaleFile

func CheckAndDeleteStaleFile(dirPath, fileName string) error

func ConvertLabelsStringToMap

func ConvertLabelsStringToMap(labels string) (map[string]string, error)

ConvertLabelsStringToMap converts the labels from string to map example: "key1=value1,key2=value2" gets converted into {"key1": "value1", "key2": "value2"}

func GetSocketBasePath

func GetSocketBasePath(targetPath, fuseSocketDir string) string

GetSocketBasePath constructs the base path for a Unix domain socket. It takes the target path and the directory where Fuse sockets are stored as input.

func ParseEndpoint

func ParseEndpoint(endpoint string, cleanupSocket bool) (string, string, error)

func ParsePodIDVolumeFromTargetpath

func ParsePodIDVolumeFromTargetpath(targetPath string) (string, string, error)

func PrepareEmptyDir

func PrepareEmptyDir(targetPath string, createEmptyDir bool) (string, error)

func RecvMsg

func RecvMsg(via net.Conn) (int, []byte, error)

func SendMsg

func SendMsg(via net.Conn, fd int, msg []byte) error

Types

type VolumeLocks

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

VolumeLocks implements a map with atomic operations. It stores a set of all volume IDs with an ongoing operation.

func NewVolumeLocks

func NewVolumeLocks() *VolumeLocks

func (*VolumeLocks) Release

func (vl *VolumeLocks) Release(volumeID string)

func (*VolumeLocks) TryAcquire

func (vl *VolumeLocks) TryAcquire(volumeID string) bool

TryAcquire tries to acquire the lock for operating on volumeID and returns true if successful. If another operation is already using volumeID, returns false.

type VolumeState

type VolumeState struct {
	BucketAccessCheckPassed bool
}

type VolumeStateStore

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

VolumeStateStore provides a thread-safe map for storing volume states.

func NewVolumeStateStore

func NewVolumeStateStore() *VolumeStateStore

NewVolumeStateStore initializes the volume state store.

func (*VolumeStateStore) Delete

func (vss *VolumeStateStore) Delete(volumeID string)

Delete removes a volume from the store.

func (*VolumeStateStore) Load

func (vss *VolumeStateStore) Load(volumeID string) (*VolumeState, bool)

Load retrieves the state of a volume.

func (*VolumeStateStore) Size

func (vss *VolumeStateStore) Size() int32

NewVolumeStateStore initializes the volume state store.

func (*VolumeStateStore) Store

func (vss *VolumeStateStore) Store(volumeID string, state *VolumeState)

Store adds or updates a volume state.