driver

package

v0.0.0-...-fb7ec14 Latest Latest Go to latest Published: Apr 18, 2023 License: MIT Imports: 17 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/converged-computing/oras-csi

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CreateListener(csiEndpoint string) (net.Listener, error)
func CreategRPCServer() *grpc.Server
func Init(sanityTestRun bool, logLevel int, orasLog bool) error
func StartService(service *Service, mode, csiEndpoint string) error
type IdentityService
type NodeService
- func NewNodeService(rootPath, pluginDataPath, nodeId string, handlersCount int, ...) (*NodeService, error)
type Service

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DefaultMode              = "unspecified"
	DefaultCSISocket         = "unix:///var/lib/csi/sockets/pluginproxy/csi.sock"
	DefaultNodeID            = ""
	DefaultRootDir           = "/"
	DefaultPluginDataDir     = "/"
	DefaultHandlersCount     = 1
	DefaultSanityTestRun     = false
	DefaultLogLevel          = 5
	DefaultEnforceNamespaces = true
)

View Source

var OrasLog bool // enable logging

View Source

var SanityTestRun bool // is this a test run?

I think this refers to csi-sanity https://github.com/kubernetes-csi/csi-test/blob/v4.4.0/cmd/csi-sanity/main.go

Functions ¶

func CreateListener ¶

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

CreateListener create listener ready for communication over given csi endpoint

func CreategRPCServer ¶

func CreategRPCServer() *grpc.Server

func Init ¶

func Init(sanityTestRun bool, logLevel int, orasLog bool) error

Init primarily sets logging levels for TBA services

func StartService ¶

func StartService(service *Service, mode, csiEndpoint string) error

Types ¶

type IdentityService ¶

type IdentityService struct {
	csi.UnimplementedIdentityServer
	Service
}

func (*IdentityService) GetPluginCapabilities ¶

func (is *IdentityService) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities returns the message of what the csi provides

func (*IdentityService) GetPluginInfo ¶

func (is *IdentityService) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

func (*IdentityService) Probe ¶

func (is *IdentityService) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

Probe indicates that the plugin is in a healthy state

type NodeService ¶

type NodeService struct {
	csi.UnimplementedNodeServer
	Service
	// contains filtered or unexported fields
}

func NewNodeService ¶

func NewNodeService(rootPath, pluginDataPath, nodeId string, handlersCount int, enforceNamespaces bool) (*NodeService, error)

NewNodeService creates the node service that runs on every node.

func (*NodeService) NodeExpandVolume ¶

func (ns *NodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

NodeExpandVolume not implemented

func (*NodeService) NodeGetCapabilities ¶

func (ns *NodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*NodeService) NodeGetInfo ¶

func (ns *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

NodeGetInfo returns the nodeid

func (*NodeService) NodeGetVolumeStats ¶

func (ns *NodeService) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

NodeGetVolumeStats not implemented

func (*NodeService) NodePublishVolume ¶

func (ns *NodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*NodeService) NodeStageVolume ¶

func (ns *NodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

NodeStageVolume only exists to validate arguments

func (*NodeService) NodeUnpublishVolume ¶

func (ns *NodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

NodeUnpublishVolume removes the bind

func (*NodeService) NodeUnstageVolume ¶

func (ns *NodeService) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

type Service ¶

type Service interface{}

Source Files ¶

View all Source files

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