Documentation
¶
Index ¶
- Constants
- func LogDebug(ctx context.Context, msg string, keysAndValues ...interface{})
- func LogError(ctx context.Context, err error, msg string, keysAndValues ...interface{})
- func LogFatal(ctx context.Context, err error, msg string, keysAndValues ...interface{})
- func LogVerbose(ctx context.Context, msg string, keysAndValues ...interface{})
- func NewBeegfsDriver(connAuthPath, configPath, csDataDir, driverName, endpoint, nodeID, ... string) (*beegfs, error)
- func NewBeegfsUrl(host string, path string) string
- func NewControllerServer(nodeID string, pluginConfig beegfsv1.PluginConfig, ...) *controllerServer
- func NewIdentityServer(name, version string) *identityServer
- func NewNodeServer(nodeId string, pluginConfig beegfsv1.PluginConfig, ...) *nodeServer
- func NewNonBlockingGRPCServer() *nonBlockingGRPCServer
Constants ¶
View Source
const ( LogLevelDebug = 3 // This log level is used for most informational logs in RPCs and GRPC calls LogLevelVerbose = 5 // This log level is used for only very repetitive logs such as the Probe GRPC call )
Variables ¶
This section is empty.
Functions ¶
func LogVerbose ¶
func NewBeegfsDriver ¶
func NewBeegfsUrl ¶ added in v1.1.0
NewBeegfsUrl converts the sysMgmtdHost and path into a URL with the format beegfs://host/path. NewBeegfsUrl is exported for use by in test/e2e/driver.
func NewControllerServer ¶
func NewControllerServer(nodeID string, pluginConfig beegfsv1.PluginConfig, clientConfTemplatePath, csDataDir string) *controllerServer
func NewIdentityServer ¶
func NewIdentityServer(name, version string) *identityServer
func NewNodeServer ¶
func NewNodeServer(nodeId string, pluginConfig beegfsv1.PluginConfig, clientConfTemplatePath string) *nodeServer
func NewNonBlockingGRPCServer ¶
func NewNonBlockingGRPCServer() *nonBlockingGRPCServer
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.