csiclient

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 struct{}

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 struct {
	// contains filtered or unexported fields
}

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 struct {
	// contains filtered or unexported fields
}