Documentation ¶
Index ¶
- type VolumeController
- func (vc *VolumeController) Finalize(ctx context.Context, req *api.FinalizeRequest) (*api.FinalizeResponse, error)
- func (vc *VolumeController) Initialize(ctx context.Context, req *api.InitializeRequest) (*api.InitializeResponse, error)
- func (vc *VolumeController) Run(grpcServerEndpoint string)
- func (vc *VolumeController) Start(ctx context.Context, req *api.StartRequest) (*api.StartResponse, error)
- func (vc *VolumeController) Stop(ctx context.Context, req *api.StopRequest) (*api.StopResponse, error)
- func (vc *VolumeController) UpdateAllowedExecutables(ctx context.Context, req *api.UpdateAllowedExecutablesRequest) (*api.UpdateAllowedExecutablesResponse, error)
- func (vc *VolumeController) UpdateMessageQueueConfig(ctx context.Context, req *api.UpdateMessageQueueConfigRequest) (*api.UpdateMessageQueueConfigResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VolumeController ¶
type VolumeController struct {
// contains filtered or unexported fields
}
func NewVolumeController ¶
func NewVolumeController( fuseOptions *fuse.FuseOptions, volumeOptions *volumeplugins.VolumeOptions, runtimeOptions *runtimeconfig.ContainerRuntimeOptions, kubeClient kubernetes.Interface, stopCh <-chan struct{}) ( *VolumeController, error)
func (*VolumeController) Finalize ¶
func (vc *VolumeController) Finalize( ctx context.Context, req *api.FinalizeRequest) ( *api.FinalizeResponse, error)
func (*VolumeController) Initialize ¶
func (vc *VolumeController) Initialize( ctx context.Context, req *api.InitializeRequest) ( *api.InitializeResponse, error)
func (*VolumeController) Run ¶
func (vc *VolumeController) Run(grpcServerEndpoint string)
func (*VolumeController) Start ¶
func (vc *VolumeController) Start( ctx context.Context, req *api.StartRequest) (*api.StartResponse, error)
func (*VolumeController) Stop ¶
func (vc *VolumeController) Stop( ctx context.Context, req *api.StopRequest) (*api.StopResponse, error)
func (*VolumeController) UpdateAllowedExecutables ¶
func (vc *VolumeController) UpdateAllowedExecutables( ctx context.Context, req *api.UpdateAllowedExecutablesRequest) ( *api.UpdateAllowedExecutablesResponse, error)
func (*VolumeController) UpdateMessageQueueConfig ¶
func (vc *VolumeController) UpdateMessageQueueConfig( ctx context.Context, req *api.UpdateMessageQueueConfigRequest) ( *api.UpdateMessageQueueConfigResponse, error)
Click to show internal directories.
Click to hide internal directories.