| /dports/sysutils/nomad/nomad-1.1.0/nomad/structs/ |
| H A D | csi.go | 910 type CSIPlugin struct { struct
939 func NewCSIPlugin(id string, index uint64) *CSIPlugin {
940 out := &CSIPlugin{
950 func (p *CSIPlugin) newStructs() { argument
957 func (p *CSIPlugin) Copy() *CSIPlugin { argument
1163 func (p *CSIPlugin) DeleteNode(nodeID string) error { argument
1244 func (p *CSIPlugin) AddJob(job *Job, summary *JobSummary) { argument
1249 func (p *CSIPlugin) DeleteJob(job *Job, summary *JobSummary) { argument
1375 func (p *CSIPlugin) Stub() *CSIPluginListStub { argument
1389 func (p *CSIPlugin) IsEmpty() bool { argument
[all …]
|
| /dports/sysutils/nomad/nomad-1.1.0/nomad/volumewatcher/ |
| H A D | interfaces_test.go | 10 func testNode(plugin *structs.CSIPlugin, s *state.StateStore) *structs.Node { argument
43 func testVolume(plugin *structs.CSIPlugin, alloc *structs.Allocation, nodeID string) *structs.CSIVo… argument
|
| H A D | volumes_watcher_test.go | 28 plugin := mock.CSIPlugin()
65 plugin := mock.CSIPlugin()
109 plugin := mock.CSIPlugin()
200 plugin := mock.CSIPlugin()
|
| H A D | volume_watcher_test.go | 22 plugin := mock.CSIPlugin()
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubelet/pkg/apis/pluginregistration/v1alpha1/ |
| H A D | constants.go | 21 CSIPlugin = "CSIPlugin" const
|
| H A D | api.proto | 18 // Type of the Plugin. CSIPlugin or DevicePlugin
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubelet/pkg/apis/pluginregistration/v1/ |
| H A D | constants.go | 21 CSIPlugin = "CSIPlugin" const
|
| H A D | api.proto | 18 // Type of the Plugin. CSIPlugin or DevicePlugin
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubelet/pkg/apis/pluginregistration/v1beta1/ |
| H A D | constants.go | 21 CSIPlugin = "CSIPlugin" const
|
| H A D | api.proto | 18 // Type of the Plugin. CSIPlugin or DevicePlugin
|
| /dports/sysutils/nomad/nomad-1.1.0/nomad/ |
| H A D | csi_endpoint.go | 226 …Volume(req *structs.CSIVolumeRegisterRequest, vol *structs.CSIVolume) (*structs.CSIPlugin, error) {
242 …e(req *structs.CSIVolumeRegisterRequest, vol *structs.CSIVolume, plugin *structs.CSIPlugin) error {
489 func (v *CSIVolume) volAndPluginLookup(namespace, volID string) (*structs.CSIPlugin, *structs.CSIVo…
830 plugin *structs.CSIPlugin
898 func (v *CSIVolume) createVolume(vol *structs.CSIVolume, plugin *structs.CSIPlugin) error {
984 func (v *CSIVolume) deleteVolume(vol *structs.CSIVolume, plugin *structs.CSIPlugin) error {
1258 type CSIPlugin struct { struct
1264 func (v *CSIPlugin) List(args *structs.CSIPluginListRequest, reply *structs.CSIPluginListResponse) … argument
1298 plug := raw.(*structs.CSIPlugin)
1309 func (v *CSIPlugin) Get(args *structs.CSIPluginGetRequest, reply *structs.CSIPluginGetResponse) err… argument
[all …]
|
| H A D | search_endpoint.go | 71 case *structs.CSIPlugin:
214 case *structs.CSIPlugin:
466 case *structs.CSIPlugin:
|
| H A D | server.go | 268 CSIPlugin *CSIPlugin member
1145 s.staticEndpoints.CSIPlugin = &CSIPlugin{srv: s, logger: s.logger.Named("csi_plugin")}
1184 server.Register(s.staticEndpoints.CSIPlugin)
|
| /dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/hashicorp/nomad/api/ |
| H A D | csi.go | 424 type CSIPlugin struct { struct
486 func (v *CSIPlugins) Info(id string, q *QueryOptions) (*CSIPlugin, *QueryMeta, error) {
487 var resp *CSIPlugin
|
| /dports/sysutils/nomad/nomad-1.1.0/api/ |
| H A D | csi.go | 424 type CSIPlugin struct { struct
486 func (v *CSIPlugins) Info(id string, q *QueryOptions) (*CSIPlugin, *QueryMeta, error) {
487 var resp *CSIPlugin
|
| /dports/sysutils/nomad/nomad-1.1.0/command/agent/ |
| H A D | csi_endpoint_test.go | 32 out, ok := obj.(*api.CSIPlugin)
163 plugin := mock.CSIPlugin()
|
| H A D | csi_endpoint.go | 412 func structsCSIPluginToApi(plug *structs.CSIPlugin) *api.CSIPlugin { argument
416 out := &api.CSIPlugin{
|
| /dports/sysutils/nomad/nomad-1.1.0/client/ |
| H A D | csi_endpoint.go | 485 func (c *CSI) findControllerPlugin(name string) (csi.CSIPlugin, error) {
489 func (c *CSI) findPlugin(ptype, name string) (csi.CSIPlugin, error) {
495 plugin, ok := pIface.(csi.CSIPlugin)
|
| /dports/sysutils/nomad/nomad-1.1.0/client/pluginmanager/csimanager/ |
| H A D | volume.go | 38 plugin csi.CSIPlugin
55 func newVolumeManager(logger hclog.Logger, eventer TriggerNodeEvent, plugin csi.CSIPlugin, rootDir,… argument
|
| H A D | instance.go | 43 client csi.CSIPlugin
|
| H A D | fingerprint.go | 16 client csi.CSIPlugin
|
| /dports/sysutils/nomad/nomad-1.1.0/command/ |
| H A D | plugin_status_csi.go | 84 func (c *PluginStatusCommand) csiFormatPlugin(plug *api.CSIPlugin) (string, error) { argument
|
| /dports/sysutils/nomad/nomad-1.1.0/nomad/state/ |
| H A D | state_store.go | 1191 var plug *structs.CSIPlugin
1193 plug = raw.(*structs.CSIPlugin).Copy()
1255 plug, ok := raw.(*structs.CSIPlugin)
1323 plug := raw.(*structs.CSIPlugin).Copy()
1412 plugins := map[string]*structs.CSIPlugin{}
2608 return obj.(*structs.CSIPlugin), nil
2614 …Store) CSIPluginDenormalize(ws memdb.WatchSet, plug *structs.CSIPlugin) (*structs.CSIPlugin, error…
2619 …uginDenormalizeTxn(txn Txn, ws memdb.WatchSet, plug *structs.CSIPlugin) (*structs.CSIPlugin, error…
2661 plug.CreateIndex = existing.(*structs.CSIPlugin).CreateIndex
4754 plugIns := make(map[string]*structs.CSIPlugin)
[all …]
|
| /dports/sysutils/nomad/nomad-1.1.0/nomad/mock/ |
| H A D | mock.go | 1647 func CSIPlugin() *structs.CSIPlugin { func
1648 return &structs.CSIPlugin{
1661 func CSIVolume(plugin *structs.CSIPlugin) *structs.CSIVolume { argument
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/pluginmanager/pluginwatcher/ |
| H A D | README.md | 52 for the given plugin type (CSIPlugin or DevicePlugin).
|