util

Documentation

Index

• Constants
• func Contained(obj, target interface{}) bool
• func FlushLogs()
• func GetCSIClientConn(csiEndpoint string) (*grpc.ClientConn, error)
• func GetCSIEndPoint(csiEndpoint string) (string, error)
• func GetCSIEndPointListener(csiEndpoint string) (net.Listener, error)
• func InitLogs()
• func IsSupportFstype(fstype string) bool
• func IsSupportPotocol(protocol string) bool
• func PathExists(path string) (bool, error)
• type GlogWriter
  • func (writer GlogWriter) Write(data []byte) (n int, err error)

Constants

const (
	// NameSpace for CSI
	NameSpace = "csi"
	// CSI endpoint environment variable name
	CSIEndpoint = "CSI_ENDPOINT"
	// CSI default endpoint
	CSIDefaultEndpoint = "unix://path/to/unix/domain/socket.sock"

	// Opensds endpoint environment variable name
	OpensdsEndpoint = "OPENSDS_ENDPOINT"
	// Opensds auth strategy
	OpensdsAuthStrategy = "OPENSDS_AUTH_STRATEGY"
	// Opensds default endpoint
	OpensdsDefaultEndpoint = "http://localhost:50040"

	//  Opensds Secondary AZ
	OpensdsSecondaryAZ        = "OPENSDS_SECONDARY_AZ"
	OpensdsDefaultSecondaryAZ = "secondary"

	// CSI  environment variable whether enable the replication function, value can be true or false
	CSIEnableReplication = "CSI_ENABLE_REPLICATION"

	// 1024 * 1024 * 1024
	GiB int64 = 1073741824
)

const DefaultLogDir = "/var/log/opensds"

Functions

func Contained

func Contained(obj, target interface{}) bool

Contained ...

func FlushLogs

func FlushLogs()

func GetCSIClientConn

func GetCSIClientConn(csiEndpoint string) (*grpc.ClientConn, error)

GetCSIClientConn from endpoint

func GetCSIEndPoint

func GetCSIEndPoint(csiEndpoint string) (string, error)

GetCSIEndPoint from environment variable

func GetCSIEndPointListener

func GetCSIEndPointListener(csiEndpoint string) (net.Listener, error)

GetCSIEndPointListener from endpoint

func InitLogs

func InitLogs()

func IsSupportFstype

func IsSupportFstype(fstype string) bool

IsSupportFstype ...

func IsSupportPotocol

func IsSupportPotocol(protocol string) bool

IsSupportPotocol ...

func PathExists

func PathExists(path string) (bool, error)

Types

type GlogWriter

type GlogWriter struct{}

func (GlogWriter) Write

func (writer GlogWriter) Write(data []byte) (n int, err error)