v1alpha1

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 15, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_grpc_volumecontrol_v1alpha1_volumectl_proto protoreflect.FileDescriptor

Functions

func RegisterVolumeControlServer 

func RegisterVolumeControlServer(s *grpc.Server, srv VolumeControlServer)

Types

type Executable 

type Executable struct {
	Checksum []byte             `protobuf:"bytes,1,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Writable bool               `protobuf:"varint,2,opt,name=writable,proto3" json:"writable,omitempty"`
	Scripts  map[string]*Script `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Executable) Descriptor deprecated 

func (*Executable) Descriptor() ([]byte, []int)

Deprecated: Use Executable.ProtoReflect.Descriptor instead.

func (*Executable) GetChecksum 

func (x *Executable) GetChecksum() []byte

func (*Executable) GetScripts 

func (x *Executable) GetScripts() map[string]*Script

func (*Executable) GetWritable 

func (x *Executable) GetWritable() bool

func (*Executable) ProtoMessage 

func (*Executable) ProtoMessage()

func (*Executable) ProtoReflect 

func (x *Executable) ProtoReflect() protoreflect.Message

func (*Executable) Reset 

func (x *Executable) Reset()

func (*Executable) String 

func (x *Executable) String() string

type ExecutablePaths 

type ExecutablePaths struct {
	Paths []string `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutablePaths) Descriptor deprecated 

func (*ExecutablePaths) Descriptor() ([]byte, []int)

Deprecated: Use ExecutablePaths.ProtoReflect.Descriptor instead.

func (*ExecutablePaths) GetPaths 

func (x *ExecutablePaths) GetPaths() []string

func (*ExecutablePaths) ProtoMessage 

func (*ExecutablePaths) ProtoMessage()

func (*ExecutablePaths) ProtoReflect 

func (x *ExecutablePaths) ProtoReflect() protoreflect.Message

func (*ExecutablePaths) Reset 

func (x *ExecutablePaths) Reset()

func (*ExecutablePaths) String 

func (x *ExecutablePaths) String() string

type ExecutablesDiffs 

type ExecutablesDiffs struct {
	AddedAndUpdated map[string]*Executable `` /* 196-byte string literal not displayed */
	DeletedPaths    []string               `protobuf:"bytes,2,rep,name=deleted_paths,json=deletedPaths,proto3" json:"deleted_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutablesDiffs) Descriptor deprecated 

func (*ExecutablesDiffs) Descriptor() ([]byte, []int)

Deprecated: Use ExecutablesDiffs.ProtoReflect.Descriptor instead.

func (*ExecutablesDiffs) GetAddedAndUpdated 

func (x *ExecutablesDiffs) GetAddedAndUpdated() map[string]*Executable

func (*ExecutablesDiffs) GetDeletedPaths 

func (x *ExecutablesDiffs) GetDeletedPaths() []string

func (*ExecutablesDiffs) ProtoMessage 

func (*ExecutablesDiffs) ProtoMessage()

func (*ExecutablesDiffs) ProtoReflect 

func (x *ExecutablesDiffs) ProtoReflect() protoreflect.Message

func (*ExecutablesDiffs) Reset 

func (x *ExecutablesDiffs) Reset()

func (*ExecutablesDiffs) String 

func (x *ExecutablesDiffs) String() string

type ExternalAllowedExecutable 

type ExternalAllowedExecutable struct {
	CommandAbsolutePath               string                   `protobuf:"bytes,1,opt,name=command_absolute_path,json=commandAbsolutePath,proto3" json:"command_absolute_path,omitempty"`
	WithResidentCommandAbsolutePath   string                   `` /* 160-byte string literal not displayed */
	Writable                          bool                     `protobuf:"varint,3,opt,name=writable,proto3" json:"writable,omitempty"`
	AreAllProcessesAllowedInNamespace bool                     `` /* 169-byte string literal not displayed */
	IsHostProcess                     bool                     `protobuf:"varint,5,opt,name=is_host_process,json=isHostProcess,proto3" json:"is_host_process,omitempty"`
	MountNamespaceId                  string                   `protobuf:"bytes,6,opt,name=mount_namespace_id,json=mountNamespaceId,proto3" json:"mount_namespace_id,omitempty"`
	ExternalAllowedScripts            []*ExternalAllowedScript `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExternalAllowedExecutable) Descriptor deprecated 

func (*ExternalAllowedExecutable) Descriptor() ([]byte, []int)

Deprecated: Use ExternalAllowedExecutable.ProtoReflect.Descriptor instead.

func (*ExternalAllowedExecutable) GetAreAllProcessesAllowedInNamespace 

func (x *ExternalAllowedExecutable) GetAreAllProcessesAllowedInNamespace() bool

func (*ExternalAllowedExecutable) GetCommandAbsolutePath 

func (x *ExternalAllowedExecutable) GetCommandAbsolutePath() string

func (*ExternalAllowedExecutable) GetExternalAllowedScripts 

func (x *ExternalAllowedExecutable) GetExternalAllowedScripts() []*ExternalAllowedScript

func (*ExternalAllowedExecutable) GetIsHostProcess 

func (x *ExternalAllowedExecutable) GetIsHostProcess() bool

func (*ExternalAllowedExecutable) GetMountNamespaceId 

func (x *ExternalAllowedExecutable) GetMountNamespaceId() string

func (*ExternalAllowedExecutable) GetWithResidentCommandAbsolutePath 

func (x *ExternalAllowedExecutable) GetWithResidentCommandAbsolutePath() string

func (*ExternalAllowedExecutable) GetWritable 

func (x *ExternalAllowedExecutable) GetWritable() bool

func (*ExternalAllowedExecutable) ProtoMessage 

func (*ExternalAllowedExecutable) ProtoMessage()

func (*ExternalAllowedExecutable) ProtoReflect 

func (x *ExternalAllowedExecutable) ProtoReflect() protoreflect.Message

func (*ExternalAllowedExecutable) Reset 

func (x *ExternalAllowedExecutable) Reset()

func (*ExternalAllowedExecutable) String 

func (x *ExternalAllowedExecutable) String() string

type ExternalAllowedScript 

type ExternalAllowedScript struct {
	AbsolutePath              string `protobuf:"bytes,1,opt,name=absolute_path,json=absolutePath,proto3" json:"absolute_path,omitempty"`
	Writable                  bool   `protobuf:"varint,2,opt,name=writable,proto3" json:"writable,omitempty"`
	RelativePathToInitWorkDir string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExternalAllowedScript) Descriptor deprecated 

func (*ExternalAllowedScript) Descriptor() ([]byte, []int)

Deprecated: Use ExternalAllowedScript.ProtoReflect.Descriptor instead.

func (*ExternalAllowedScript) GetAbsolutePath 

func (x *ExternalAllowedScript) GetAbsolutePath() string

func (*ExternalAllowedScript) GetRelativePathToInitWorkDir 

func (x *ExternalAllowedScript) GetRelativePathToInitWorkDir() string

func (*ExternalAllowedScript) GetWritable 

func (x *ExternalAllowedScript) GetWritable() bool

func (*ExternalAllowedScript) ProtoMessage 

func (*ExternalAllowedScript) ProtoMessage()

func (*ExternalAllowedScript) ProtoReflect 

func (x *ExternalAllowedScript) ProtoReflect() protoreflect.Message

func (*ExternalAllowedScript) Reset 

func (x *ExternalAllowedScript) Reset()

func (*ExternalAllowedScript) String 

func (x *ExternalAllowedScript) String() string

type FinalizeRequest 

type FinalizeRequest struct {
	FuseMountPointDir string `protobuf:"bytes,1,opt,name=fuse_mount_point_dir,json=fuseMountPointDir,proto3" json:"fuse_mount_point_dir,omitempty"`
	Force             bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*FinalizeRequest) Descriptor deprecated 

func (*FinalizeRequest) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeRequest.ProtoReflect.Descriptor instead.

func (*FinalizeRequest) GetForce 

func (x *FinalizeRequest) GetForce() bool

func (*FinalizeRequest) GetFuseMountPointDir 

func (x *FinalizeRequest) GetFuseMountPointDir() string

func (*FinalizeRequest) ProtoMessage 

func (*FinalizeRequest) ProtoMessage()

func (*FinalizeRequest) ProtoReflect 

func (x *FinalizeRequest) ProtoReflect() protoreflect.Message

func (*FinalizeRequest) Reset 

func (x *FinalizeRequest) Reset()

func (*FinalizeRequest) String 

func (x *FinalizeRequest) String() string

type FinalizeResponse 

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

func (*FinalizeResponse) Descriptor deprecated 

func (*FinalizeResponse) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeResponse.ProtoReflect.Descriptor instead.

func (*FinalizeResponse) ProtoMessage 

func (*FinalizeResponse) ProtoMessage()

func (*FinalizeResponse) ProtoReflect 

func (x *FinalizeResponse) ProtoReflect() protoreflect.Message

func (*FinalizeResponse) Reset 

func (x *FinalizeResponse) Reset()

func (*FinalizeResponse) String 

func (x *FinalizeResponse) String() string

type InitializeRequest 

type InitializeRequest struct {
	FuseSourcePath             string                       `protobuf:"bytes,1,opt,name=fuse_source_path,json=fuseSourcePath,proto3" json:"fuse_source_path,omitempty"`
	ExternalAllowedExecutables []*ExternalAllowedExecutable `` /* 141-byte string literal not displayed */
	CsiVolumeHandle            string                       `protobuf:"bytes,3,opt,name=csi_volume_handle,json=csiVolumeHandle,proto3" json:"csi_volume_handle,omitempty"`
	LocalFuseMountsHostRootDir string                       `` /* 147-byte string literal not displayed */
	DisableUsageControl        bool                         `protobuf:"varint,5,opt,name=disable_usage_control,json=disableUsageControl,proto3" json:"disable_usage_control,omitempty"`
	// contains filtered or unexported fields
}

func (*InitializeRequest) Descriptor deprecated 

func (*InitializeRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitializeRequest.ProtoReflect.Descriptor instead.

func (*InitializeRequest) GetCsiVolumeHandle 

func (x *InitializeRequest) GetCsiVolumeHandle() string

func (*InitializeRequest) GetDisableUsageControl 

func (x *InitializeRequest) GetDisableUsageControl() bool

func (*InitializeRequest) GetExternalAllowedExecutables 

func (x *InitializeRequest) GetExternalAllowedExecutables() []*ExternalAllowedExecutable

func (*InitializeRequest) GetFuseSourcePath 

func (x *InitializeRequest) GetFuseSourcePath() string

func (*InitializeRequest) GetLocalFuseMountsHostRootDir 

func (x *InitializeRequest) GetLocalFuseMountsHostRootDir() string

func (*InitializeRequest) ProtoMessage 

func (*InitializeRequest) ProtoMessage()

func (*InitializeRequest) ProtoReflect 

func (x *InitializeRequest) ProtoReflect() protoreflect.Message

func (*InitializeRequest) Reset 

func (x *InitializeRequest) Reset()

func (*InitializeRequest) String 

func (x *InitializeRequest) String() string

type InitializeResponse 

type InitializeResponse struct {
	FuseMountPointDir string `protobuf:"bytes,1,opt,name=fuse_mount_point_dir,json=fuseMountPointDir,proto3" json:"fuse_mount_point_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*InitializeResponse) Descriptor deprecated 

func (*InitializeResponse) Descriptor() ([]byte, []int)

Deprecated: Use InitializeResponse.ProtoReflect.Descriptor instead.

func (*InitializeResponse) GetFuseMountPointDir 

func (x *InitializeResponse) GetFuseMountPointDir() string

func (*InitializeResponse) ProtoMessage 

func (*InitializeResponse) ProtoMessage()

func (*InitializeResponse) ProtoReflect 

func (x *InitializeResponse) ProtoReflect() protoreflect.Message

func (*InitializeResponse) Reset 

func (x *InitializeResponse) Reset()

func (*InitializeResponse) String 

func (x *InitializeResponse) String() string

type MessageQueue 

type MessageQueue struct {
	Brokers                        []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	User                           string   `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Password                       string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Topic                          string   `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	CompressionCodec               string   `protobuf:"bytes,5,opt,name=compression_codec,json=compressionCodec,proto3" json:"compression_codec,omitempty"`
	MaxBatchBytes                  string   `protobuf:"bytes,6,opt,name=max_batch_bytes,json=maxBatchBytes,proto3" json:"max_batch_bytes,omitempty"`
	UpdatePublishChannelBufferSize string   `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MessageQueue) Descriptor deprecated 

func (*MessageQueue) Descriptor() ([]byte, []int)

Deprecated: Use MessageQueue.ProtoReflect.Descriptor instead.

func (*MessageQueue) GetBrokers 

func (x *MessageQueue) GetBrokers() []string

func (*MessageQueue) GetCompressionCodec 

func (x *MessageQueue) GetCompressionCodec() string

func (*MessageQueue) GetMaxBatchBytes 

func (x *MessageQueue) GetMaxBatchBytes() string

func (*MessageQueue) GetPassword 

func (x *MessageQueue) GetPassword() string

func (*MessageQueue) GetTopic 

func (x *MessageQueue) GetTopic() string

func (*MessageQueue) GetUpdatePublishChannelBufferSize 

func (x *MessageQueue) GetUpdatePublishChannelBufferSize() string

func (*MessageQueue) GetUser 

func (x *MessageQueue) GetUser() string

func (*MessageQueue) ProtoMessage 

func (*MessageQueue) ProtoMessage()

func (*MessageQueue) ProtoReflect 

func (x *MessageQueue) ProtoReflect() protoreflect.Message

func (*MessageQueue) Reset 

func (x *MessageQueue) Reset()

func (*MessageQueue) String 

func (x *MessageQueue) String() string

type Script 

type Script struct {
	Checksum                  []byte `protobuf:"bytes,1,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Writable                  bool   `protobuf:"varint,2,opt,name=writable,proto3" json:"writable,omitempty"`
	RelativePathToInitWorkDir string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Script) Descriptor deprecated 

func (*Script) Descriptor() ([]byte, []int)

Deprecated: Use Script.ProtoReflect.Descriptor instead.

func (*Script) GetChecksum 

func (x *Script) GetChecksum() []byte

func (*Script) GetRelativePathToInitWorkDir 

func (x *Script) GetRelativePathToInitWorkDir() string

func (*Script) GetWritable 

func (x *Script) GetWritable() bool

func (*Script) ProtoMessage 

func (*Script) ProtoMessage()

func (*Script) ProtoReflect 

func (x *Script) ProtoReflect() protoreflect.Message

func (*Script) Reset 

func (x *Script) Reset()

func (*Script) String 

func (x *Script) String() string

type StartRequest 

type StartRequest struct {
	PodNamespace                string                 `protobuf:"bytes,1,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	PodName                     string                 `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	DataContainerName           string                 `protobuf:"bytes,3,opt,name=data_container_name,json=dataContainerName,proto3" json:"data_container_name,omitempty"`
	PvcKey                      string                 `protobuf:"bytes,4,opt,name=pvc_key,json=pvcKey,proto3" json:"pvc_key,omitempty"`
	AllowedExecutables          map[string]*Executable `` /* 203-byte string literal not displayed */
	MessageQueueUpdatePublisher *MessageQueue          `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartRequest) Descriptor deprecated 

func (*StartRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetAllowedExecutables 

func (x *StartRequest) GetAllowedExecutables() map[string]*Executable

func (*StartRequest) GetDataContainerName 

func (x *StartRequest) GetDataContainerName() string

func (*StartRequest) GetMessageQueueUpdatePublisher 

func (x *StartRequest) GetMessageQueueUpdatePublisher() *MessageQueue

func (*StartRequest) GetPodName 

func (x *StartRequest) GetPodName() string

func (*StartRequest) GetPodNamespace 

func (x *StartRequest) GetPodNamespace() string

func (*StartRequest) GetPvcKey 

func (x *StartRequest) GetPvcKey() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

func (x *StartRequest) ProtoReflect() protoreflect.Message

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResponse 

type StartResponse struct {
	MountPoint                   string `protobuf:"bytes,1,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	UsageControlEnabled          bool   `protobuf:"varint,2,opt,name=usage_control_enabled,json=usageControlEnabled,proto3" json:"usage_control_enabled,omitempty"`
	MessageQueuePublisherEnabled bool   `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartResponse) Descriptor deprecated 

func (*StartResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) GetMessageQueuePublisherEnabled 

func (x *StartResponse) GetMessageQueuePublisherEnabled() bool

func (*StartResponse) GetMountPoint 

func (x *StartResponse) GetMountPoint() string

func (*StartResponse) GetUsageControlEnabled 

func (x *StartResponse) GetUsageControlEnabled() bool

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

func (x *StartResponse) ProtoReflect() protoreflect.Message

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

type StopRequest 

type StopRequest struct {
	PodNamespace                string                      `protobuf:"bytes,1,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	PodName                     string                      `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	MountPointToExecutablePaths map[string]*ExecutablePaths `` /* 236-byte string literal not displayed */
	MountPoint                  string                      `protobuf:"bytes,4,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated 

func (*StopRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) GetMountPoint 

func (x *StopRequest) GetMountPoint() string

func (*StopRequest) GetMountPointToExecutablePaths 

func (x *StopRequest) GetMountPointToExecutablePaths() map[string]*ExecutablePaths

func (*StopRequest) GetPodName 

func (x *StopRequest) GetPodName() string

func (*StopRequest) GetPodNamespace 

func (x *StopRequest) GetPodNamespace() string

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

func (x *StopRequest) ProtoReflect() protoreflect.Message

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

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

func (*StopResponse) Descriptor deprecated 

func (*StopResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

func (x *StopResponse) ProtoReflect() protoreflect.Message

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type UnimplementedVolumeControlServer 

type UnimplementedVolumeControlServer struct {
}

UnimplementedVolumeControlServer can be embedded to have forward compatible implementations.

func (*UnimplementedVolumeControlServer) Finalize 

func (*UnimplementedVolumeControlServer) Finalize(context.Context, *FinalizeRequest) (*FinalizeResponse, error)

func (*UnimplementedVolumeControlServer) Initialize 

func (*UnimplementedVolumeControlServer) Initialize(context.Context, *InitializeRequest) (*InitializeResponse, error)

func (*UnimplementedVolumeControlServer) Start 

func (*UnimplementedVolumeControlServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (*UnimplementedVolumeControlServer) Stop 

func (*UnimplementedVolumeControlServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

func (*UnimplementedVolumeControlServer) UpdateAllowedExecutables 

func (*UnimplementedVolumeControlServer) UpdateAllowedExecutables(context.Context, *UpdateAllowedExecutablesRequest) (*UpdateAllowedExecutablesResponse, error)

func (*UnimplementedVolumeControlServer) UpdateMessageQueueConfig 

func (*UnimplementedVolumeControlServer) UpdateMessageQueueConfig(context.Context, *UpdateMessageQueueConfigRequest) (*UpdateMessageQueueConfigResponse, error)

type UpdateAllowedExecutablesRequest 

type UpdateAllowedExecutablesRequest struct {
	PodNamespace     string                       `protobuf:"bytes,1,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	PodName          string                       `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	ExecutablesDiffs map[string]*ExecutablesDiffs `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateAllowedExecutablesRequest) Descriptor deprecated 

func (*UpdateAllowedExecutablesRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateAllowedExecutablesRequest.ProtoReflect.Descriptor instead.

func (*UpdateAllowedExecutablesRequest) GetExecutablesDiffs 

func (x *UpdateAllowedExecutablesRequest) GetExecutablesDiffs() map[string]*ExecutablesDiffs

func (*UpdateAllowedExecutablesRequest) GetPodName 

func (x *UpdateAllowedExecutablesRequest) GetPodName() string

func (*UpdateAllowedExecutablesRequest) GetPodNamespace 

func (x *UpdateAllowedExecutablesRequest) GetPodNamespace() string

func (*UpdateAllowedExecutablesRequest) ProtoMessage 

func (*UpdateAllowedExecutablesRequest) ProtoMessage()

func (*UpdateAllowedExecutablesRequest) ProtoReflect 

func (x *UpdateAllowedExecutablesRequest) ProtoReflect() protoreflect.Message

func (*UpdateAllowedExecutablesRequest) Reset 

func (x *UpdateAllowedExecutablesRequest) Reset()

func (*UpdateAllowedExecutablesRequest) String 

func (x *UpdateAllowedExecutablesRequest) String() string

type UpdateAllowedExecutablesResponse 

type UpdateAllowedExecutablesResponse struct {
	PvcKeyToMountPoint map[string]string `` /* 209-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateAllowedExecutablesResponse) Descriptor deprecated 

func (*UpdateAllowedExecutablesResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateAllowedExecutablesResponse.ProtoReflect.Descriptor instead.

func (*UpdateAllowedExecutablesResponse) GetPvcKeyToMountPoint 

func (x *UpdateAllowedExecutablesResponse) GetPvcKeyToMountPoint() map[string]string

func (*UpdateAllowedExecutablesResponse) ProtoMessage 

func (*UpdateAllowedExecutablesResponse) ProtoMessage()

func (*UpdateAllowedExecutablesResponse) ProtoReflect 

func (x *UpdateAllowedExecutablesResponse) ProtoReflect() protoreflect.Message

func (*UpdateAllowedExecutablesResponse) Reset 

func (x *UpdateAllowedExecutablesResponse) Reset()

func (*UpdateAllowedExecutablesResponse) String 

func (x *UpdateAllowedExecutablesResponse) String() string

type UpdateMessageQueueConfigRequest 

type UpdateMessageQueueConfigRequest struct {
	PodNamespace      string                   `protobuf:"bytes,1,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	PodName           string                   `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	MessageQueueDiffs map[string]*MessageQueue `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateMessageQueueConfigRequest) Descriptor deprecated 

func (*UpdateMessageQueueConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateMessageQueueConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateMessageQueueConfigRequest) GetMessageQueueDiffs 

func (x *UpdateMessageQueueConfigRequest) GetMessageQueueDiffs() map[string]*MessageQueue

func (*UpdateMessageQueueConfigRequest) GetPodName 

func (x *UpdateMessageQueueConfigRequest) GetPodName() string

func (*UpdateMessageQueueConfigRequest) GetPodNamespace 

func (x *UpdateMessageQueueConfigRequest) GetPodNamespace() string

func (*UpdateMessageQueueConfigRequest) ProtoMessage 

func (*UpdateMessageQueueConfigRequest) ProtoMessage()

func (*UpdateMessageQueueConfigRequest) ProtoReflect 

func (x *UpdateMessageQueueConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateMessageQueueConfigRequest) Reset 

func (x *UpdateMessageQueueConfigRequest) Reset()

func (*UpdateMessageQueueConfigRequest) String 

func (x *UpdateMessageQueueConfigRequest) String() string

type UpdateMessageQueueConfigResponse 

type UpdateMessageQueueConfigResponse struct {
	PvcKeyToMountPoint map[string]string `` /* 209-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateMessageQueueConfigResponse) Descriptor deprecated 

func (*UpdateMessageQueueConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateMessageQueueConfigResponse.ProtoReflect.Descriptor instead.

func (*UpdateMessageQueueConfigResponse) GetPvcKeyToMountPoint 

func (x *UpdateMessageQueueConfigResponse) GetPvcKeyToMountPoint() map[string]string

func (*UpdateMessageQueueConfigResponse) ProtoMessage 

func (*UpdateMessageQueueConfigResponse) ProtoMessage()

func (*UpdateMessageQueueConfigResponse) ProtoReflect 

func (x *UpdateMessageQueueConfigResponse) ProtoReflect() protoreflect.Message

func (*UpdateMessageQueueConfigResponse) Reset 

func (x *UpdateMessageQueueConfigResponse) Reset()

func (*UpdateMessageQueueConfigResponse) String 

func (x *UpdateMessageQueueConfigResponse) String() string

type VolumeControlClient 

type VolumeControlClient interface {
	Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*InitializeResponse, error)
	Finalize(ctx context.Context, in *FinalizeRequest, opts ...grpc.CallOption) (*FinalizeResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	UpdateAllowedExecutables(ctx context.Context, in *UpdateAllowedExecutablesRequest, opts ...grpc.CallOption) (*UpdateAllowedExecutablesResponse, error)
	UpdateMessageQueueConfig(ctx context.Context, in *UpdateMessageQueueConfigRequest, opts ...grpc.CallOption) (*UpdateMessageQueueConfigResponse, error)
}

VolumeControlClient is the client API for VolumeControl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVolumeControlClient 

func NewVolumeControlClient(cc grpc.ClientConnInterface) VolumeControlClient

type VolumeControlServer 

type VolumeControlServer interface {
	Initialize(context.Context, *InitializeRequest) (*InitializeResponse, error)
	Finalize(context.Context, *FinalizeRequest) (*FinalizeResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	UpdateAllowedExecutables(context.Context, *UpdateAllowedExecutablesRequest) (*UpdateAllowedExecutablesResponse, error)
	UpdateMessageQueueConfig(context.Context, *UpdateMessageQueueConfigRequest) (*UpdateMessageQueueConfigResponse, error)
}

VolumeControlServer is the server API for VolumeControl service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.