csiclient

Documentation

Index

• func NewConnection(endpoint string) (*grpc.ClientConn, error)
• type Builder
• type ClientBuilder
  • func (b ClientBuilder) NewConnection(endpoint string) (*grpc.ClientConn, error)
  • func (b ClientBuilder) NewConnectionWithContext(ctx context.Context, endpoint string) (*grpc.ClientConn, error)
  • func (b ClientBuilder) NewIdentityServiceClient(conn *grpc.ClientConn) Identity
  • func (b ClientBuilder) NewNodeServiceClient(conn *grpc.ClientConn) Node
• type Identity
• type IdentitySvcClient
  • func NewIdentitySvcClient(conn *grpc.ClientConn) *IdentitySvcClient
  • func (c IdentitySvcClient) GetPluginInfo(ctx context.Context) (*csi.GetPluginInfoResponse, error)
  • func (c IdentitySvcClient) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)
  • func (c IdentitySvcClient) ProbeForever(conn *grpc.ClientConn, singleProbeTimeout time.Duration) error
• type Node
• type NodeSvcClient
  • func NewNodeSvcClient(conn *grpc.ClientConn) *NodeSvcClient
  • func (c *NodeSvcClient) GetCapabilities(ctx context.Context) (*csi.NodeGetCapabilitiesResponse, error)
  • func (c *NodeSvcClient) GetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (c *NodeSvcClient) PublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (c *NodeSvcClient) StageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (c *NodeSvcClient) UnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (c *NodeSvcClient) UnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

Functions

func NewConnection

func NewConnection(endpoint string) (*grpc.ClientConn, error)

Types

type Builder

type Builder interface {
	NewConnection(endpoint string) (*grpc.ClientConn, error)
	NewConnectionWithContext(ctx context.Context, endpoint string) (*grpc.ClientConn, error)

	NewNodeServiceClient(conn *grpc.ClientConn) Node
	NewIdentityServiceClient(conn *grpc.ClientConn) Identity
}

type ClientBuilder

type ClientBuilder struct{}

func (ClientBuilder) NewConnection

func (b ClientBuilder) NewConnection(endpoint string) (*grpc.ClientConn, error)

func (ClientBuilder) NewConnectionWithContext

func (b ClientBuilder) NewConnectionWithContext(ctx context.Context, endpoint string) (*grpc.ClientConn, error)

func (ClientBuilder) NewIdentityServiceClient

func (b ClientBuilder) NewIdentityServiceClient(conn *grpc.ClientConn) Identity

func (ClientBuilder) NewNodeServiceClient

func (b ClientBuilder) NewNodeServiceClient(conn *grpc.ClientConn) Node

type Identity

type Identity interface {
	GetPluginInfo(ctx context.Context) (*csi.GetPluginInfoResponse, error)
	Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)
	ProbeForever(conn *grpc.ClientConn, singleProbeTimeout time.Duration) error
}

type IdentitySvcClient

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

func NewIdentitySvcClient

func NewIdentitySvcClient(conn *grpc.ClientConn) *IdentitySvcClient

func (IdentitySvcClient) GetPluginInfo

func (c IdentitySvcClient) GetPluginInfo(ctx context.Context) (*csi.GetPluginInfoResponse, error)

func (IdentitySvcClient) Probe

func (c IdentitySvcClient) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

func (IdentitySvcClient) ProbeForever

func (c IdentitySvcClient) ProbeForever(conn *grpc.ClientConn, singleProbeTimeout time.Duration) error

type Node

type Node interface {
	GetCapabilities(ctx context.Context) (*csi.NodeGetCapabilitiesResponse, error)
	GetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

	StageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
	UnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

	PublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
	UnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
}

type NodeSvcClient

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

func NewNodeSvcClient

func NewNodeSvcClient(conn *grpc.ClientConn) *NodeSvcClient

func (*NodeSvcClient) GetCapabilities

func (c *NodeSvcClient) GetCapabilities(ctx context.Context) (*csi.NodeGetCapabilitiesResponse, error)

func (*NodeSvcClient) GetVolumeStats

func (c *NodeSvcClient) GetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*NodeSvcClient) PublishVolume

func (c *NodeSvcClient) PublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*NodeSvcClient) StageVolume

func (c *NodeSvcClient) StageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*NodeSvcClient) UnpublishVolume

func (c *NodeSvcClient) UnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*NodeSvcClient) UnstageVolume

func (c *NodeSvcClient) UnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)