utils

package

v1.1.1 Latest Latest Go to latest Published: Sep 20, 2021 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ambiknai/ibm-csi-common

Links

Open Source Insights

Documentation ¶

Overview ¶

Package utils ...

Index ¶

Constants
Variables
func BytesToGiB(volumeSizeBytes int64) int
func GetContextLogger(ctx context.Context, isDebug bool) (*zap.Logger, string)
func GetContextLoggerWithRequestID(ctx context.Context, isDebug bool, requestIDIn *string) (*zap.Logger, string)
func GetTestLogger(t *testing.T) (logger *zap.Logger, teardown func())
func ListContainsSubstr(mainStr []string, subStr string) bool
func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability
func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
func RoundUpBytes(volumeSizeBytes int64) int64
type APIKeyImpl
- func NewAPIKeyImpl(loggerIn *zap.Logger) (*APIKeyImpl, error)
- func (d *APIKeyImpl) UpdateIAMKeys(config *config.Config) error
type ClusterInfo
- func NewClusterInfo(logger *zap.Logger) (*ClusterInfo, error)
type LockStore
- func (s *LockStore) Lock(name string)
- func (s *LockStore) Unlock(name string)

Constants ¶

View Source

const (
	// GiB in bytes
	GiB = 1024 * 1024 * 1024

	// MinimumVolumeSizeInBytes minimum size of the volume in bytes
	MinimumVolumeSizeInBytes int64 = 10 * GiB
	// MaximumVolumeSizeInBytes the max allowed capacity
	MaximumVolumeSizeInBytes int64 = 2 * 1024 * GiB //2000GB = 2TB

	// MinimumVolumeDiskSizeInGb minimum size of the volume in GB
	MinimumVolumeDiskSizeInGb = 10
	// MaximumVolumeDiskSizeInGb ...
	MaximumVolumeDiskSizeInGb = 2048
	// DefaultVolumeDiskSizeinGb default size of the volume in GB
	DefaultVolumeDiskSizeinGb = 10
)

View Source

const (

	// KB ...
	KB = 1 << (10 * iota)
	// MB ...
	MB
	// GB ...
	GB
	// TB ...
	TB
)

View Source

const (
	// ClusterInfoPath ...
	ClusterInfoPath = "cluster_info/cluster-config.json"

	// NodeZoneLabel  Zone Label attached to node
	NodeZoneLabel = "failure-domain.beta.kubernetes.io/zone"

	// NodeRegionLabel Region Label attached to node
	NodeRegionLabel = "failure-domain.beta.kubernetes.io/region"

	// NodeWorkerIDLabel  worker ID label attached to node
	NodeWorkerIDLabel = "ibm-cloud.kubernetes.io/worker-id"

	// VolumeIDLabel ...
	VolumeIDLabel = "volumeId"

	// VolumeCRNLabel ...
	VolumeCRNLabel = "volumeCRN"

	// ClusterIDLabel ...
	ClusterIDLabel = "clusterID"

	// IOPSLabel ...
	IOPSLabel = "iops"

	// ZoneLabel ...
	ZoneLabel = "zone"
)

Variables ¶

View Source

var LockEnabled = flag.Bool("lock_enabled", true, "Enable or disable lock")

LockEnabled ...

Functions ¶

func BytesToGiB ¶

func BytesToGiB(volumeSizeBytes int64) int

BytesToGiB converts Bytes to GiB

func GetContextLogger ¶

func GetContextLogger(ctx context.Context, isDebug bool) (*zap.Logger, string)

GetContextLogger ...

func GetContextLoggerWithRequestID ¶

func GetContextLoggerWithRequestID(ctx context.Context, isDebug bool, requestIDIn *string) (*zap.Logger, string)

GetContextLoggerWithRequestID adds existing requestID in the logger The Existing requestID might be coming from ControllerPublishVolume etc

func GetTestLogger ¶

func GetTestLogger(t *testing.T) (logger *zap.Logger, teardown func())

GetTestLogger ...

func ListContainsSubstr ¶

func ListContainsSubstr(mainStr []string, subStr string) bool

ListContainsSubstr Checks if subStr is there in mainStr

func NewControllerServiceCapability ¶

func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability

NewControllerServiceCapability ...

func NewNodeServiceCapability ¶

func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability

NewNodeServiceCapability ...

func NewVolumeCapabilityAccessMode ¶

func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode

NewVolumeCapabilityAccessMode ...

func RoundUpBytes ¶

func RoundUpBytes(volumeSizeBytes int64) int64

RoundUpBytes rounds up the volume size in bytes upto multiplications of GiB in the unit of Bytes

Types ¶

type APIKeyImpl ¶

type APIKeyImpl struct {
	GRPCBackend grpcClient.GrpcSessionFactory
	// contains filtered or unexported fields
}

APIKeyImpl implementation

func NewAPIKeyImpl ¶

func NewAPIKeyImpl(loggerIn *zap.Logger) (*APIKeyImpl, error)

NewAPIKeyImpl returns the new decryptor

func (*APIKeyImpl) UpdateIAMKeys ¶

func (d *APIKeyImpl) UpdateIAMKeys(config *config.Config) error

UpdateIAMKeys decrypts the API keys and updates.

type ClusterInfo ¶

type ClusterInfo struct {
	ClusterID   string `json:"cluster_id"`
	ClusterName string `json:"cluster_name,omitempty"`
	DataCenter  string `json:"datacenter,omitempty"`
	CustomerID  string `json:"customer_id,omitempty"`
}

ClusterInfo contains the cluster information

func NewClusterInfo ¶

func NewClusterInfo(logger *zap.Logger) (*ClusterInfo, error)

NewClusterInfo loads cluster info

type LockStore ¶

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

LockStore ...

func (*LockStore) Lock ¶

func (s *LockStore) Lock(name string)

Lock ...

func (*LockStore) Unlock ¶

func (s *LockStore) Unlock(name string)

Unlock ...

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
grpc-client Package grpcclient ...	Package grpcclient ...
fake-grpc Package fakegrpc ...	Package fakegrpc ...

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL