imrpc

package
v1.5.2-rc3 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BackendStoreDriver_name = map[int32]string{
	0: "v1",
	1: "v2",
}
View Source 
var BackendStoreDriver_value = map[string]int32{
	"v1": 0,
	"v2": 1,
}
View Source 
var DiskType_name = map[int32]string{
	0: "filesystem",
	1: "block",
}
View Source 
var DiskType_value = map[string]int32{
	"filesystem": 0,
	"block":      1,
}

Functions

func RegisterDiskServiceServer added in v1.5.0 

func RegisterDiskServiceServer(s *grpc.Server, srv DiskServiceServer)

func RegisterInstanceServiceServer added in v1.5.0 

func RegisterInstanceServiceServer(s *grpc.Server, srv InstanceServiceServer)

func RegisterProcessManagerServiceServer 

func RegisterProcessManagerServiceServer(s *grpc.Server, srv ProcessManagerServiceServer)

func RegisterProxyEngineServiceServer 

func RegisterProxyEngineServiceServer(s *grpc.Server, srv ProxyEngineServiceServer)

Types

type BackendStoreDriver added in v1.5.0 

type BackendStoreDriver int32
const (
	BackendStoreDriver_v1 BackendStoreDriver = 0
	BackendStoreDriver_v2 BackendStoreDriver = 1
)

func (BackendStoreDriver) EnumDescriptor added in v1.5.0 

func (BackendStoreDriver) EnumDescriptor() ([]byte, []int)

func (BackendStoreDriver) String added in v1.5.0 

func (x BackendStoreDriver) String() string

type Disk added in v1.5.0 

type Disk struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid                 string   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	TotalSize            int64    `protobuf:"varint,5,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	FreeSize             int64    `protobuf:"varint,6,opt,name=free_size,json=freeSize,proto3" json:"free_size,omitempty"`
	TotalBlocks          int64    `protobuf:"varint,7,opt,name=total_blocks,json=totalBlocks,proto3" json:"total_blocks,omitempty"`
	FreeBlocks           int64    `protobuf:"varint,8,opt,name=free_blocks,json=freeBlocks,proto3" json:"free_blocks,omitempty"`
	BlockSize            int64    `protobuf:"varint,9,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	ClusterSize          int64    `protobuf:"varint,10,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Disk) Descriptor added in v1.5.0 

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

func (*Disk) GetBlockSize added in v1.5.0 

func (m *Disk) GetBlockSize() int64

func (*Disk) GetClusterSize added in v1.5.0 

func (m *Disk) GetClusterSize() int64

func (*Disk) GetFreeBlocks added in v1.5.0 

func (m *Disk) GetFreeBlocks() int64

func (*Disk) GetFreeSize added in v1.5.0 

func (m *Disk) GetFreeSize() int64

func (*Disk) GetId added in v1.5.0 

func (m *Disk) GetId() string

func (*Disk) GetPath added in v1.5.0 

func (m *Disk) GetPath() string

func (*Disk) GetTotalBlocks added in v1.5.0 

func (m *Disk) GetTotalBlocks() int64

func (*Disk) GetTotalSize added in v1.5.0 

func (m *Disk) GetTotalSize() int64

func (*Disk) GetType added in v1.5.0 

func (m *Disk) GetType() string

func (*Disk) GetUuid added in v1.5.0 

func (m *Disk) GetUuid() string

func (*Disk) ProtoMessage added in v1.5.0 

func (*Disk) ProtoMessage()

func (*Disk) Reset added in v1.5.0 

func (m *Disk) Reset()

func (*Disk) String added in v1.5.0 

func (m *Disk) String() string

func (*Disk) XXX_DiscardUnknown added in v1.5.0 

func (m *Disk) XXX_DiscardUnknown()

func (*Disk) XXX_Marshal added in v1.5.0 

func (m *Disk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Disk) XXX_Merge added in v1.5.0 

func (m *Disk) XXX_Merge(src proto.Message)

func (*Disk) XXX_Size added in v1.5.0 

func (m *Disk) XXX_Size() int

func (*Disk) XXX_Unmarshal added in v1.5.0 

func (m *Disk) XXX_Unmarshal(b []byte) error

type DiskCreateRequest added in v1.5.0 

type DiskCreateRequest struct {
	DiskType             DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName             string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid             string   `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	DiskPath             string   `protobuf:"bytes,4,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	BlockSize            int64    `protobuf:"varint,5,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskCreateRequest) Descriptor added in v1.5.0 

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

func (*DiskCreateRequest) GetBlockSize added in v1.5.0 

func (m *DiskCreateRequest) GetBlockSize() int64

func (*DiskCreateRequest) GetDiskName added in v1.5.0 

func (m *DiskCreateRequest) GetDiskName() string

func (*DiskCreateRequest) GetDiskPath added in v1.5.0 

func (m *DiskCreateRequest) GetDiskPath() string

func (*DiskCreateRequest) GetDiskType added in v1.5.0 

func (m *DiskCreateRequest) GetDiskType() DiskType

func (*DiskCreateRequest) GetDiskUuid added in v1.5.0 

func (m *DiskCreateRequest) GetDiskUuid() string

func (*DiskCreateRequest) ProtoMessage added in v1.5.0 

func (*DiskCreateRequest) ProtoMessage()

func (*DiskCreateRequest) Reset added in v1.5.0 

func (m *DiskCreateRequest) Reset()

func (*DiskCreateRequest) String added in v1.5.0 

func (m *DiskCreateRequest) String() string

func (*DiskCreateRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskCreateRequest) XXX_DiscardUnknown()

func (*DiskCreateRequest) XXX_Marshal added in v1.5.0 

func (m *DiskCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskCreateRequest) XXX_Merge added in v1.5.0 

func (m *DiskCreateRequest) XXX_Merge(src proto.Message)

func (*DiskCreateRequest) XXX_Size added in v1.5.0 

func (m *DiskCreateRequest) XXX_Size() int

func (*DiskCreateRequest) XXX_Unmarshal added in v1.5.0 

func (m *DiskCreateRequest) XXX_Unmarshal(b []byte) error

type DiskDeleteRequest added in v1.5.0 

type DiskDeleteRequest struct {
	DiskType             DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName             string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid             string   `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskDeleteRequest) Descriptor added in v1.5.0 

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

func (*DiskDeleteRequest) GetDiskName added in v1.5.0 

func (m *DiskDeleteRequest) GetDiskName() string

func (*DiskDeleteRequest) GetDiskType added in v1.5.0 

func (m *DiskDeleteRequest) GetDiskType() DiskType

func (*DiskDeleteRequest) GetDiskUuid added in v1.5.0 

func (m *DiskDeleteRequest) GetDiskUuid() string

func (*DiskDeleteRequest) ProtoMessage added in v1.5.0 

func (*DiskDeleteRequest) ProtoMessage()

func (*DiskDeleteRequest) Reset added in v1.5.0 

func (m *DiskDeleteRequest) Reset()

func (*DiskDeleteRequest) String added in v1.5.0 

func (m *DiskDeleteRequest) String() string

func (*DiskDeleteRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskDeleteRequest) XXX_DiscardUnknown()

func (*DiskDeleteRequest) XXX_Marshal added in v1.5.0 

func (m *DiskDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskDeleteRequest) XXX_Merge added in v1.5.0 

func (m *DiskDeleteRequest) XXX_Merge(src proto.Message)

func (*DiskDeleteRequest) XXX_Size added in v1.5.0 

func (m *DiskDeleteRequest) XXX_Size() int

func (*DiskDeleteRequest) XXX_Unmarshal added in v1.5.0 

func (m *DiskDeleteRequest) XXX_Unmarshal(b []byte) error

type DiskGetRequest added in v1.5.0 

type DiskGetRequest struct {
	DiskType             DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName             string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskPath             string   `protobuf:"bytes,3,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskGetRequest) Descriptor added in v1.5.0 

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

func (*DiskGetRequest) GetDiskName added in v1.5.0 

func (m *DiskGetRequest) GetDiskName() string

func (*DiskGetRequest) GetDiskPath added in v1.5.0 

func (m *DiskGetRequest) GetDiskPath() string

func (*DiskGetRequest) GetDiskType added in v1.5.0 

func (m *DiskGetRequest) GetDiskType() DiskType

func (*DiskGetRequest) ProtoMessage added in v1.5.0 

func (*DiskGetRequest) ProtoMessage()

func (*DiskGetRequest) Reset added in v1.5.0 

func (m *DiskGetRequest) Reset()

func (*DiskGetRequest) String added in v1.5.0 

func (m *DiskGetRequest) String() string

func (*DiskGetRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskGetRequest) XXX_DiscardUnknown()

func (*DiskGetRequest) XXX_Marshal added in v1.5.0 

func (m *DiskGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskGetRequest) XXX_Merge added in v1.5.0 

func (m *DiskGetRequest) XXX_Merge(src proto.Message)

func (*DiskGetRequest) XXX_Size added in v1.5.0 

func (m *DiskGetRequest) XXX_Size() int

func (*DiskGetRequest) XXX_Unmarshal added in v1.5.0 

func (m *DiskGetRequest) XXX_Unmarshal(b []byte) error

type DiskReplicaInstanceDeleteRequest added in v1.5.0 

type DiskReplicaInstanceDeleteRequest struct {
	DiskType             DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName             string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid             string   `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	ReplciaInstanceName  string   `protobuf:"bytes,4,opt,name=replcia_instance_name,json=replciaInstanceName,proto3" json:"replcia_instance_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskReplicaInstanceDeleteRequest) Descriptor added in v1.5.0 

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

func (*DiskReplicaInstanceDeleteRequest) GetDiskName added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) GetDiskName() string

func (*DiskReplicaInstanceDeleteRequest) GetDiskType added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) GetDiskType() DiskType

func (*DiskReplicaInstanceDeleteRequest) GetDiskUuid added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) GetDiskUuid() string

func (*DiskReplicaInstanceDeleteRequest) GetReplciaInstanceName added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) GetReplciaInstanceName() string

func (*DiskReplicaInstanceDeleteRequest) ProtoMessage added in v1.5.0 

func (*DiskReplicaInstanceDeleteRequest) ProtoMessage()

func (*DiskReplicaInstanceDeleteRequest) Reset added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) Reset()

func (*DiskReplicaInstanceDeleteRequest) String added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) String() string

func (*DiskReplicaInstanceDeleteRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) XXX_DiscardUnknown()

func (*DiskReplicaInstanceDeleteRequest) XXX_Marshal added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskReplicaInstanceDeleteRequest) XXX_Merge added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) XXX_Merge(src proto.Message)

func (*DiskReplicaInstanceDeleteRequest) XXX_Size added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) XXX_Size() int

func (*DiskReplicaInstanceDeleteRequest) XXX_Unmarshal added in v1.5.0 

func (m *DiskReplicaInstanceDeleteRequest) XXX_Unmarshal(b []byte) error

type DiskReplicaInstanceListRequest added in v1.5.0 

type DiskReplicaInstanceListRequest struct {
	DiskType             DiskType `protobuf:"varint,1,opt,name=disk_type,json=diskType,proto3,enum=imrpc.DiskType" json:"disk_type,omitempty"`
	DiskName             string   `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskReplicaInstanceListRequest) Descriptor added in v1.5.0 

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

func (*DiskReplicaInstanceListRequest) GetDiskName added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) GetDiskName() string

func (*DiskReplicaInstanceListRequest) GetDiskType added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) GetDiskType() DiskType

func (*DiskReplicaInstanceListRequest) ProtoMessage added in v1.5.0 

func (*DiskReplicaInstanceListRequest) ProtoMessage()

func (*DiskReplicaInstanceListRequest) Reset added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) Reset()

func (*DiskReplicaInstanceListRequest) String added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) String() string

func (*DiskReplicaInstanceListRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) XXX_DiscardUnknown()

func (*DiskReplicaInstanceListRequest) XXX_Marshal added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskReplicaInstanceListRequest) XXX_Merge added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) XXX_Merge(src proto.Message)

func (*DiskReplicaInstanceListRequest) XXX_Size added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) XXX_Size() int

func (*DiskReplicaInstanceListRequest) XXX_Unmarshal added in v1.5.0 

func (m *DiskReplicaInstanceListRequest) XXX_Unmarshal(b []byte) error

type DiskReplicaInstanceListResponse added in v1.5.0 

type DiskReplicaInstanceListResponse struct {
	ReplicaInstances     map[string]*ReplicaInstance `` /* 197-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*DiskReplicaInstanceListResponse) Descriptor added in v1.5.0 

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

func (*DiskReplicaInstanceListResponse) GetReplicaInstances added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) GetReplicaInstances() map[string]*ReplicaInstance

func (*DiskReplicaInstanceListResponse) ProtoMessage added in v1.5.0 

func (*DiskReplicaInstanceListResponse) ProtoMessage()

func (*DiskReplicaInstanceListResponse) Reset added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) Reset()

func (*DiskReplicaInstanceListResponse) String added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) String() string

func (*DiskReplicaInstanceListResponse) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) XXX_DiscardUnknown()

func (*DiskReplicaInstanceListResponse) XXX_Marshal added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskReplicaInstanceListResponse) XXX_Merge added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) XXX_Merge(src proto.Message)

func (*DiskReplicaInstanceListResponse) XXX_Size added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) XXX_Size() int

func (*DiskReplicaInstanceListResponse) XXX_Unmarshal added in v1.5.0 

func (m *DiskReplicaInstanceListResponse) XXX_Unmarshal(b []byte) error

type DiskServiceClient added in v1.5.0 

type DiskServiceClient interface {
	DiskCreate(ctx context.Context, in *DiskCreateRequest, opts ...grpc.CallOption) (*Disk, error)
	DiskDelete(ctx context.Context, in *DiskDeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DiskGet(ctx context.Context, in *DiskGetRequest, opts ...grpc.CallOption) (*Disk, error)
	DiskReplicaInstanceList(ctx context.Context, in *DiskReplicaInstanceListRequest, opts ...grpc.CallOption) (*DiskReplicaInstanceListResponse, error)
	DiskReplicaInstanceDelete(ctx context.Context, in *DiskReplicaInstanceDeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VersionGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DiskVersionResponse, error)
}

DiskServiceClient is the client API for DiskService service.

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

func NewDiskServiceClient added in v1.5.0 

func NewDiskServiceClient(cc *grpc.ClientConn) DiskServiceClient

type DiskServiceServer added in v1.5.0 

type DiskServiceServer interface {
	DiskCreate(context.Context, *DiskCreateRequest) (*Disk, error)
	DiskDelete(context.Context, *DiskDeleteRequest) (*empty.Empty, error)
	DiskGet(context.Context, *DiskGetRequest) (*Disk, error)
	DiskReplicaInstanceList(context.Context, *DiskReplicaInstanceListRequest) (*DiskReplicaInstanceListResponse, error)
	DiskReplicaInstanceDelete(context.Context, *DiskReplicaInstanceDeleteRequest) (*empty.Empty, error)
	VersionGet(context.Context, *empty.Empty) (*DiskVersionResponse, error)
}

DiskServiceServer is the server API for DiskService service.

type DiskType added in v1.5.0 

type DiskType int32
const (
	DiskType_filesystem DiskType = 0
	DiskType_block      DiskType = 1
)

func (DiskType) EnumDescriptor added in v1.5.0 

func (DiskType) EnumDescriptor() ([]byte, []int)

func (DiskType) String added in v1.5.0 

func (x DiskType) String() string

type DiskVersionResponse added in v1.5.0 

type DiskVersionResponse struct {
	Version                                 string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	GitCommit                               string   `protobuf:"bytes,2,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"`
	BuildDate                               string   `protobuf:"bytes,3,opt,name=buildDate,proto3" json:"buildDate,omitempty"`
	InstanceManagerDiskServiceAPIVersion    int64    `` /* 126-byte string literal not displayed */
	InstanceManagerDiskServiceAPIMinVersion int64    `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral                    struct{} `json:"-"`
	XXX_unrecognized                        []byte   `json:"-"`
	XXX_sizecache                           int32    `json:"-"`
}

func (*DiskVersionResponse) Descriptor added in v1.5.0 

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

func (*DiskVersionResponse) GetBuildDate added in v1.5.0 

func (m *DiskVersionResponse) GetBuildDate() string

func (*DiskVersionResponse) GetGitCommit added in v1.5.0 

func (m *DiskVersionResponse) GetGitCommit() string

func (*DiskVersionResponse) GetInstanceManagerDiskServiceAPIMinVersion added in v1.5.0 

func (m *DiskVersionResponse) GetInstanceManagerDiskServiceAPIMinVersion() int64

func (*DiskVersionResponse) GetInstanceManagerDiskServiceAPIVersion added in v1.5.0 

func (m *DiskVersionResponse) GetInstanceManagerDiskServiceAPIVersion() int64

func (*DiskVersionResponse) GetVersion added in v1.5.0 

func (m *DiskVersionResponse) GetVersion() string

func (*DiskVersionResponse) ProtoMessage added in v1.5.0 

func (*DiskVersionResponse) ProtoMessage()

func (*DiskVersionResponse) Reset added in v1.5.0 

func (m *DiskVersionResponse) Reset()

func (*DiskVersionResponse) String added in v1.5.0 

func (m *DiskVersionResponse) String() string

func (*DiskVersionResponse) XXX_DiscardUnknown added in v1.5.0 

func (m *DiskVersionResponse) XXX_DiscardUnknown()

func (*DiskVersionResponse) XXX_Marshal added in v1.5.0 

func (m *DiskVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskVersionResponse) XXX_Merge added in v1.5.0 

func (m *DiskVersionResponse) XXX_Merge(src proto.Message)

func (*DiskVersionResponse) XXX_Size added in v1.5.0 

func (m *DiskVersionResponse) XXX_Size() int

func (*DiskVersionResponse) XXX_Unmarshal added in v1.5.0 

func (m *DiskVersionResponse) XXX_Unmarshal(b []byte) error

type EngineBackupRestoreProxyResponse 

type EngineBackupRestoreProxyResponse struct {
	TaskError            []byte   `protobuf:"bytes,1,opt,name=taskError,proto3" json:"taskError,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EngineBackupRestoreProxyResponse) Descriptor 

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

func (*EngineBackupRestoreProxyResponse) GetTaskError 

func (m *EngineBackupRestoreProxyResponse) GetTaskError() []byte

func (*EngineBackupRestoreProxyResponse) ProtoMessage 

func (*EngineBackupRestoreProxyResponse) ProtoMessage()

func (*EngineBackupRestoreProxyResponse) Reset 

func (m *EngineBackupRestoreProxyResponse) Reset()

func (*EngineBackupRestoreProxyResponse) String 

func (m *EngineBackupRestoreProxyResponse) String() string

func (*EngineBackupRestoreProxyResponse) XXX_DiscardUnknown 

func (m *EngineBackupRestoreProxyResponse) XXX_DiscardUnknown()

func (*EngineBackupRestoreProxyResponse) XXX_Marshal 

func (m *EngineBackupRestoreProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineBackupRestoreProxyResponse) XXX_Merge 

func (m *EngineBackupRestoreProxyResponse) XXX_Merge(src proto.Message)

func (*EngineBackupRestoreProxyResponse) XXX_Size 

func (m *EngineBackupRestoreProxyResponse) XXX_Size() int

func (*EngineBackupRestoreProxyResponse) XXX_Unmarshal 

func (m *EngineBackupRestoreProxyResponse) XXX_Unmarshal(b []byte) error

type EngineBackupRestoreRequest 

type EngineBackupRestoreRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Envs                 []string            `protobuf:"bytes,2,rep,name=envs,proto3" json:"envs,omitempty"`
	Url                  string              `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Target               string              `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	VolumeName           string              `protobuf:"bytes,5,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	ConcurrentLimit      int32               `protobuf:"varint,6,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineBackupRestoreRequest) Descriptor 

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

func (*EngineBackupRestoreRequest) GetConcurrentLimit added in v1.5.0 

func (m *EngineBackupRestoreRequest) GetConcurrentLimit() int32

func (*EngineBackupRestoreRequest) GetEnvs 

func (m *EngineBackupRestoreRequest) GetEnvs() []string

func (*EngineBackupRestoreRequest) GetProxyEngineRequest 

func (m *EngineBackupRestoreRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineBackupRestoreRequest) GetTarget 

func (m *EngineBackupRestoreRequest) GetTarget() string

func (*EngineBackupRestoreRequest) GetUrl 

func (m *EngineBackupRestoreRequest) GetUrl() string

func (*EngineBackupRestoreRequest) GetVolumeName 

func (m *EngineBackupRestoreRequest) GetVolumeName() string

func (*EngineBackupRestoreRequest) ProtoMessage 

func (*EngineBackupRestoreRequest) ProtoMessage()

func (*EngineBackupRestoreRequest) Reset 

func (m *EngineBackupRestoreRequest) Reset()

func (*EngineBackupRestoreRequest) String 

func (m *EngineBackupRestoreRequest) String() string

func (*EngineBackupRestoreRequest) XXX_DiscardUnknown 

func (m *EngineBackupRestoreRequest) XXX_DiscardUnknown()

func (*EngineBackupRestoreRequest) XXX_Marshal 

func (m *EngineBackupRestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineBackupRestoreRequest) XXX_Merge 

func (m *EngineBackupRestoreRequest) XXX_Merge(src proto.Message)

func (*EngineBackupRestoreRequest) XXX_Size 

func (m *EngineBackupRestoreRequest) XXX_Size() int

func (*EngineBackupRestoreRequest) XXX_Unmarshal 

func (m *EngineBackupRestoreRequest) XXX_Unmarshal(b []byte) error

type EngineBackupRestoreStatus 

type EngineBackupRestoreStatus struct {
	IsRestoring            bool     `protobuf:"varint,1,opt,name=is_restoring,json=isRestoring,proto3" json:"is_restoring,omitempty"`
	LastRestored           string   `protobuf:"bytes,2,opt,name=last_restored,json=lastRestored,proto3" json:"last_restored,omitempty"`
	CurrentRestoringBackup string   `` /* 129-byte string literal not displayed */
	Progress               int32    `protobuf:"varint,4,opt,name=progress,proto3" json:"progress,omitempty"`
	Error                  string   `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Filename               string   `protobuf:"bytes,6,opt,name=filename,proto3" json:"filename,omitempty"`
	State                  string   `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"`
	BackupUrl              string   `protobuf:"bytes,8,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,omitempty"`
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*EngineBackupRestoreStatus) Descriptor 

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

func (*EngineBackupRestoreStatus) GetBackupUrl 

func (m *EngineBackupRestoreStatus) GetBackupUrl() string

func (*EngineBackupRestoreStatus) GetCurrentRestoringBackup 

func (m *EngineBackupRestoreStatus) GetCurrentRestoringBackup() string

func (*EngineBackupRestoreStatus) GetError 

func (m *EngineBackupRestoreStatus) GetError() string

func (*EngineBackupRestoreStatus) GetFilename 

func (m *EngineBackupRestoreStatus) GetFilename() string

func (*EngineBackupRestoreStatus) GetIsRestoring 

func (m *EngineBackupRestoreStatus) GetIsRestoring() bool

func (*EngineBackupRestoreStatus) GetLastRestored 

func (m *EngineBackupRestoreStatus) GetLastRestored() string

func (*EngineBackupRestoreStatus) GetProgress 

func (m *EngineBackupRestoreStatus) GetProgress() int32

func (*EngineBackupRestoreStatus) GetState 

func (m *EngineBackupRestoreStatus) GetState() string

func (*EngineBackupRestoreStatus) ProtoMessage 

func (*EngineBackupRestoreStatus) ProtoMessage()

func (*EngineBackupRestoreStatus) Reset 

func (m *EngineBackupRestoreStatus) Reset()

func (*EngineBackupRestoreStatus) String 

func (m *EngineBackupRestoreStatus) String() string

func (*EngineBackupRestoreStatus) XXX_DiscardUnknown 

func (m *EngineBackupRestoreStatus) XXX_DiscardUnknown()

func (*EngineBackupRestoreStatus) XXX_Marshal 

func (m *EngineBackupRestoreStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineBackupRestoreStatus) XXX_Merge 

func (m *EngineBackupRestoreStatus) XXX_Merge(src proto.Message)

func (*EngineBackupRestoreStatus) XXX_Size 

func (m *EngineBackupRestoreStatus) XXX_Size() int

func (*EngineBackupRestoreStatus) XXX_Unmarshal 

func (m *EngineBackupRestoreStatus) XXX_Unmarshal(b []byte) error

type EngineBackupRestoreStatusProxyResponse 

type EngineBackupRestoreStatusProxyResponse struct {
	Status               map[string]*EngineBackupRestoreStatus `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*EngineBackupRestoreStatusProxyResponse) Descriptor 

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

func (*EngineBackupRestoreStatusProxyResponse) GetStatus 

func (m *EngineBackupRestoreStatusProxyResponse) GetStatus() map[string]*EngineBackupRestoreStatus

func (*EngineBackupRestoreStatusProxyResponse) ProtoMessage 

func (*EngineBackupRestoreStatusProxyResponse) ProtoMessage()

func (*EngineBackupRestoreStatusProxyResponse) Reset 

func (m *EngineBackupRestoreStatusProxyResponse) Reset()

func (*EngineBackupRestoreStatusProxyResponse) String 

func (m *EngineBackupRestoreStatusProxyResponse) String() string

func (*EngineBackupRestoreStatusProxyResponse) XXX_DiscardUnknown 

func (m *EngineBackupRestoreStatusProxyResponse) XXX_DiscardUnknown()

func (*EngineBackupRestoreStatusProxyResponse) XXX_Marshal 

func (m *EngineBackupRestoreStatusProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineBackupRestoreStatusProxyResponse) XXX_Merge 

func (m *EngineBackupRestoreStatusProxyResponse) XXX_Merge(src proto.Message)

func (*EngineBackupRestoreStatusProxyResponse) XXX_Size 

func (m *EngineBackupRestoreStatusProxyResponse) XXX_Size() int

func (*EngineBackupRestoreStatusProxyResponse) XXX_Unmarshal 

func (m *EngineBackupRestoreStatusProxyResponse) XXX_Unmarshal(b []byte) error

type EngineMetricsGetProxyResponse 

type EngineMetricsGetProxyResponse struct {
	Metrics              *ptypes.Metrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*EngineMetricsGetProxyResponse) Descriptor 

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

func (*EngineMetricsGetProxyResponse) GetMetrics 

func (m *EngineMetricsGetProxyResponse) GetMetrics() *ptypes.Metrics

func (*EngineMetricsGetProxyResponse) ProtoMessage 

func (*EngineMetricsGetProxyResponse) ProtoMessage()

func (*EngineMetricsGetProxyResponse) Reset 

func (m *EngineMetricsGetProxyResponse) Reset()

func (*EngineMetricsGetProxyResponse) String 

func (m *EngineMetricsGetProxyResponse) String() string

func (*EngineMetricsGetProxyResponse) XXX_DiscardUnknown 

func (m *EngineMetricsGetProxyResponse) XXX_DiscardUnknown()

func (*EngineMetricsGetProxyResponse) XXX_Marshal 

func (m *EngineMetricsGetProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineMetricsGetProxyResponse) XXX_Merge 

func (m *EngineMetricsGetProxyResponse) XXX_Merge(src proto.Message)

func (*EngineMetricsGetProxyResponse) XXX_Size 

func (m *EngineMetricsGetProxyResponse) XXX_Size() int

func (*EngineMetricsGetProxyResponse) XXX_Unmarshal 

func (m *EngineMetricsGetProxyResponse) XXX_Unmarshal(b []byte) error

type EngineReplicaAddRequest 

type EngineReplicaAddRequest struct {
	ProxyEngineRequest        *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress            string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	Restore                   bool                `protobuf:"varint,3,opt,name=restore,proto3" json:"restore,omitempty"`
	Size                      int64               `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	CurrentSize               int64               `protobuf:"varint,5,opt,name=current_size,json=currentSize,proto3" json:"current_size,omitempty"`
	FastSync                  bool                `protobuf:"varint,6,opt,name=fast_sync,json=fastSync,proto3" json:"fast_sync,omitempty"`
	FileSyncHttpClientTimeout int32               `` /* 143-byte string literal not displayed */
	ReplicaName               string              `protobuf:"bytes,8,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}            `json:"-"`
	XXX_unrecognized          []byte              `json:"-"`
	XXX_sizecache             int32               `json:"-"`
}

func (*EngineReplicaAddRequest) Descriptor 

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

func (*EngineReplicaAddRequest) GetCurrentSize 

func (m *EngineReplicaAddRequest) GetCurrentSize() int64

func (*EngineReplicaAddRequest) GetFastSync 

func (m *EngineReplicaAddRequest) GetFastSync() bool

func (*EngineReplicaAddRequest) GetFileSyncHttpClientTimeout 

func (m *EngineReplicaAddRequest) GetFileSyncHttpClientTimeout() int32

func (*EngineReplicaAddRequest) GetProxyEngineRequest 

func (m *EngineReplicaAddRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaAddRequest) GetReplicaAddress 

func (m *EngineReplicaAddRequest) GetReplicaAddress() string

func (*EngineReplicaAddRequest) GetReplicaName added in v1.5.0 

func (m *EngineReplicaAddRequest) GetReplicaName() string

func (*EngineReplicaAddRequest) GetRestore 

func (m *EngineReplicaAddRequest) GetRestore() bool

func (*EngineReplicaAddRequest) GetSize 

func (m *EngineReplicaAddRequest) GetSize() int64

func (*EngineReplicaAddRequest) ProtoMessage 

func (*EngineReplicaAddRequest) ProtoMessage()

func (*EngineReplicaAddRequest) Reset 

func (m *EngineReplicaAddRequest) Reset()

func (*EngineReplicaAddRequest) String 

func (m *EngineReplicaAddRequest) String() string

func (*EngineReplicaAddRequest) XXX_DiscardUnknown 

func (m *EngineReplicaAddRequest) XXX_DiscardUnknown()

func (*EngineReplicaAddRequest) XXX_Marshal 

func (m *EngineReplicaAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineReplicaAddRequest) XXX_Merge 

func (m *EngineReplicaAddRequest) XXX_Merge(src proto.Message)

func (*EngineReplicaAddRequest) XXX_Size 

func (m *EngineReplicaAddRequest) XXX_Size() int

func (*EngineReplicaAddRequest) XXX_Unmarshal 

func (m *EngineReplicaAddRequest) XXX_Unmarshal(b []byte) error

type EngineReplicaListProxyResponse 

type EngineReplicaListProxyResponse struct {
	ReplicaList          *ptypes.ReplicaListReply `protobuf:"bytes,1,opt,name=replica_list,json=replicaList,proto3" json:"replica_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*EngineReplicaListProxyResponse) Descriptor 

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

func (*EngineReplicaListProxyResponse) GetReplicaList 

func (m *EngineReplicaListProxyResponse) GetReplicaList() *ptypes.ReplicaListReply

func (*EngineReplicaListProxyResponse) ProtoMessage 

func (*EngineReplicaListProxyResponse) ProtoMessage()

func (*EngineReplicaListProxyResponse) Reset 

func (m *EngineReplicaListProxyResponse) Reset()

func (*EngineReplicaListProxyResponse) String 

func (m *EngineReplicaListProxyResponse) String() string

func (*EngineReplicaListProxyResponse) XXX_DiscardUnknown 

func (m *EngineReplicaListProxyResponse) XXX_DiscardUnknown()

func (*EngineReplicaListProxyResponse) XXX_Marshal 

func (m *EngineReplicaListProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineReplicaListProxyResponse) XXX_Merge 

func (m *EngineReplicaListProxyResponse) XXX_Merge(src proto.Message)

func (*EngineReplicaListProxyResponse) XXX_Size 

func (m *EngineReplicaListProxyResponse) XXX_Size() int

func (*EngineReplicaListProxyResponse) XXX_Unmarshal 

func (m *EngineReplicaListProxyResponse) XXX_Unmarshal(b []byte) error

type EngineReplicaModeUpdateRequest 

type EngineReplicaModeUpdateRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress       string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	Mode                 ptypes.ReplicaMode  `protobuf:"varint,3,opt,name=mode,proto3,enum=ptypes.ReplicaMode" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineReplicaModeUpdateRequest) Descriptor 

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

func (*EngineReplicaModeUpdateRequest) GetMode 

func (m *EngineReplicaModeUpdateRequest) GetMode() ptypes.ReplicaMode

func (*EngineReplicaModeUpdateRequest) GetProxyEngineRequest 

func (m *EngineReplicaModeUpdateRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaModeUpdateRequest) GetReplicaAddress 

func (m *EngineReplicaModeUpdateRequest) GetReplicaAddress() string

func (*EngineReplicaModeUpdateRequest) ProtoMessage 

func (*EngineReplicaModeUpdateRequest) ProtoMessage()

func (*EngineReplicaModeUpdateRequest) Reset 

func (m *EngineReplicaModeUpdateRequest) Reset()

func (*EngineReplicaModeUpdateRequest) String 

func (m *EngineReplicaModeUpdateRequest) String() string

func (*EngineReplicaModeUpdateRequest) XXX_DiscardUnknown 

func (m *EngineReplicaModeUpdateRequest) XXX_DiscardUnknown()

func (*EngineReplicaModeUpdateRequest) XXX_Marshal 

func (m *EngineReplicaModeUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineReplicaModeUpdateRequest) XXX_Merge 

func (m *EngineReplicaModeUpdateRequest) XXX_Merge(src proto.Message)

func (*EngineReplicaModeUpdateRequest) XXX_Size 

func (m *EngineReplicaModeUpdateRequest) XXX_Size() int

func (*EngineReplicaModeUpdateRequest) XXX_Unmarshal 

func (m *EngineReplicaModeUpdateRequest) XXX_Unmarshal(b []byte) error

type EngineReplicaRebuildStatusProxyResponse 

type EngineReplicaRebuildStatusProxyResponse struct {
	Status               map[string]*ptypes.ReplicaRebuildStatusResponse `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*EngineReplicaRebuildStatusProxyResponse) Descriptor 

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

func (*EngineReplicaRebuildStatusProxyResponse) GetStatus 

func (m *EngineReplicaRebuildStatusProxyResponse) GetStatus() map[string]*ptypes.ReplicaRebuildStatusResponse

func (*EngineReplicaRebuildStatusProxyResponse) ProtoMessage 

func (*EngineReplicaRebuildStatusProxyResponse) ProtoMessage()

func (*EngineReplicaRebuildStatusProxyResponse) Reset 

func (m *EngineReplicaRebuildStatusProxyResponse) Reset()

func (*EngineReplicaRebuildStatusProxyResponse) String 

func (m *EngineReplicaRebuildStatusProxyResponse) String() string

func (*EngineReplicaRebuildStatusProxyResponse) XXX_DiscardUnknown 

func (m *EngineReplicaRebuildStatusProxyResponse) XXX_DiscardUnknown()

func (*EngineReplicaRebuildStatusProxyResponse) XXX_Marshal 

func (m *EngineReplicaRebuildStatusProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineReplicaRebuildStatusProxyResponse) XXX_Merge 

func (m *EngineReplicaRebuildStatusProxyResponse) XXX_Merge(src proto.Message)

func (*EngineReplicaRebuildStatusProxyResponse) XXX_Size 

func (m *EngineReplicaRebuildStatusProxyResponse) XXX_Size() int

func (*EngineReplicaRebuildStatusProxyResponse) XXX_Unmarshal 

func (m *EngineReplicaRebuildStatusProxyResponse) XXX_Unmarshal(b []byte) error

type EngineReplicaRemoveRequest 

type EngineReplicaRemoveRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress       string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	ReplicaName          string              `protobuf:"bytes,3,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineReplicaRemoveRequest) Descriptor 

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

func (*EngineReplicaRemoveRequest) GetProxyEngineRequest 

func (m *EngineReplicaRemoveRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaRemoveRequest) GetReplicaAddress 

func (m *EngineReplicaRemoveRequest) GetReplicaAddress() string

func (*EngineReplicaRemoveRequest) GetReplicaName added in v1.5.0 

func (m *EngineReplicaRemoveRequest) GetReplicaName() string

func (*EngineReplicaRemoveRequest) ProtoMessage 

func (*EngineReplicaRemoveRequest) ProtoMessage()

func (*EngineReplicaRemoveRequest) Reset 

func (m *EngineReplicaRemoveRequest) Reset()

func (*EngineReplicaRemoveRequest) String 

func (m *EngineReplicaRemoveRequest) String() string

func (*EngineReplicaRemoveRequest) XXX_DiscardUnknown 

func (m *EngineReplicaRemoveRequest) XXX_DiscardUnknown()

func (*EngineReplicaRemoveRequest) XXX_Marshal 

func (m *EngineReplicaRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineReplicaRemoveRequest) XXX_Merge 

func (m *EngineReplicaRemoveRequest) XXX_Merge(src proto.Message)

func (*EngineReplicaRemoveRequest) XXX_Size 

func (m *EngineReplicaRemoveRequest) XXX_Size() int

func (*EngineReplicaRemoveRequest) XXX_Unmarshal 

func (m *EngineReplicaRemoveRequest) XXX_Unmarshal(b []byte) error

type EngineReplicaVerifyRebuildRequest 

type EngineReplicaVerifyRebuildRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	ReplicaAddress       string              `protobuf:"bytes,2,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	ReplicaName          string              `protobuf:"bytes,3,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineReplicaVerifyRebuildRequest) Descriptor 

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

func (*EngineReplicaVerifyRebuildRequest) GetProxyEngineRequest 

func (m *EngineReplicaVerifyRebuildRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineReplicaVerifyRebuildRequest) GetReplicaAddress 

func (m *EngineReplicaVerifyRebuildRequest) GetReplicaAddress() string

func (*EngineReplicaVerifyRebuildRequest) GetReplicaName added in v1.5.2 

func (m *EngineReplicaVerifyRebuildRequest) GetReplicaName() string

func (*EngineReplicaVerifyRebuildRequest) ProtoMessage 

func (*EngineReplicaVerifyRebuildRequest) ProtoMessage()

func (*EngineReplicaVerifyRebuildRequest) Reset 

func (m *EngineReplicaVerifyRebuildRequest) Reset()

func (*EngineReplicaVerifyRebuildRequest) String 

func (m *EngineReplicaVerifyRebuildRequest) String() string

func (*EngineReplicaVerifyRebuildRequest) XXX_DiscardUnknown 

func (m *EngineReplicaVerifyRebuildRequest) XXX_DiscardUnknown()

func (*EngineReplicaVerifyRebuildRequest) XXX_Marshal 

func (m *EngineReplicaVerifyRebuildRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineReplicaVerifyRebuildRequest) XXX_Merge 

func (m *EngineReplicaVerifyRebuildRequest) XXX_Merge(src proto.Message)

func (*EngineReplicaVerifyRebuildRequest) XXX_Size 

func (m *EngineReplicaVerifyRebuildRequest) XXX_Size() int

func (*EngineReplicaVerifyRebuildRequest) XXX_Unmarshal 

func (m *EngineReplicaVerifyRebuildRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotBackupProxyResponse 

type EngineSnapshotBackupProxyResponse struct {
	BackupId             string   `protobuf:"bytes,1,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	Replica              string   `protobuf:"bytes,2,opt,name=replica,proto3" json:"replica,omitempty"`
	IsIncremental        bool     `protobuf:"varint,3,opt,name=is_incremental,json=isIncremental,proto3" json:"is_incremental,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EngineSnapshotBackupProxyResponse) Descriptor 

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

func (*EngineSnapshotBackupProxyResponse) GetBackupId 

func (m *EngineSnapshotBackupProxyResponse) GetBackupId() string

func (*EngineSnapshotBackupProxyResponse) GetIsIncremental 

func (m *EngineSnapshotBackupProxyResponse) GetIsIncremental() bool

func (*EngineSnapshotBackupProxyResponse) GetReplica 

func (m *EngineSnapshotBackupProxyResponse) GetReplica() string

func (*EngineSnapshotBackupProxyResponse) ProtoMessage 

func (*EngineSnapshotBackupProxyResponse) ProtoMessage()

func (*EngineSnapshotBackupProxyResponse) Reset 

func (m *EngineSnapshotBackupProxyResponse) Reset()

func (*EngineSnapshotBackupProxyResponse) String 

func (m *EngineSnapshotBackupProxyResponse) String() string

func (*EngineSnapshotBackupProxyResponse) XXX_DiscardUnknown 

func (m *EngineSnapshotBackupProxyResponse) XXX_DiscardUnknown()

func (*EngineSnapshotBackupProxyResponse) XXX_Marshal 

func (m *EngineSnapshotBackupProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotBackupProxyResponse) XXX_Merge 

func (m *EngineSnapshotBackupProxyResponse) XXX_Merge(src proto.Message)

func (*EngineSnapshotBackupProxyResponse) XXX_Size 

func (m *EngineSnapshotBackupProxyResponse) XXX_Size() int

func (*EngineSnapshotBackupProxyResponse) XXX_Unmarshal 

func (m *EngineSnapshotBackupProxyResponse) XXX_Unmarshal(b []byte) error

type EngineSnapshotBackupRequest 

type EngineSnapshotBackupRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Envs                 []string            `protobuf:"bytes,8,rep,name=envs,proto3" json:"envs,omitempty"`
	BackupName           string              `protobuf:"bytes,2,opt,name=backup_name,json=backupName,proto3" json:"backup_name,omitempty"`
	SnapshotName         string              `protobuf:"bytes,3,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	BackupTarget         string              `protobuf:"bytes,4,opt,name=backup_target,json=backupTarget,proto3" json:"backup_target,omitempty"`
	BackingImageName     string              `protobuf:"bytes,5,opt,name=backing_image_name,json=backingImageName,proto3" json:"backing_image_name,omitempty"`
	BackingImageChecksum string              `protobuf:"bytes,6,opt,name=backing_image_checksum,json=backingImageChecksum,proto3" json:"backing_image_checksum,omitempty"`
	Labels               map[string]string   `` /* 153-byte string literal not displayed */
	CompressionMethod    string              `protobuf:"bytes,9,opt,name=compression_method,json=compressionMethod,proto3" json:"compression_method,omitempty"`
	ConcurrentLimit      int32               `protobuf:"varint,10,opt,name=concurrent_limit,json=concurrentLimit,proto3" json:"concurrent_limit,omitempty"`
	StorageClassName     string              `protobuf:"bytes,11,opt,name=storage_class_name,json=storageClassName,proto3" json:"storage_class_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotBackupRequest) Descriptor 

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

func (*EngineSnapshotBackupRequest) GetBackingImageChecksum 

func (m *EngineSnapshotBackupRequest) GetBackingImageChecksum() string

func (*EngineSnapshotBackupRequest) GetBackingImageName 

func (m *EngineSnapshotBackupRequest) GetBackingImageName() string

func (*EngineSnapshotBackupRequest) GetBackupName 

func (m *EngineSnapshotBackupRequest) GetBackupName() string

func (*EngineSnapshotBackupRequest) GetBackupTarget 

func (m *EngineSnapshotBackupRequest) GetBackupTarget() string

func (*EngineSnapshotBackupRequest) GetCompressionMethod added in v1.5.0 

func (m *EngineSnapshotBackupRequest) GetCompressionMethod() string

func (*EngineSnapshotBackupRequest) GetConcurrentLimit added in v1.5.0 

func (m *EngineSnapshotBackupRequest) GetConcurrentLimit() int32

func (*EngineSnapshotBackupRequest) GetEnvs 

func (m *EngineSnapshotBackupRequest) GetEnvs() []string

func (*EngineSnapshotBackupRequest) GetLabels 

func (m *EngineSnapshotBackupRequest) GetLabels() map[string]string

func (*EngineSnapshotBackupRequest) GetProxyEngineRequest 

func (m *EngineSnapshotBackupRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotBackupRequest) GetSnapshotName 

func (m *EngineSnapshotBackupRequest) GetSnapshotName() string

func (*EngineSnapshotBackupRequest) GetStorageClassName added in v1.5.0 

func (m *EngineSnapshotBackupRequest) GetStorageClassName() string

func (*EngineSnapshotBackupRequest) ProtoMessage 

func (*EngineSnapshotBackupRequest) ProtoMessage()

func (*EngineSnapshotBackupRequest) Reset 

func (m *EngineSnapshotBackupRequest) Reset()

func (*EngineSnapshotBackupRequest) String 

func (m *EngineSnapshotBackupRequest) String() string

func (*EngineSnapshotBackupRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotBackupRequest) XXX_DiscardUnknown()

func (*EngineSnapshotBackupRequest) XXX_Marshal 

func (m *EngineSnapshotBackupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotBackupRequest) XXX_Merge 

func (m *EngineSnapshotBackupRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotBackupRequest) XXX_Size 

func (m *EngineSnapshotBackupRequest) XXX_Size() int

func (*EngineSnapshotBackupRequest) XXX_Unmarshal 

func (m *EngineSnapshotBackupRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotBackupStatusProxyResponse 

type EngineSnapshotBackupStatusProxyResponse struct {
	BackupUrl            string   `protobuf:"bytes,1,opt,name=backup_url,json=backupUrl,proto3" json:"backup_url,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Progress             int32    `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"`
	SnapshotName         string   `protobuf:"bytes,4,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	State                string   `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	ReplicaAddress       string   `protobuf:"bytes,6,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EngineSnapshotBackupStatusProxyResponse) Descriptor 

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

func (*EngineSnapshotBackupStatusProxyResponse) GetBackupUrl 

func (m *EngineSnapshotBackupStatusProxyResponse) GetBackupUrl() string

func (*EngineSnapshotBackupStatusProxyResponse) GetError 

func (m *EngineSnapshotBackupStatusProxyResponse) GetError() string

func (*EngineSnapshotBackupStatusProxyResponse) GetProgress 

func (m *EngineSnapshotBackupStatusProxyResponse) GetProgress() int32

func (*EngineSnapshotBackupStatusProxyResponse) GetReplicaAddress 

func (m *EngineSnapshotBackupStatusProxyResponse) GetReplicaAddress() string

func (*EngineSnapshotBackupStatusProxyResponse) GetSnapshotName 

func (m *EngineSnapshotBackupStatusProxyResponse) GetSnapshotName() string

func (*EngineSnapshotBackupStatusProxyResponse) GetState 

func (m *EngineSnapshotBackupStatusProxyResponse) GetState() string

func (*EngineSnapshotBackupStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotBackupStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotBackupStatusProxyResponse) Reset 

func (m *EngineSnapshotBackupStatusProxyResponse) Reset()

func (*EngineSnapshotBackupStatusProxyResponse) String 

func (m *EngineSnapshotBackupStatusProxyResponse) String() string

func (*EngineSnapshotBackupStatusProxyResponse) XXX_DiscardUnknown 

func (m *EngineSnapshotBackupStatusProxyResponse) XXX_DiscardUnknown()

func (*EngineSnapshotBackupStatusProxyResponse) XXX_Marshal 

func (m *EngineSnapshotBackupStatusProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotBackupStatusProxyResponse) XXX_Merge 

func (m *EngineSnapshotBackupStatusProxyResponse) XXX_Merge(src proto.Message)

func (*EngineSnapshotBackupStatusProxyResponse) XXX_Size 

func (m *EngineSnapshotBackupStatusProxyResponse) XXX_Size() int

func (*EngineSnapshotBackupStatusProxyResponse) XXX_Unmarshal 

func (m *EngineSnapshotBackupStatusProxyResponse) XXX_Unmarshal(b []byte) error

type EngineSnapshotBackupStatusRequest 

type EngineSnapshotBackupStatusRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	BackupName           string              `protobuf:"bytes,2,opt,name=backup_name,json=backupName,proto3" json:"backup_name,omitempty"`
	ReplicaAddress       string              `protobuf:"bytes,3,opt,name=replica_address,json=replicaAddress,proto3" json:"replica_address,omitempty"`
	ReplicaName          string              `protobuf:"bytes,4,opt,name=replica_name,json=replicaName,proto3" json:"replica_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotBackupStatusRequest) Descriptor 

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

func (*EngineSnapshotBackupStatusRequest) GetBackupName 

func (m *EngineSnapshotBackupStatusRequest) GetBackupName() string

func (*EngineSnapshotBackupStatusRequest) GetProxyEngineRequest 

func (m *EngineSnapshotBackupStatusRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotBackupStatusRequest) GetReplicaAddress 

func (m *EngineSnapshotBackupStatusRequest) GetReplicaAddress() string

func (*EngineSnapshotBackupStatusRequest) GetReplicaName added in v1.5.2 

func (m *EngineSnapshotBackupStatusRequest) GetReplicaName() string

func (*EngineSnapshotBackupStatusRequest) ProtoMessage 

func (*EngineSnapshotBackupStatusRequest) ProtoMessage()

func (*EngineSnapshotBackupStatusRequest) Reset 

func (m *EngineSnapshotBackupStatusRequest) Reset()

func (*EngineSnapshotBackupStatusRequest) String 

func (m *EngineSnapshotBackupStatusRequest) String() string

func (*EngineSnapshotBackupStatusRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotBackupStatusRequest) XXX_DiscardUnknown()

func (*EngineSnapshotBackupStatusRequest) XXX_Marshal 

func (m *EngineSnapshotBackupStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotBackupStatusRequest) XXX_Merge 

func (m *EngineSnapshotBackupStatusRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotBackupStatusRequest) XXX_Size 

func (m *EngineSnapshotBackupStatusRequest) XXX_Size() int

func (*EngineSnapshotBackupStatusRequest) XXX_Unmarshal 

func (m *EngineSnapshotBackupStatusRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotCloneRequest 

type EngineSnapshotCloneRequest struct {
	ProxyEngineRequest        *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	FromEngineAddress         string              `protobuf:"bytes,2,opt,name=from_engine_address,json=fromEngineAddress,proto3" json:"from_engine_address,omitempty"`
	SnapshotName              string              `protobuf:"bytes,3,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	ExportBackingImageIfExist bool                `` /* 143-byte string literal not displayed */
	FileSyncHttpClientTimeout int32               `` /* 143-byte string literal not displayed */
	FromEngineName            string              `protobuf:"bytes,6,opt,name=from_engine_name,json=fromEngineName,proto3" json:"from_engine_name,omitempty"`
	FromVolumeName            string              `protobuf:"bytes,7,opt,name=from_volume_name,json=fromVolumeName,proto3" json:"from_volume_name,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}            `json:"-"`
	XXX_unrecognized          []byte              `json:"-"`
	XXX_sizecache             int32               `json:"-"`
}

func (*EngineSnapshotCloneRequest) Descriptor 

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

func (*EngineSnapshotCloneRequest) GetExportBackingImageIfExist 

func (m *EngineSnapshotCloneRequest) GetExportBackingImageIfExist() bool

func (*EngineSnapshotCloneRequest) GetFileSyncHttpClientTimeout 

func (m *EngineSnapshotCloneRequest) GetFileSyncHttpClientTimeout() int32

func (*EngineSnapshotCloneRequest) GetFromEngineAddress added in v1.5.2 

func (m *EngineSnapshotCloneRequest) GetFromEngineAddress() string

func (*EngineSnapshotCloneRequest) GetFromEngineName added in v1.5.2 

func (m *EngineSnapshotCloneRequest) GetFromEngineName() string

func (*EngineSnapshotCloneRequest) GetFromVolumeName added in v1.5.2 

func (m *EngineSnapshotCloneRequest) GetFromVolumeName() string

func (*EngineSnapshotCloneRequest) GetProxyEngineRequest 

func (m *EngineSnapshotCloneRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotCloneRequest) GetSnapshotName 

func (m *EngineSnapshotCloneRequest) GetSnapshotName() string

func (*EngineSnapshotCloneRequest) ProtoMessage 

func (*EngineSnapshotCloneRequest) ProtoMessage()

func (*EngineSnapshotCloneRequest) Reset 

func (m *EngineSnapshotCloneRequest) Reset()

func (*EngineSnapshotCloneRequest) String 

func (m *EngineSnapshotCloneRequest) String() string

func (*EngineSnapshotCloneRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotCloneRequest) XXX_DiscardUnknown()

func (*EngineSnapshotCloneRequest) XXX_Marshal 

func (m *EngineSnapshotCloneRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotCloneRequest) XXX_Merge 

func (m *EngineSnapshotCloneRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotCloneRequest) XXX_Size 

func (m *EngineSnapshotCloneRequest) XXX_Size() int

func (*EngineSnapshotCloneRequest) XXX_Unmarshal 

func (m *EngineSnapshotCloneRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotCloneStatusProxyResponse 

type EngineSnapshotCloneStatusProxyResponse struct {
	Status               map[string]*ptypes.SnapshotCloneStatusResponse `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*EngineSnapshotCloneStatusProxyResponse) Descriptor 

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

func (*EngineSnapshotCloneStatusProxyResponse) GetStatus 

func (m *EngineSnapshotCloneStatusProxyResponse) GetStatus() map[string]*ptypes.SnapshotCloneStatusResponse

func (*EngineSnapshotCloneStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotCloneStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotCloneStatusProxyResponse) Reset 

func (m *EngineSnapshotCloneStatusProxyResponse) Reset()

func (*EngineSnapshotCloneStatusProxyResponse) String 

func (m *EngineSnapshotCloneStatusProxyResponse) String() string

func (*EngineSnapshotCloneStatusProxyResponse) XXX_DiscardUnknown 

func (m *EngineSnapshotCloneStatusProxyResponse) XXX_DiscardUnknown()

func (*EngineSnapshotCloneStatusProxyResponse) XXX_Marshal 

func (m *EngineSnapshotCloneStatusProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotCloneStatusProxyResponse) XXX_Merge 

func (m *EngineSnapshotCloneStatusProxyResponse) XXX_Merge(src proto.Message)

func (*EngineSnapshotCloneStatusProxyResponse) XXX_Size 

func (m *EngineSnapshotCloneStatusProxyResponse) XXX_Size() int

func (*EngineSnapshotCloneStatusProxyResponse) XXX_Unmarshal 

func (m *EngineSnapshotCloneStatusProxyResponse) XXX_Unmarshal(b []byte) error

type EngineSnapshotDiskInfo 

type EngineSnapshotDiskInfo struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parent               string            `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Children             map[string]bool   `` /* 158-byte string literal not displayed */
	Removed              bool              `protobuf:"varint,4,opt,name=removed,proto3" json:"removed,omitempty"`
	UserCreated          bool              `protobuf:"varint,5,opt,name=user_created,json=userCreated,proto3" json:"user_created,omitempty"`
	Created              string            `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	Size                 string            `protobuf:"bytes,7,opt,name=size,proto3" json:"size,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EngineSnapshotDiskInfo) Descriptor 

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

func (*EngineSnapshotDiskInfo) GetChildren 

func (m *EngineSnapshotDiskInfo) GetChildren() map[string]bool

func (*EngineSnapshotDiskInfo) GetCreated 

func (m *EngineSnapshotDiskInfo) GetCreated() string

func (*EngineSnapshotDiskInfo) GetLabels 

func (m *EngineSnapshotDiskInfo) GetLabels() map[string]string

func (*EngineSnapshotDiskInfo) GetName 

func (m *EngineSnapshotDiskInfo) GetName() string

func (*EngineSnapshotDiskInfo) GetParent 

func (m *EngineSnapshotDiskInfo) GetParent() string

func (*EngineSnapshotDiskInfo) GetRemoved 

func (m *EngineSnapshotDiskInfo) GetRemoved() bool

func (*EngineSnapshotDiskInfo) GetSize 

func (m *EngineSnapshotDiskInfo) GetSize() string

func (*EngineSnapshotDiskInfo) GetUserCreated 

func (m *EngineSnapshotDiskInfo) GetUserCreated() bool

func (*EngineSnapshotDiskInfo) ProtoMessage 

func (*EngineSnapshotDiskInfo) ProtoMessage()

func (*EngineSnapshotDiskInfo) Reset 

func (m *EngineSnapshotDiskInfo) Reset()

func (*EngineSnapshotDiskInfo) String 

func (m *EngineSnapshotDiskInfo) String() string

func (*EngineSnapshotDiskInfo) XXX_DiscardUnknown 

func (m *EngineSnapshotDiskInfo) XXX_DiscardUnknown()

func (*EngineSnapshotDiskInfo) XXX_Marshal 

func (m *EngineSnapshotDiskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotDiskInfo) XXX_Merge 

func (m *EngineSnapshotDiskInfo) XXX_Merge(src proto.Message)

func (*EngineSnapshotDiskInfo) XXX_Size 

func (m *EngineSnapshotDiskInfo) XXX_Size() int

func (*EngineSnapshotDiskInfo) XXX_Unmarshal 

func (m *EngineSnapshotDiskInfo) XXX_Unmarshal(b []byte) error

type EngineSnapshotHashRequest 

type EngineSnapshotHashRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SnapshotName         string              `protobuf:"bytes,2,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	Rehash               bool                `protobuf:"varint,3,opt,name=rehash,proto3" json:"rehash,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotHashRequest) Descriptor 

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

func (*EngineSnapshotHashRequest) GetProxyEngineRequest 

func (m *EngineSnapshotHashRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotHashRequest) GetRehash 

func (m *EngineSnapshotHashRequest) GetRehash() bool

func (*EngineSnapshotHashRequest) GetSnapshotName 

func (m *EngineSnapshotHashRequest) GetSnapshotName() string

func (*EngineSnapshotHashRequest) ProtoMessage 

func (*EngineSnapshotHashRequest) ProtoMessage()

func (*EngineSnapshotHashRequest) Reset 

func (m *EngineSnapshotHashRequest) Reset()

func (*EngineSnapshotHashRequest) String 

func (m *EngineSnapshotHashRequest) String() string

func (*EngineSnapshotHashRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotHashRequest) XXX_DiscardUnknown()

func (*EngineSnapshotHashRequest) XXX_Marshal 

func (m *EngineSnapshotHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotHashRequest) XXX_Merge 

func (m *EngineSnapshotHashRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotHashRequest) XXX_Size 

func (m *EngineSnapshotHashRequest) XXX_Size() int

func (*EngineSnapshotHashRequest) XXX_Unmarshal 

func (m *EngineSnapshotHashRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotHashStatusProxyResponse 

type EngineSnapshotHashStatusProxyResponse struct {
	Status               map[string]*ptypes.SnapshotHashStatusResponse `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*EngineSnapshotHashStatusProxyResponse) Descriptor 

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

func (*EngineSnapshotHashStatusProxyResponse) GetStatus 

func (m *EngineSnapshotHashStatusProxyResponse) GetStatus() map[string]*ptypes.SnapshotHashStatusResponse

func (*EngineSnapshotHashStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotHashStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotHashStatusProxyResponse) Reset 

func (m *EngineSnapshotHashStatusProxyResponse) Reset()

func (*EngineSnapshotHashStatusProxyResponse) String 

func (m *EngineSnapshotHashStatusProxyResponse) String() string

func (*EngineSnapshotHashStatusProxyResponse) XXX_DiscardUnknown 

func (m *EngineSnapshotHashStatusProxyResponse) XXX_DiscardUnknown()

func (*EngineSnapshotHashStatusProxyResponse) XXX_Marshal 

func (m *EngineSnapshotHashStatusProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotHashStatusProxyResponse) XXX_Merge 

func (m *EngineSnapshotHashStatusProxyResponse) XXX_Merge(src proto.Message)

func (*EngineSnapshotHashStatusProxyResponse) XXX_Size 

func (m *EngineSnapshotHashStatusProxyResponse) XXX_Size() int

func (*EngineSnapshotHashStatusProxyResponse) XXX_Unmarshal 

func (m *EngineSnapshotHashStatusProxyResponse) XXX_Unmarshal(b []byte) error

type EngineSnapshotHashStatusRequest 

type EngineSnapshotHashStatusRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SnapshotName         string              `protobuf:"bytes,2,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotHashStatusRequest) Descriptor 

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

func (*EngineSnapshotHashStatusRequest) GetProxyEngineRequest 

func (m *EngineSnapshotHashStatusRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotHashStatusRequest) GetSnapshotName 

func (m *EngineSnapshotHashStatusRequest) GetSnapshotName() string

func (*EngineSnapshotHashStatusRequest) ProtoMessage 

func (*EngineSnapshotHashStatusRequest) ProtoMessage()

func (*EngineSnapshotHashStatusRequest) Reset 

func (m *EngineSnapshotHashStatusRequest) Reset()

func (*EngineSnapshotHashStatusRequest) String 

func (m *EngineSnapshotHashStatusRequest) String() string

func (*EngineSnapshotHashStatusRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotHashStatusRequest) XXX_DiscardUnknown()

func (*EngineSnapshotHashStatusRequest) XXX_Marshal 

func (m *EngineSnapshotHashStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotHashStatusRequest) XXX_Merge 

func (m *EngineSnapshotHashStatusRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotHashStatusRequest) XXX_Size 

func (m *EngineSnapshotHashStatusRequest) XXX_Size() int

func (*EngineSnapshotHashStatusRequest) XXX_Unmarshal 

func (m *EngineSnapshotHashStatusRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotListProxyResponse 

type EngineSnapshotListProxyResponse struct {
	Disks                map[string]*EngineSnapshotDiskInfo `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*EngineSnapshotListProxyResponse) Descriptor 

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

func (*EngineSnapshotListProxyResponse) GetDisks 

func (m *EngineSnapshotListProxyResponse) GetDisks() map[string]*EngineSnapshotDiskInfo

func (*EngineSnapshotListProxyResponse) ProtoMessage 

func (*EngineSnapshotListProxyResponse) ProtoMessage()

func (*EngineSnapshotListProxyResponse) Reset 

func (m *EngineSnapshotListProxyResponse) Reset()

func (*EngineSnapshotListProxyResponse) String 

func (m *EngineSnapshotListProxyResponse) String() string

func (*EngineSnapshotListProxyResponse) XXX_DiscardUnknown 

func (m *EngineSnapshotListProxyResponse) XXX_DiscardUnknown()

func (*EngineSnapshotListProxyResponse) XXX_Marshal 

func (m *EngineSnapshotListProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotListProxyResponse) XXX_Merge 

func (m *EngineSnapshotListProxyResponse) XXX_Merge(src proto.Message)

func (*EngineSnapshotListProxyResponse) XXX_Size 

func (m *EngineSnapshotListProxyResponse) XXX_Size() int

func (*EngineSnapshotListProxyResponse) XXX_Unmarshal 

func (m *EngineSnapshotListProxyResponse) XXX_Unmarshal(b []byte) error

type EngineSnapshotPurgeRequest 

type EngineSnapshotPurgeRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SkipIfInProgress     bool                `protobuf:"varint,2,opt,name=skip_if_in_progress,json=skipIfInProgress,proto3" json:"skip_if_in_progress,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotPurgeRequest) Descriptor 

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

func (*EngineSnapshotPurgeRequest) GetProxyEngineRequest 

func (m *EngineSnapshotPurgeRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotPurgeRequest) GetSkipIfInProgress 

func (m *EngineSnapshotPurgeRequest) GetSkipIfInProgress() bool

func (*EngineSnapshotPurgeRequest) ProtoMessage 

func (*EngineSnapshotPurgeRequest) ProtoMessage()

func (*EngineSnapshotPurgeRequest) Reset 

func (m *EngineSnapshotPurgeRequest) Reset()

func (*EngineSnapshotPurgeRequest) String 

func (m *EngineSnapshotPurgeRequest) String() string

func (*EngineSnapshotPurgeRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotPurgeRequest) XXX_DiscardUnknown()

func (*EngineSnapshotPurgeRequest) XXX_Marshal 

func (m *EngineSnapshotPurgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotPurgeRequest) XXX_Merge 

func (m *EngineSnapshotPurgeRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotPurgeRequest) XXX_Size 

func (m *EngineSnapshotPurgeRequest) XXX_Size() int

func (*EngineSnapshotPurgeRequest) XXX_Unmarshal 

func (m *EngineSnapshotPurgeRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotPurgeStatusProxyResponse 

type EngineSnapshotPurgeStatusProxyResponse struct {
	Status               map[string]*ptypes.SnapshotPurgeStatusResponse `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*EngineSnapshotPurgeStatusProxyResponse) Descriptor 

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

func (*EngineSnapshotPurgeStatusProxyResponse) GetStatus 

func (m *EngineSnapshotPurgeStatusProxyResponse) GetStatus() map[string]*ptypes.SnapshotPurgeStatusResponse

func (*EngineSnapshotPurgeStatusProxyResponse) ProtoMessage 

func (*EngineSnapshotPurgeStatusProxyResponse) ProtoMessage()

func (*EngineSnapshotPurgeStatusProxyResponse) Reset 

func (m *EngineSnapshotPurgeStatusProxyResponse) Reset()

func (*EngineSnapshotPurgeStatusProxyResponse) String 

func (m *EngineSnapshotPurgeStatusProxyResponse) String() string

func (*EngineSnapshotPurgeStatusProxyResponse) XXX_DiscardUnknown 

func (m *EngineSnapshotPurgeStatusProxyResponse) XXX_DiscardUnknown()

func (*EngineSnapshotPurgeStatusProxyResponse) XXX_Marshal 

func (m *EngineSnapshotPurgeStatusProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotPurgeStatusProxyResponse) XXX_Merge 

func (m *EngineSnapshotPurgeStatusProxyResponse) XXX_Merge(src proto.Message)

func (*EngineSnapshotPurgeStatusProxyResponse) XXX_Size 

func (m *EngineSnapshotPurgeStatusProxyResponse) XXX_Size() int

func (*EngineSnapshotPurgeStatusProxyResponse) XXX_Unmarshal 

func (m *EngineSnapshotPurgeStatusProxyResponse) XXX_Unmarshal(b []byte) error

type EngineSnapshotRemoveRequest 

type EngineSnapshotRemoveRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Names                []string            `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotRemoveRequest) Descriptor 

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

func (*EngineSnapshotRemoveRequest) GetNames 

func (m *EngineSnapshotRemoveRequest) GetNames() []string

func (*EngineSnapshotRemoveRequest) GetProxyEngineRequest 

func (m *EngineSnapshotRemoveRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotRemoveRequest) ProtoMessage 

func (*EngineSnapshotRemoveRequest) ProtoMessage()

func (*EngineSnapshotRemoveRequest) Reset 

func (m *EngineSnapshotRemoveRequest) Reset()

func (*EngineSnapshotRemoveRequest) String 

func (m *EngineSnapshotRemoveRequest) String() string

func (*EngineSnapshotRemoveRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotRemoveRequest) XXX_DiscardUnknown()

func (*EngineSnapshotRemoveRequest) XXX_Marshal 

func (m *EngineSnapshotRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotRemoveRequest) XXX_Merge 

func (m *EngineSnapshotRemoveRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotRemoveRequest) XXX_Size 

func (m *EngineSnapshotRemoveRequest) XXX_Size() int

func (*EngineSnapshotRemoveRequest) XXX_Unmarshal 

func (m *EngineSnapshotRemoveRequest) XXX_Unmarshal(b []byte) error

type EngineSnapshotRevertRequest 

type EngineSnapshotRevertRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Name                 string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EngineSnapshotRevertRequest) Descriptor 

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

func (*EngineSnapshotRevertRequest) GetName 

func (m *EngineSnapshotRevertRequest) GetName() string

func (*EngineSnapshotRevertRequest) GetProxyEngineRequest 

func (m *EngineSnapshotRevertRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineSnapshotRevertRequest) ProtoMessage 

func (*EngineSnapshotRevertRequest) ProtoMessage()

func (*EngineSnapshotRevertRequest) Reset 

func (m *EngineSnapshotRevertRequest) Reset()

func (*EngineSnapshotRevertRequest) String 

func (m *EngineSnapshotRevertRequest) String() string

func (*EngineSnapshotRevertRequest) XXX_DiscardUnknown 

func (m *EngineSnapshotRevertRequest) XXX_DiscardUnknown()

func (*EngineSnapshotRevertRequest) XXX_Marshal 

func (m *EngineSnapshotRevertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineSnapshotRevertRequest) XXX_Merge 

func (m *EngineSnapshotRevertRequest) XXX_Merge(src proto.Message)

func (*EngineSnapshotRevertRequest) XXX_Size 

func (m *EngineSnapshotRevertRequest) XXX_Size() int

func (*EngineSnapshotRevertRequest) XXX_Unmarshal 

func (m *EngineSnapshotRevertRequest) XXX_Unmarshal(b []byte) error

type EngineVersionProxyResponse 

type EngineVersionProxyResponse struct {
	Version              *ptypes.VersionOutput `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*EngineVersionProxyResponse) Descriptor 

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

func (*EngineVersionProxyResponse) GetVersion 

func (m *EngineVersionProxyResponse) GetVersion() *ptypes.VersionOutput

func (*EngineVersionProxyResponse) ProtoMessage 

func (*EngineVersionProxyResponse) ProtoMessage()

func (*EngineVersionProxyResponse) Reset 

func (m *EngineVersionProxyResponse) Reset()

func (*EngineVersionProxyResponse) String 

func (m *EngineVersionProxyResponse) String() string

func (*EngineVersionProxyResponse) XXX_DiscardUnknown 

func (m *EngineVersionProxyResponse) XXX_DiscardUnknown()

func (*EngineVersionProxyResponse) XXX_Marshal 

func (m *EngineVersionProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVersionProxyResponse) XXX_Merge 

func (m *EngineVersionProxyResponse) XXX_Merge(src proto.Message)

func (*EngineVersionProxyResponse) XXX_Size 

func (m *EngineVersionProxyResponse) XXX_Size() int

func (*EngineVersionProxyResponse) XXX_Unmarshal 

func (m *EngineVersionProxyResponse) XXX_Unmarshal(b []byte) error

type EngineVolumeExpandRequest 

type EngineVolumeExpandRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest         `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	Expand               *ptypes.VolumeExpandRequest `protobuf:"bytes,2,opt,name=expand,proto3" json:"expand,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*EngineVolumeExpandRequest) Descriptor 

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

func (*EngineVolumeExpandRequest) GetExpand 

func (m *EngineVolumeExpandRequest) GetExpand() *ptypes.VolumeExpandRequest

func (*EngineVolumeExpandRequest) GetProxyEngineRequest 

func (m *EngineVolumeExpandRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeExpandRequest) ProtoMessage 

func (*EngineVolumeExpandRequest) ProtoMessage()

func (*EngineVolumeExpandRequest) Reset 

func (m *EngineVolumeExpandRequest) Reset()

func (*EngineVolumeExpandRequest) String 

func (m *EngineVolumeExpandRequest) String() string

func (*EngineVolumeExpandRequest) XXX_DiscardUnknown 

func (m *EngineVolumeExpandRequest) XXX_DiscardUnknown()

func (*EngineVolumeExpandRequest) XXX_Marshal 

func (m *EngineVolumeExpandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVolumeExpandRequest) XXX_Merge 

func (m *EngineVolumeExpandRequest) XXX_Merge(src proto.Message)

func (*EngineVolumeExpandRequest) XXX_Size 

func (m *EngineVolumeExpandRequest) XXX_Size() int

func (*EngineVolumeExpandRequest) XXX_Unmarshal 

func (m *EngineVolumeExpandRequest) XXX_Unmarshal(b []byte) error

type EngineVolumeFrontendStartRequest 

type EngineVolumeFrontendStartRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest                `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	FrontendStart        *ptypes.VolumeFrontendStartRequest `protobuf:"bytes,2,opt,name=frontend_start,json=frontendStart,proto3" json:"frontend_start,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*EngineVolumeFrontendStartRequest) Descriptor 

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

func (*EngineVolumeFrontendStartRequest) GetFrontendStart 

func (m *EngineVolumeFrontendStartRequest) GetFrontendStart() *ptypes.VolumeFrontendStartRequest

func (*EngineVolumeFrontendStartRequest) GetProxyEngineRequest 

func (m *EngineVolumeFrontendStartRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeFrontendStartRequest) ProtoMessage 

func (*EngineVolumeFrontendStartRequest) ProtoMessage()

func (*EngineVolumeFrontendStartRequest) Reset 

func (m *EngineVolumeFrontendStartRequest) Reset()

func (*EngineVolumeFrontendStartRequest) String 

func (m *EngineVolumeFrontendStartRequest) String() string

func (*EngineVolumeFrontendStartRequest) XXX_DiscardUnknown 

func (m *EngineVolumeFrontendStartRequest) XXX_DiscardUnknown()

func (*EngineVolumeFrontendStartRequest) XXX_Marshal 

func (m *EngineVolumeFrontendStartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVolumeFrontendStartRequest) XXX_Merge 

func (m *EngineVolumeFrontendStartRequest) XXX_Merge(src proto.Message)

func (*EngineVolumeFrontendStartRequest) XXX_Size 

func (m *EngineVolumeFrontendStartRequest) XXX_Size() int

func (*EngineVolumeFrontendStartRequest) XXX_Unmarshal 

func (m *EngineVolumeFrontendStartRequest) XXX_Unmarshal(b []byte) error

type EngineVolumeGetProxyResponse 

type EngineVolumeGetProxyResponse struct {
	Volume               *ptypes.Volume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EngineVolumeGetProxyResponse) Descriptor 

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

func (*EngineVolumeGetProxyResponse) GetVolume 

func (m *EngineVolumeGetProxyResponse) GetVolume() *ptypes.Volume

func (*EngineVolumeGetProxyResponse) ProtoMessage 

func (*EngineVolumeGetProxyResponse) ProtoMessage()

func (*EngineVolumeGetProxyResponse) Reset 

func (m *EngineVolumeGetProxyResponse) Reset()

func (*EngineVolumeGetProxyResponse) String 

func (m *EngineVolumeGetProxyResponse) String() string

func (*EngineVolumeGetProxyResponse) XXX_DiscardUnknown 

func (m *EngineVolumeGetProxyResponse) XXX_DiscardUnknown()

func (*EngineVolumeGetProxyResponse) XXX_Marshal 

func (m *EngineVolumeGetProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVolumeGetProxyResponse) XXX_Merge 

func (m *EngineVolumeGetProxyResponse) XXX_Merge(src proto.Message)

func (*EngineVolumeGetProxyResponse) XXX_Size 

func (m *EngineVolumeGetProxyResponse) XXX_Size() int

func (*EngineVolumeGetProxyResponse) XXX_Unmarshal 

func (m *EngineVolumeGetProxyResponse) XXX_Unmarshal(b []byte) error

type EngineVolumeSnapshotProxyResponse 

type EngineVolumeSnapshotProxyResponse struct {
	Snapshot             *ptypes.VolumeSnapshotReply `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*EngineVolumeSnapshotProxyResponse) Descriptor 

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

func (*EngineVolumeSnapshotProxyResponse) GetSnapshot 

func (m *EngineVolumeSnapshotProxyResponse) GetSnapshot() *ptypes.VolumeSnapshotReply

func (*EngineVolumeSnapshotProxyResponse) ProtoMessage 

func (*EngineVolumeSnapshotProxyResponse) ProtoMessage()

func (*EngineVolumeSnapshotProxyResponse) Reset 

func (m *EngineVolumeSnapshotProxyResponse) Reset()

func (*EngineVolumeSnapshotProxyResponse) String 

func (m *EngineVolumeSnapshotProxyResponse) String() string

func (*EngineVolumeSnapshotProxyResponse) XXX_DiscardUnknown 

func (m *EngineVolumeSnapshotProxyResponse) XXX_DiscardUnknown()

func (*EngineVolumeSnapshotProxyResponse) XXX_Marshal 

func (m *EngineVolumeSnapshotProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVolumeSnapshotProxyResponse) XXX_Merge 

func (m *EngineVolumeSnapshotProxyResponse) XXX_Merge(src proto.Message)

func (*EngineVolumeSnapshotProxyResponse) XXX_Size 

func (m *EngineVolumeSnapshotProxyResponse) XXX_Size() int

func (*EngineVolumeSnapshotProxyResponse) XXX_Unmarshal 

func (m *EngineVolumeSnapshotProxyResponse) XXX_Unmarshal(b []byte) error

type EngineVolumeSnapshotRequest 

type EngineVolumeSnapshotRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest           `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	SnapshotVolume       *ptypes.VolumeSnapshotRequest `protobuf:"bytes,2,opt,name=snapshot_volume,json=snapshotVolume,proto3" json:"snapshot_volume,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*EngineVolumeSnapshotRequest) Descriptor 

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

func (*EngineVolumeSnapshotRequest) GetProxyEngineRequest 

func (m *EngineVolumeSnapshotRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeSnapshotRequest) GetSnapshotVolume 

func (m *EngineVolumeSnapshotRequest) GetSnapshotVolume() *ptypes.VolumeSnapshotRequest

func (*EngineVolumeSnapshotRequest) ProtoMessage 

func (*EngineVolumeSnapshotRequest) ProtoMessage()

func (*EngineVolumeSnapshotRequest) Reset 

func (m *EngineVolumeSnapshotRequest) Reset()

func (*EngineVolumeSnapshotRequest) String 

func (m *EngineVolumeSnapshotRequest) String() string

func (*EngineVolumeSnapshotRequest) XXX_DiscardUnknown 

func (m *EngineVolumeSnapshotRequest) XXX_DiscardUnknown()

func (*EngineVolumeSnapshotRequest) XXX_Marshal 

func (m *EngineVolumeSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVolumeSnapshotRequest) XXX_Merge 

func (m *EngineVolumeSnapshotRequest) XXX_Merge(src proto.Message)

func (*EngineVolumeSnapshotRequest) XXX_Size 

func (m *EngineVolumeSnapshotRequest) XXX_Size() int

func (*EngineVolumeSnapshotRequest) XXX_Unmarshal 

func (m *EngineVolumeSnapshotRequest) XXX_Unmarshal(b []byte) error

type EngineVolumeUnmapMarkSnapChainRemovedSetRequest 

type EngineVolumeUnmapMarkSnapChainRemovedSetRequest struct {
	ProxyEngineRequest   *ProxyEngineRequest                               `protobuf:"bytes,1,opt,name=proxy_engine_request,json=proxyEngineRequest,proto3" json:"proxy_engine_request,omitempty"`
	UnmapMarkSnap        *ptypes.VolumeUnmapMarkSnapChainRemovedSetRequest `protobuf:"bytes,2,opt,name=unmap_mark_snap,json=unmapMarkSnap,proto3" json:"unmap_mark_snap,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_unrecognized     []byte                                            `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) Descriptor 

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

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetProxyEngineRequest 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetProxyEngineRequest() *ProxyEngineRequest

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetUnmapMarkSnap 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) GetUnmapMarkSnap() *ptypes.VolumeUnmapMarkSnapChainRemovedSetRequest

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) ProtoMessage 

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) ProtoMessage()

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) Reset 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) Reset()

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) String 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) String() string

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_DiscardUnknown 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_DiscardUnknown()

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Marshal 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Merge 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Merge(src proto.Message)

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Size 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Size() int

func (*EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Unmarshal 

func (m *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) XXX_Unmarshal(b []byte) error

type InstanceCreateRequest added in v1.5.0 

type InstanceCreateRequest struct {
	Spec                 *InstanceSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*InstanceCreateRequest) Descriptor added in v1.5.0 

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

func (*InstanceCreateRequest) GetSpec added in v1.5.0 

func (m *InstanceCreateRequest) GetSpec() *InstanceSpec

func (*InstanceCreateRequest) ProtoMessage added in v1.5.0 

func (*InstanceCreateRequest) ProtoMessage()

func (*InstanceCreateRequest) Reset added in v1.5.0 

func (m *InstanceCreateRequest) Reset()

func (*InstanceCreateRequest) String added in v1.5.0 

func (m *InstanceCreateRequest) String() string

func (*InstanceCreateRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceCreateRequest) XXX_DiscardUnknown()

func (*InstanceCreateRequest) XXX_Marshal added in v1.5.0 

func (m *InstanceCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceCreateRequest) XXX_Merge added in v1.5.0 

func (m *InstanceCreateRequest) XXX_Merge(src proto.Message)

func (*InstanceCreateRequest) XXX_Size added in v1.5.0 

func (m *InstanceCreateRequest) XXX_Size() int

func (*InstanceCreateRequest) XXX_Unmarshal added in v1.5.0 

func (m *InstanceCreateRequest) XXX_Unmarshal(b []byte) error

type InstanceDeleteRequest added in v1.5.0 

type InstanceDeleteRequest struct {
	BackendStoreDriver   BackendStoreDriver `` /* 148-byte string literal not displayed */
	Name                 string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	DiskUuid             string             `protobuf:"bytes,4,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	CleanupRequired      bool               `protobuf:"varint,5,opt,name=cleanup_required,json=cleanupRequired,proto3" json:"cleanup_required,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*InstanceDeleteRequest) Descriptor added in v1.5.0 

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

func (*InstanceDeleteRequest) GetBackendStoreDriver added in v1.5.0 

func (m *InstanceDeleteRequest) GetBackendStoreDriver() BackendStoreDriver

func (*InstanceDeleteRequest) GetCleanupRequired added in v1.5.0 

func (m *InstanceDeleteRequest) GetCleanupRequired() bool

func (*InstanceDeleteRequest) GetDiskUuid added in v1.5.0 

func (m *InstanceDeleteRequest) GetDiskUuid() string

func (*InstanceDeleteRequest) GetName added in v1.5.0 

func (m *InstanceDeleteRequest) GetName() string

func (*InstanceDeleteRequest) GetType added in v1.5.0 

func (m *InstanceDeleteRequest) GetType() string

func (*InstanceDeleteRequest) ProtoMessage added in v1.5.0 

func (*InstanceDeleteRequest) ProtoMessage()

func (*InstanceDeleteRequest) Reset added in v1.5.0 

func (m *InstanceDeleteRequest) Reset()

func (*InstanceDeleteRequest) String added in v1.5.0 

func (m *InstanceDeleteRequest) String() string

func (*InstanceDeleteRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceDeleteRequest) XXX_DiscardUnknown()

func (*InstanceDeleteRequest) XXX_Marshal added in v1.5.0 

func (m *InstanceDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceDeleteRequest) XXX_Merge added in v1.5.0 

func (m *InstanceDeleteRequest) XXX_Merge(src proto.Message)

func (*InstanceDeleteRequest) XXX_Size added in v1.5.0 

func (m *InstanceDeleteRequest) XXX_Size() int

func (*InstanceDeleteRequest) XXX_Unmarshal added in v1.5.0 

func (m *InstanceDeleteRequest) XXX_Unmarshal(b []byte) error

type InstanceGetRequest added in v1.5.0 

type InstanceGetRequest struct {
	BackendStoreDriver   BackendStoreDriver `` /* 148-byte string literal not displayed */
	Name                 string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*InstanceGetRequest) Descriptor added in v1.5.0 

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

func (*InstanceGetRequest) GetBackendStoreDriver added in v1.5.0 

func (m *InstanceGetRequest) GetBackendStoreDriver() BackendStoreDriver

func (*InstanceGetRequest) GetName added in v1.5.0 

func (m *InstanceGetRequest) GetName() string

func (*InstanceGetRequest) GetType added in v1.5.0 

func (m *InstanceGetRequest) GetType() string

func (*InstanceGetRequest) ProtoMessage added in v1.5.0 

func (*InstanceGetRequest) ProtoMessage()

func (*InstanceGetRequest) Reset added in v1.5.0 

func (m *InstanceGetRequest) Reset()

func (*InstanceGetRequest) String added in v1.5.0 

func (m *InstanceGetRequest) String() string

func (*InstanceGetRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceGetRequest) XXX_DiscardUnknown()

func (*InstanceGetRequest) XXX_Marshal added in v1.5.0 

func (m *InstanceGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceGetRequest) XXX_Merge added in v1.5.0 

func (m *InstanceGetRequest) XXX_Merge(src proto.Message)

func (*InstanceGetRequest) XXX_Size added in v1.5.0 

func (m *InstanceGetRequest) XXX_Size() int

func (*InstanceGetRequest) XXX_Unmarshal added in v1.5.0 

func (m *InstanceGetRequest) XXX_Unmarshal(b []byte) error

type InstanceListResponse added in v1.5.0 

type InstanceListResponse struct {
	Instances            map[string]*InstanceResponse `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*InstanceListResponse) Descriptor added in v1.5.0 

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

func (*InstanceListResponse) GetInstances added in v1.5.0 

func (m *InstanceListResponse) GetInstances() map[string]*InstanceResponse

func (*InstanceListResponse) ProtoMessage added in v1.5.0 

func (*InstanceListResponse) ProtoMessage()

func (*InstanceListResponse) Reset added in v1.5.0 

func (m *InstanceListResponse) Reset()

func (*InstanceListResponse) String added in v1.5.0 

func (m *InstanceListResponse) String() string

func (*InstanceListResponse) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceListResponse) XXX_DiscardUnknown()

func (*InstanceListResponse) XXX_Marshal added in v1.5.0 

func (m *InstanceListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceListResponse) XXX_Merge added in v1.5.0 

func (m *InstanceListResponse) XXX_Merge(src proto.Message)

func (*InstanceListResponse) XXX_Size added in v1.5.0 

func (m *InstanceListResponse) XXX_Size() int

func (*InstanceListResponse) XXX_Unmarshal added in v1.5.0 

func (m *InstanceListResponse) XXX_Unmarshal(b []byte) error

type InstanceLogRequest added in v1.5.0 

type InstanceLogRequest struct {
	BackendStoreDriver   BackendStoreDriver `` /* 148-byte string literal not displayed */
	Name                 string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*InstanceLogRequest) Descriptor added in v1.5.0 

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

func (*InstanceLogRequest) GetBackendStoreDriver added in v1.5.0 

func (m *InstanceLogRequest) GetBackendStoreDriver() BackendStoreDriver

func (*InstanceLogRequest) GetName added in v1.5.0 

func (m *InstanceLogRequest) GetName() string

func (*InstanceLogRequest) GetType added in v1.5.0 

func (m *InstanceLogRequest) GetType() string

func (*InstanceLogRequest) ProtoMessage added in v1.5.0 

func (*InstanceLogRequest) ProtoMessage()

func (*InstanceLogRequest) Reset added in v1.5.0 

func (m *InstanceLogRequest) Reset()

func (*InstanceLogRequest) String added in v1.5.0 

func (m *InstanceLogRequest) String() string

func (*InstanceLogRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceLogRequest) XXX_DiscardUnknown()

func (*InstanceLogRequest) XXX_Marshal added in v1.5.0 

func (m *InstanceLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceLogRequest) XXX_Merge added in v1.5.0 

func (m *InstanceLogRequest) XXX_Merge(src proto.Message)

func (*InstanceLogRequest) XXX_Size added in v1.5.0 

func (m *InstanceLogRequest) XXX_Size() int

func (*InstanceLogRequest) XXX_Unmarshal added in v1.5.0 

func (m *InstanceLogRequest) XXX_Unmarshal(b []byte) error

type InstanceReplaceRequest added in v1.5.0 

type InstanceReplaceRequest struct {
	Spec                 *InstanceSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	TerminateSignal      string        `protobuf:"bytes,2,opt,name=terminate_signal,json=terminateSignal,proto3" json:"terminate_signal,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*InstanceReplaceRequest) Descriptor added in v1.5.0 

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

func (*InstanceReplaceRequest) GetSpec added in v1.5.0 

func (m *InstanceReplaceRequest) GetSpec() *InstanceSpec

func (*InstanceReplaceRequest) GetTerminateSignal added in v1.5.0 

func (m *InstanceReplaceRequest) GetTerminateSignal() string

func (*InstanceReplaceRequest) ProtoMessage added in v1.5.0 

func (*InstanceReplaceRequest) ProtoMessage()

func (*InstanceReplaceRequest) Reset added in v1.5.0 

func (m *InstanceReplaceRequest) Reset()

func (*InstanceReplaceRequest) String added in v1.5.0 

func (m *InstanceReplaceRequest) String() string

func (*InstanceReplaceRequest) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceReplaceRequest) XXX_DiscardUnknown()

func (*InstanceReplaceRequest) XXX_Marshal added in v1.5.0 

func (m *InstanceReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceReplaceRequest) XXX_Merge added in v1.5.0 

func (m *InstanceReplaceRequest) XXX_Merge(src proto.Message)

func (*InstanceReplaceRequest) XXX_Size added in v1.5.0 

func (m *InstanceReplaceRequest) XXX_Size() int

func (*InstanceReplaceRequest) XXX_Unmarshal added in v1.5.0 

func (m *InstanceReplaceRequest) XXX_Unmarshal(b []byte) error

type InstanceResponse added in v1.5.0 

type InstanceResponse struct {
	Spec                 *InstanceSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               *InstanceStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Deleted              bool            `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*InstanceResponse) Descriptor added in v1.5.0 

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

func (*InstanceResponse) GetDeleted added in v1.5.0 

func (m *InstanceResponse) GetDeleted() bool

func (*InstanceResponse) GetSpec added in v1.5.0 

func (m *InstanceResponse) GetSpec() *InstanceSpec

func (*InstanceResponse) GetStatus added in v1.5.0 

func (m *InstanceResponse) GetStatus() *InstanceStatus

func (*InstanceResponse) ProtoMessage added in v1.5.0 

func (*InstanceResponse) ProtoMessage()

func (*InstanceResponse) Reset added in v1.5.0 

func (m *InstanceResponse) Reset()

func (*InstanceResponse) String added in v1.5.0 

func (m *InstanceResponse) String() string

func (*InstanceResponse) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceResponse) XXX_DiscardUnknown()

func (*InstanceResponse) XXX_Marshal added in v1.5.0 

func (m *InstanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceResponse) XXX_Merge added in v1.5.0 

func (m *InstanceResponse) XXX_Merge(src proto.Message)

func (*InstanceResponse) XXX_Size added in v1.5.0 

func (m *InstanceResponse) XXX_Size() int

func (*InstanceResponse) XXX_Unmarshal added in v1.5.0 

func (m *InstanceResponse) XXX_Unmarshal(b []byte) error

type InstanceServiceClient added in v1.5.0 

type InstanceServiceClient interface {
	InstanceCreate(ctx context.Context, in *InstanceCreateRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	InstanceDelete(ctx context.Context, in *InstanceDeleteRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	InstanceGet(ctx context.Context, in *InstanceGetRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	InstanceList(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*InstanceListResponse, error)
	InstanceLog(ctx context.Context, in *InstanceLogRequest, opts ...grpc.CallOption) (InstanceService_InstanceLogClient, error)
	InstanceWatch(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (InstanceService_InstanceWatchClient, error)
	InstanceReplace(ctx context.Context, in *InstanceReplaceRequest, opts ...grpc.CallOption) (*InstanceResponse, error)
	VersionGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VersionResponse, error)
}

InstanceServiceClient is the client API for InstanceService service.

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

func NewInstanceServiceClient added in v1.5.0 

func NewInstanceServiceClient(cc *grpc.ClientConn) InstanceServiceClient

type InstanceServiceServer added in v1.5.0 

type InstanceServiceServer interface {
	InstanceCreate(context.Context, *InstanceCreateRequest) (*InstanceResponse, error)
	InstanceDelete(context.Context, *InstanceDeleteRequest) (*InstanceResponse, error)
	InstanceGet(context.Context, *InstanceGetRequest) (*InstanceResponse, error)
	InstanceList(context.Context, *empty.Empty) (*InstanceListResponse, error)
	InstanceLog(*InstanceLogRequest, InstanceService_InstanceLogServer) error
	InstanceWatch(*empty.Empty, InstanceService_InstanceWatchServer) error
	InstanceReplace(context.Context, *InstanceReplaceRequest) (*InstanceResponse, error)
	VersionGet(context.Context, *empty.Empty) (*VersionResponse, error)
}

InstanceServiceServer is the server API for InstanceService service.

type InstanceService_InstanceLogClient added in v1.5.0 

type InstanceService_InstanceLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type InstanceService_InstanceLogServer added in v1.5.0 

type InstanceService_InstanceLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type InstanceService_InstanceWatchClient added in v1.5.0 

type InstanceService_InstanceWatchClient interface {
	Recv() (*empty.Empty, error)
	grpc.ClientStream
}

type InstanceService_InstanceWatchServer added in v1.5.0 

type InstanceService_InstanceWatchServer interface {
	Send(*empty.Empty) error
	grpc.ServerStream
}

type InstanceSpec added in v1.5.0 

type InstanceSpec struct {
	BackendStoreDriver   BackendStoreDriver   `` /* 148-byte string literal not displayed */
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string               `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	VolumeName           string               `protobuf:"bytes,4,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	PortCount            int32                `protobuf:"varint,5,opt,name=port_count,json=portCount,proto3" json:"port_count,omitempty"`
	PortArgs             []string             `protobuf:"bytes,6,rep,name=port_args,json=portArgs,proto3" json:"port_args,omitempty"`
	ProcessInstanceSpec  *ProcessInstanceSpec `protobuf:"bytes,7,opt,name=process_instance_spec,json=processInstanceSpec,proto3" json:"process_instance_spec,omitempty"`
	SpdkInstanceSpec     *SpdkInstanceSpec    `protobuf:"bytes,8,opt,name=spdk_instance_spec,json=spdkInstanceSpec,proto3" json:"spdk_instance_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*InstanceSpec) Descriptor added in v1.5.0 

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

func (*InstanceSpec) GetBackendStoreDriver added in v1.5.0 

func (m *InstanceSpec) GetBackendStoreDriver() BackendStoreDriver

func (*InstanceSpec) GetName added in v1.5.0 

func (m *InstanceSpec) GetName() string

func (*InstanceSpec) GetPortArgs added in v1.5.0 

func (m *InstanceSpec) GetPortArgs() []string

func (*InstanceSpec) GetPortCount added in v1.5.0 

func (m *InstanceSpec) GetPortCount() int32

func (*InstanceSpec) GetProcessInstanceSpec added in v1.5.0 

func (m *InstanceSpec) GetProcessInstanceSpec() *ProcessInstanceSpec

func (*InstanceSpec) GetSpdkInstanceSpec added in v1.5.0 

func (m *InstanceSpec) GetSpdkInstanceSpec() *SpdkInstanceSpec

func (*InstanceSpec) GetType added in v1.5.0 

func (m *InstanceSpec) GetType() string

func (*InstanceSpec) GetVolumeName added in v1.5.0 

func (m *InstanceSpec) GetVolumeName() string

func (*InstanceSpec) ProtoMessage added in v1.5.0 

func (*InstanceSpec) ProtoMessage()

func (*InstanceSpec) Reset added in v1.5.0 

func (m *InstanceSpec) Reset()

func (*InstanceSpec) String added in v1.5.0 

func (m *InstanceSpec) String() string

func (*InstanceSpec) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceSpec) XXX_DiscardUnknown()

func (*InstanceSpec) XXX_Marshal added in v1.5.0 

func (m *InstanceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceSpec) XXX_Merge added in v1.5.0 

func (m *InstanceSpec) XXX_Merge(src proto.Message)

func (*InstanceSpec) XXX_Size added in v1.5.0 

func (m *InstanceSpec) XXX_Size() int

func (*InstanceSpec) XXX_Unmarshal added in v1.5.0 

func (m *InstanceSpec) XXX_Unmarshal(b []byte) error

type InstanceStatus added in v1.5.0 

type InstanceStatus struct {
	State                string   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	ErrorMsg             string   `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	PortStart            int32    `protobuf:"varint,3,opt,name=port_start,json=portStart,proto3" json:"port_start,omitempty"`
	PortEnd              int32    `protobuf:"varint,4,opt,name=port_end,json=portEnd,proto3" json:"port_end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InstanceStatus) Descriptor added in v1.5.0 

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

func (*InstanceStatus) GetErrorMsg added in v1.5.0 

func (m *InstanceStatus) GetErrorMsg() string

func (*InstanceStatus) GetPortEnd added in v1.5.0 

func (m *InstanceStatus) GetPortEnd() int32

func (*InstanceStatus) GetPortStart added in v1.5.0 

func (m *InstanceStatus) GetPortStart() int32

func (*InstanceStatus) GetState added in v1.5.0 

func (m *InstanceStatus) GetState() string

func (*InstanceStatus) ProtoMessage added in v1.5.0 

func (*InstanceStatus) ProtoMessage()

func (*InstanceStatus) Reset added in v1.5.0 

func (m *InstanceStatus) Reset()

func (*InstanceStatus) String added in v1.5.0 

func (m *InstanceStatus) String() string

func (*InstanceStatus) XXX_DiscardUnknown added in v1.5.0 

func (m *InstanceStatus) XXX_DiscardUnknown()

func (*InstanceStatus) XXX_Marshal added in v1.5.0 

func (m *InstanceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceStatus) XXX_Merge added in v1.5.0 

func (m *InstanceStatus) XXX_Merge(src proto.Message)

func (*InstanceStatus) XXX_Size added in v1.5.0 

func (m *InstanceStatus) XXX_Size() int

func (*InstanceStatus) XXX_Unmarshal added in v1.5.0 

func (m *InstanceStatus) XXX_Unmarshal(b []byte) error

type LogRequest 

type LogRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRequest) Descriptor 

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

func (*LogRequest) GetName 

func (m *LogRequest) GetName() string

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) Reset 

func (m *LogRequest) Reset()

func (*LogRequest) String 

func (m *LogRequest) String() string

func (*LogRequest) XXX_DiscardUnknown 

func (m *LogRequest) XXX_DiscardUnknown()

func (*LogRequest) XXX_Marshal 

func (m *LogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogRequest) XXX_Merge 

func (m *LogRequest) XXX_Merge(src proto.Message)

func (*LogRequest) XXX_Size 

func (m *LogRequest) XXX_Size() int

func (*LogRequest) XXX_Unmarshal 

func (m *LogRequest) XXX_Unmarshal(b []byte) error

type LogResponse 

type LogResponse struct {
	Line                 string   `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogResponse) Descriptor 

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

func (*LogResponse) GetLine 

func (m *LogResponse) GetLine() string

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) Reset 

func (m *LogResponse) Reset()

func (*LogResponse) String 

func (m *LogResponse) String() string

func (*LogResponse) XXX_DiscardUnknown 

func (m *LogResponse) XXX_DiscardUnknown()

func (*LogResponse) XXX_Marshal 

func (m *LogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogResponse) XXX_Merge 

func (m *LogResponse) XXX_Merge(src proto.Message)

func (*LogResponse) XXX_Size 

func (m *LogResponse) XXX_Size() int

func (*LogResponse) XXX_Unmarshal 

func (m *LogResponse) XXX_Unmarshal(b []byte) error

type ProcessCreateRequest 

type ProcessCreateRequest struct {
	Spec                 *ProcessSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ProcessCreateRequest) Descriptor 

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

func (*ProcessCreateRequest) GetSpec 

func (m *ProcessCreateRequest) GetSpec() *ProcessSpec

func (*ProcessCreateRequest) ProtoMessage 

func (*ProcessCreateRequest) ProtoMessage()

func (*ProcessCreateRequest) Reset 

func (m *ProcessCreateRequest) Reset()

func (*ProcessCreateRequest) String 

func (m *ProcessCreateRequest) String() string

func (*ProcessCreateRequest) XXX_DiscardUnknown 

func (m *ProcessCreateRequest) XXX_DiscardUnknown()

func (*ProcessCreateRequest) XXX_Marshal 

func (m *ProcessCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessCreateRequest) XXX_Merge 

func (m *ProcessCreateRequest) XXX_Merge(src proto.Message)

func (*ProcessCreateRequest) XXX_Size 

func (m *ProcessCreateRequest) XXX_Size() int

func (*ProcessCreateRequest) XXX_Unmarshal 

func (m *ProcessCreateRequest) XXX_Unmarshal(b []byte) error

type ProcessDeleteRequest 

type ProcessDeleteRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessDeleteRequest) Descriptor 

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

func (*ProcessDeleteRequest) GetName 

func (m *ProcessDeleteRequest) GetName() string

func (*ProcessDeleteRequest) ProtoMessage 

func (*ProcessDeleteRequest) ProtoMessage()

func (*ProcessDeleteRequest) Reset 

func (m *ProcessDeleteRequest) Reset()

func (*ProcessDeleteRequest) String 

func (m *ProcessDeleteRequest) String() string

func (*ProcessDeleteRequest) XXX_DiscardUnknown 

func (m *ProcessDeleteRequest) XXX_DiscardUnknown()

func (*ProcessDeleteRequest) XXX_Marshal 

func (m *ProcessDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessDeleteRequest) XXX_Merge 

func (m *ProcessDeleteRequest) XXX_Merge(src proto.Message)

func (*ProcessDeleteRequest) XXX_Size 

func (m *ProcessDeleteRequest) XXX_Size() int

func (*ProcessDeleteRequest) XXX_Unmarshal 

func (m *ProcessDeleteRequest) XXX_Unmarshal(b []byte) error

type ProcessGetRequest 

type ProcessGetRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessGetRequest) Descriptor 

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

func (*ProcessGetRequest) GetName 

func (m *ProcessGetRequest) GetName() string

func (*ProcessGetRequest) ProtoMessage 

func (*ProcessGetRequest) ProtoMessage()

func (*ProcessGetRequest) Reset 

func (m *ProcessGetRequest) Reset()

func (*ProcessGetRequest) String 

func (m *ProcessGetRequest) String() string

func (*ProcessGetRequest) XXX_DiscardUnknown 

func (m *ProcessGetRequest) XXX_DiscardUnknown()

func (*ProcessGetRequest) XXX_Marshal 

func (m *ProcessGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessGetRequest) XXX_Merge 

func (m *ProcessGetRequest) XXX_Merge(src proto.Message)

func (*ProcessGetRequest) XXX_Size 

func (m *ProcessGetRequest) XXX_Size() int

func (*ProcessGetRequest) XXX_Unmarshal 

func (m *ProcessGetRequest) XXX_Unmarshal(b []byte) error

type ProcessInstanceSpec added in v1.5.0 

type ProcessInstanceSpec struct {
	Binary               string   `protobuf:"bytes,1,opt,name=binary,proto3" json:"binary,omitempty"`
	Args                 []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessInstanceSpec) Descriptor added in v1.5.0 

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

func (*ProcessInstanceSpec) GetArgs added in v1.5.0 

func (m *ProcessInstanceSpec) GetArgs() []string

func (*ProcessInstanceSpec) GetBinary added in v1.5.0 

func (m *ProcessInstanceSpec) GetBinary() string

func (*ProcessInstanceSpec) ProtoMessage added in v1.5.0 

func (*ProcessInstanceSpec) ProtoMessage()

func (*ProcessInstanceSpec) Reset added in v1.5.0 

func (m *ProcessInstanceSpec) Reset()

func (*ProcessInstanceSpec) String added in v1.5.0 

func (m *ProcessInstanceSpec) String() string

func (*ProcessInstanceSpec) XXX_DiscardUnknown added in v1.5.0 

func (m *ProcessInstanceSpec) XXX_DiscardUnknown()

func (*ProcessInstanceSpec) XXX_Marshal added in v1.5.0 

func (m *ProcessInstanceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessInstanceSpec) XXX_Merge added in v1.5.0 

func (m *ProcessInstanceSpec) XXX_Merge(src proto.Message)

func (*ProcessInstanceSpec) XXX_Size added in v1.5.0 

func (m *ProcessInstanceSpec) XXX_Size() int

func (*ProcessInstanceSpec) XXX_Unmarshal added in v1.5.0 

func (m *ProcessInstanceSpec) XXX_Unmarshal(b []byte) error

type ProcessListRequest 

type ProcessListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessListRequest) Descriptor 

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

func (*ProcessListRequest) ProtoMessage 

func (*ProcessListRequest) ProtoMessage()

func (*ProcessListRequest) Reset 

func (m *ProcessListRequest) Reset()

func (*ProcessListRequest) String 

func (m *ProcessListRequest) String() string

func (*ProcessListRequest) XXX_DiscardUnknown 

func (m *ProcessListRequest) XXX_DiscardUnknown()

func (*ProcessListRequest) XXX_Marshal 

func (m *ProcessListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessListRequest) XXX_Merge 

func (m *ProcessListRequest) XXX_Merge(src proto.Message)

func (*ProcessListRequest) XXX_Size 

func (m *ProcessListRequest) XXX_Size() int

func (*ProcessListRequest) XXX_Unmarshal 

func (m *ProcessListRequest) XXX_Unmarshal(b []byte) error

type ProcessListResponse 

type ProcessListResponse struct {
	Processes            map[string]*ProcessResponse `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ProcessListResponse) Descriptor 

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

func (*ProcessListResponse) GetProcesses 

func (m *ProcessListResponse) GetProcesses() map[string]*ProcessResponse

func (*ProcessListResponse) ProtoMessage 

func (*ProcessListResponse) ProtoMessage()

func (*ProcessListResponse) Reset 

func (m *ProcessListResponse) Reset()

func (*ProcessListResponse) String 

func (m *ProcessListResponse) String() string

func (*ProcessListResponse) XXX_DiscardUnknown 

func (m *ProcessListResponse) XXX_DiscardUnknown()

func (*ProcessListResponse) XXX_Marshal 

func (m *ProcessListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessListResponse) XXX_Merge 

func (m *ProcessListResponse) XXX_Merge(src proto.Message)

func (*ProcessListResponse) XXX_Size 

func (m *ProcessListResponse) XXX_Size() int

func (*ProcessListResponse) XXX_Unmarshal 

func (m *ProcessListResponse) XXX_Unmarshal(b []byte) error

type ProcessManagerServiceClient 

type ProcessManagerServiceClient interface {
	ProcessCreate(ctx context.Context, in *ProcessCreateRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessGet(ctx context.Context, in *ProcessGetRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	ProcessList(ctx context.Context, in *ProcessListRequest, opts ...grpc.CallOption) (*ProcessListResponse, error)
	ProcessLog(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (ProcessManagerService_ProcessLogClient, error)
	ProcessWatch(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (ProcessManagerService_ProcessWatchClient, error)
	ProcessReplace(ctx context.Context, in *ProcessReplaceRequest, opts ...grpc.CallOption) (*ProcessResponse, error)
	VersionGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VersionResponse, error)
}

ProcessManagerServiceClient is the client API for ProcessManagerService service.

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

func NewProcessManagerServiceClient 

func NewProcessManagerServiceClient(cc *grpc.ClientConn) ProcessManagerServiceClient

type ProcessManagerServiceServer 

type ProcessManagerServiceServer interface {
	ProcessCreate(context.Context, *ProcessCreateRequest) (*ProcessResponse, error)
	ProcessDelete(context.Context, *ProcessDeleteRequest) (*ProcessResponse, error)
	ProcessGet(context.Context, *ProcessGetRequest) (*ProcessResponse, error)
	ProcessList(context.Context, *ProcessListRequest) (*ProcessListResponse, error)
	ProcessLog(*LogRequest, ProcessManagerService_ProcessLogServer) error
	ProcessWatch(*empty.Empty, ProcessManagerService_ProcessWatchServer) error
	ProcessReplace(context.Context, *ProcessReplaceRequest) (*ProcessResponse, error)
	VersionGet(context.Context, *empty.Empty) (*VersionResponse, error)
}

ProcessManagerServiceServer is the server API for ProcessManagerService service.

type ProcessManagerService_ProcessLogClient 

type ProcessManagerService_ProcessLogClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type ProcessManagerService_ProcessLogServer 

type ProcessManagerService_ProcessLogServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type ProcessManagerService_ProcessWatchClient 

type ProcessManagerService_ProcessWatchClient interface {
	Recv() (*ProcessResponse, error)
	grpc.ClientStream
}

type ProcessManagerService_ProcessWatchServer 

type ProcessManagerService_ProcessWatchServer interface {
	Send(*ProcessResponse) error
	grpc.ServerStream
}

type ProcessReplaceRequest 

type ProcessReplaceRequest struct {
	Spec                 *ProcessSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	TerminateSignal      string       `protobuf:"bytes,2,opt,name=terminate_signal,json=terminateSignal,proto3" json:"terminate_signal,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ProcessReplaceRequest) Descriptor 

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

func (*ProcessReplaceRequest) GetSpec 

func (m *ProcessReplaceRequest) GetSpec() *ProcessSpec

func (*ProcessReplaceRequest) GetTerminateSignal 

func (m *ProcessReplaceRequest) GetTerminateSignal() string

func (*ProcessReplaceRequest) ProtoMessage 

func (*ProcessReplaceRequest) ProtoMessage()

func (*ProcessReplaceRequest) Reset 

func (m *ProcessReplaceRequest) Reset()

func (*ProcessReplaceRequest) String 

func (m *ProcessReplaceRequest) String() string

func (*ProcessReplaceRequest) XXX_DiscardUnknown 

func (m *ProcessReplaceRequest) XXX_DiscardUnknown()

func (*ProcessReplaceRequest) XXX_Marshal 

func (m *ProcessReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessReplaceRequest) XXX_Merge 

func (m *ProcessReplaceRequest) XXX_Merge(src proto.Message)

func (*ProcessReplaceRequest) XXX_Size 

func (m *ProcessReplaceRequest) XXX_Size() int

func (*ProcessReplaceRequest) XXX_Unmarshal 

func (m *ProcessReplaceRequest) XXX_Unmarshal(b []byte) error

type ProcessResponse 

type ProcessResponse struct {
	Spec                 *ProcessSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               *ProcessStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Deleted              bool           `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ProcessResponse) Descriptor 

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

func (*ProcessResponse) GetDeleted 

func (m *ProcessResponse) GetDeleted() bool

func (*ProcessResponse) GetSpec 

func (m *ProcessResponse) GetSpec() *ProcessSpec

func (*ProcessResponse) GetStatus 

func (m *ProcessResponse) GetStatus() *ProcessStatus

func (*ProcessResponse) ProtoMessage 

func (*ProcessResponse) ProtoMessage()

func (*ProcessResponse) Reset 

func (m *ProcessResponse) Reset()

func (*ProcessResponse) String 

func (m *ProcessResponse) String() string

func (*ProcessResponse) XXX_DiscardUnknown 

func (m *ProcessResponse) XXX_DiscardUnknown()

func (*ProcessResponse) XXX_Marshal 

func (m *ProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessResponse) XXX_Merge 

func (m *ProcessResponse) XXX_Merge(src proto.Message)

func (*ProcessResponse) XXX_Size 

func (m *ProcessResponse) XXX_Size() int

func (*ProcessResponse) XXX_Unmarshal 

func (m *ProcessResponse) XXX_Unmarshal(b []byte) error

type ProcessSpec 

type ProcessSpec struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Binary               string   `protobuf:"bytes,2,opt,name=binary,proto3" json:"binary,omitempty"`
	Args                 []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	PortCount            int32    `protobuf:"varint,4,opt,name=port_count,json=portCount,proto3" json:"port_count,omitempty"`
	PortArgs             []string `protobuf:"bytes,5,rep,name=port_args,json=portArgs,proto3" json:"port_args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessSpec) Descriptor 

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

func (*ProcessSpec) GetArgs 

func (m *ProcessSpec) GetArgs() []string

func (*ProcessSpec) GetBinary 

func (m *ProcessSpec) GetBinary() string

func (*ProcessSpec) GetName 

func (m *ProcessSpec) GetName() string

func (*ProcessSpec) GetPortArgs 

func (m *ProcessSpec) GetPortArgs() []string

func (*ProcessSpec) GetPortCount 

func (m *ProcessSpec) GetPortCount() int32

func (*ProcessSpec) ProtoMessage 

func (*ProcessSpec) ProtoMessage()

func (*ProcessSpec) Reset 

func (m *ProcessSpec) Reset()

func (*ProcessSpec) String 

func (m *ProcessSpec) String() string

func (*ProcessSpec) XXX_DiscardUnknown 

func (m *ProcessSpec) XXX_DiscardUnknown()

func (*ProcessSpec) XXX_Marshal 

func (m *ProcessSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessSpec) XXX_Merge 

func (m *ProcessSpec) XXX_Merge(src proto.Message)

func (*ProcessSpec) XXX_Size 

func (m *ProcessSpec) XXX_Size() int

func (*ProcessSpec) XXX_Unmarshal 

func (m *ProcessSpec) XXX_Unmarshal(b []byte) error

type ProcessStatus 

type ProcessStatus struct {
	State                string   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	ErrorMsg             string   `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	PortStart            int32    `protobuf:"varint,3,opt,name=port_start,json=portStart,proto3" json:"port_start,omitempty"`
	PortEnd              int32    `protobuf:"varint,4,opt,name=port_end,json=portEnd,proto3" json:"port_end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessStatus) Descriptor 

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

func (*ProcessStatus) GetErrorMsg 

func (m *ProcessStatus) GetErrorMsg() string

func (*ProcessStatus) GetPortEnd 

func (m *ProcessStatus) GetPortEnd() int32

func (*ProcessStatus) GetPortStart 

func (m *ProcessStatus) GetPortStart() int32

func (*ProcessStatus) GetState 

func (m *ProcessStatus) GetState() string

func (*ProcessStatus) ProtoMessage 

func (*ProcessStatus) ProtoMessage()

func (*ProcessStatus) Reset 

func (m *ProcessStatus) Reset()

func (*ProcessStatus) String 

func (m *ProcessStatus) String() string

func (*ProcessStatus) XXX_DiscardUnknown 

func (m *ProcessStatus) XXX_DiscardUnknown()

func (*ProcessStatus) XXX_Marshal 

func (m *ProcessStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessStatus) XXX_Merge 

func (m *ProcessStatus) XXX_Merge(src proto.Message)

func (*ProcessStatus) XXX_Size 

func (m *ProcessStatus) XXX_Size() int

func (*ProcessStatus) XXX_Unmarshal 

func (m *ProcessStatus) XXX_Unmarshal(b []byte) error

type ProxyEngineRequest 

type ProxyEngineRequest struct {
	Address              string             `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	BackendStoreDriver   BackendStoreDriver `` /* 148-byte string literal not displayed */
	EngineName           string             `protobuf:"bytes,3,opt,name=engine_name,json=engineName,proto3" json:"engine_name,omitempty"`
	VolumeName           string             `protobuf:"bytes,4,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ProxyEngineRequest) Descriptor 

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

func (*ProxyEngineRequest) GetAddress 

func (m *ProxyEngineRequest) GetAddress() string

func (*ProxyEngineRequest) GetBackendStoreDriver added in v1.5.0 

func (m *ProxyEngineRequest) GetBackendStoreDriver() BackendStoreDriver

func (*ProxyEngineRequest) GetEngineName added in v1.5.0 

func (m *ProxyEngineRequest) GetEngineName() string

func (*ProxyEngineRequest) GetVolumeName added in v1.5.2 

func (m *ProxyEngineRequest) GetVolumeName() string

func (*ProxyEngineRequest) ProtoMessage 

func (*ProxyEngineRequest) ProtoMessage()

func (*ProxyEngineRequest) Reset 

func (m *ProxyEngineRequest) Reset()

func (*ProxyEngineRequest) String 

func (m *ProxyEngineRequest) String() string

func (*ProxyEngineRequest) XXX_DiscardUnknown 

func (m *ProxyEngineRequest) XXX_DiscardUnknown()

func (*ProxyEngineRequest) XXX_Marshal 

func (m *ProxyEngineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyEngineRequest) XXX_Merge 

func (m *ProxyEngineRequest) XXX_Merge(src proto.Message)

func (*ProxyEngineRequest) XXX_Size 

func (m *ProxyEngineRequest) XXX_Size() int

func (*ProxyEngineRequest) XXX_Unmarshal 

func (m *ProxyEngineRequest) XXX_Unmarshal(b []byte) error

type ProxyEngineServiceClient 

type ProxyEngineServiceClient interface {
	ServerVersionGet(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineVersionProxyResponse, error)
	VolumeGet(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineVolumeGetProxyResponse, error)
	VolumeExpand(ctx context.Context, in *EngineVolumeExpandRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VolumeFrontendStart(ctx context.Context, in *EngineVolumeFrontendStartRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VolumeFrontendShutdown(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VolumeUnmapMarkSnapChainRemovedSet(ctx context.Context, in *EngineVolumeUnmapMarkSnapChainRemovedSetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VolumeSnapshot(ctx context.Context, in *EngineVolumeSnapshotRequest, opts ...grpc.CallOption) (*EngineVolumeSnapshotProxyResponse, error)
	SnapshotList(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineSnapshotListProxyResponse, error)
	SnapshotRevert(ctx context.Context, in *EngineSnapshotRevertRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SnapshotPurge(ctx context.Context, in *EngineSnapshotPurgeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SnapshotPurgeStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineSnapshotPurgeStatusProxyResponse, error)
	SnapshotClone(ctx context.Context, in *EngineSnapshotCloneRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SnapshotCloneStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineSnapshotCloneStatusProxyResponse, error)
	SnapshotRemove(ctx context.Context, in *EngineSnapshotRemoveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SnapshotHash(ctx context.Context, in *EngineSnapshotHashRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SnapshotHashStatus(ctx context.Context, in *EngineSnapshotHashStatusRequest, opts ...grpc.CallOption) (*EngineSnapshotHashStatusProxyResponse, error)
	SnapshotBackup(ctx context.Context, in *EngineSnapshotBackupRequest, opts ...grpc.CallOption) (*EngineSnapshotBackupProxyResponse, error)
	SnapshotBackupStatus(ctx context.Context, in *EngineSnapshotBackupStatusRequest, opts ...grpc.CallOption) (*EngineSnapshotBackupStatusProxyResponse, error)
	BackupRestore(ctx context.Context, in *EngineBackupRestoreRequest, opts ...grpc.CallOption) (*EngineBackupRestoreProxyResponse, error)
	BackupRestoreStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineBackupRestoreStatusProxyResponse, error)
	ReplicaAdd(ctx context.Context, in *EngineReplicaAddRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReplicaList(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineReplicaListProxyResponse, error)
	ReplicaRebuildingStatus(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineReplicaRebuildStatusProxyResponse, error)
	ReplicaVerifyRebuild(ctx context.Context, in *EngineReplicaVerifyRebuildRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReplicaRemove(ctx context.Context, in *EngineReplicaRemoveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReplicaModeUpdate(ctx context.Context, in *EngineReplicaModeUpdateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	MetricsGet(ctx context.Context, in *ProxyEngineRequest, opts ...grpc.CallOption) (*EngineMetricsGetProxyResponse, error)
}

ProxyEngineServiceClient is the client API for ProxyEngineService service.

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

func NewProxyEngineServiceClient 

func NewProxyEngineServiceClient(cc *grpc.ClientConn) ProxyEngineServiceClient

type ProxyEngineServiceServer 

type ProxyEngineServiceServer interface {
	ServerVersionGet(context.Context, *ProxyEngineRequest) (*EngineVersionProxyResponse, error)
	VolumeGet(context.Context, *ProxyEngineRequest) (*EngineVolumeGetProxyResponse, error)
	VolumeExpand(context.Context, *EngineVolumeExpandRequest) (*empty.Empty, error)
	VolumeFrontendStart(context.Context, *EngineVolumeFrontendStartRequest) (*empty.Empty, error)
	VolumeFrontendShutdown(context.Context, *ProxyEngineRequest) (*empty.Empty, error)
	VolumeUnmapMarkSnapChainRemovedSet(context.Context, *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) (*empty.Empty, error)
	VolumeSnapshot(context.Context, *EngineVolumeSnapshotRequest) (*EngineVolumeSnapshotProxyResponse, error)
	SnapshotList(context.Context, *ProxyEngineRequest) (*EngineSnapshotListProxyResponse, error)
	SnapshotRevert(context.Context, *EngineSnapshotRevertRequest) (*empty.Empty, error)
	SnapshotPurge(context.Context, *EngineSnapshotPurgeRequest) (*empty.Empty, error)
	SnapshotPurgeStatus(context.Context, *ProxyEngineRequest) (*EngineSnapshotPurgeStatusProxyResponse, error)
	SnapshotClone(context.Context, *EngineSnapshotCloneRequest) (*empty.Empty, error)
	SnapshotCloneStatus(context.Context, *ProxyEngineRequest) (*EngineSnapshotCloneStatusProxyResponse, error)
	SnapshotRemove(context.Context, *EngineSnapshotRemoveRequest) (*empty.Empty, error)
	SnapshotHash(context.Context, *EngineSnapshotHashRequest) (*empty.Empty, error)
	SnapshotHashStatus(context.Context, *EngineSnapshotHashStatusRequest) (*EngineSnapshotHashStatusProxyResponse, error)
	SnapshotBackup(context.Context, *EngineSnapshotBackupRequest) (*EngineSnapshotBackupProxyResponse, error)
	SnapshotBackupStatus(context.Context, *EngineSnapshotBackupStatusRequest) (*EngineSnapshotBackupStatusProxyResponse, error)
	BackupRestore(context.Context, *EngineBackupRestoreRequest) (*EngineBackupRestoreProxyResponse, error)
	BackupRestoreStatus(context.Context, *ProxyEngineRequest) (*EngineBackupRestoreStatusProxyResponse, error)
	ReplicaAdd(context.Context, *EngineReplicaAddRequest) (*empty.Empty, error)
	ReplicaList(context.Context, *ProxyEngineRequest) (*EngineReplicaListProxyResponse, error)
	ReplicaRebuildingStatus(context.Context, *ProxyEngineRequest) (*EngineReplicaRebuildStatusProxyResponse, error)
	ReplicaVerifyRebuild(context.Context, *EngineReplicaVerifyRebuildRequest) (*empty.Empty, error)
	ReplicaRemove(context.Context, *EngineReplicaRemoveRequest) (*empty.Empty, error)
	ReplicaModeUpdate(context.Context, *EngineReplicaModeUpdateRequest) (*empty.Empty, error)
	MetricsGet(context.Context, *ProxyEngineRequest) (*EngineMetricsGetProxyResponse, error)
}

ProxyEngineServiceServer is the server API for ProxyEngineService service.

type ReplicaInstance added in v1.5.0 

type ReplicaInstance struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uuid                 string   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	DiskName             string   `protobuf:"bytes,3,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid             string   `protobuf:"bytes,4,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	SpecSize             uint64   `protobuf:"varint,5,opt,name=spec_size,json=specSize,proto3" json:"spec_size,omitempty"`
	ActualSize           uint64   `protobuf:"varint,6,opt,name=actual_size,json=actualSize,proto3" json:"actual_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaInstance) Descriptor added in v1.5.0 

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

func (*ReplicaInstance) GetActualSize added in v1.5.0 

func (m *ReplicaInstance) GetActualSize() uint64

func (*ReplicaInstance) GetDiskName added in v1.5.0 

func (m *ReplicaInstance) GetDiskName() string

func (*ReplicaInstance) GetDiskUuid added in v1.5.0 

func (m *ReplicaInstance) GetDiskUuid() string

func (*ReplicaInstance) GetName added in v1.5.0 

func (m *ReplicaInstance) GetName() string

func (*ReplicaInstance) GetSpecSize added in v1.5.0 

func (m *ReplicaInstance) GetSpecSize() uint64

func (*ReplicaInstance) GetUuid added in v1.5.0 

func (m *ReplicaInstance) GetUuid() string

func (*ReplicaInstance) ProtoMessage added in v1.5.0 

func (*ReplicaInstance) ProtoMessage()

func (*ReplicaInstance) Reset added in v1.5.0 

func (m *ReplicaInstance) Reset()

func (*ReplicaInstance) String added in v1.5.0 

func (m *ReplicaInstance) String() string

func (*ReplicaInstance) XXX_DiscardUnknown added in v1.5.0 

func (m *ReplicaInstance) XXX_DiscardUnknown()

func (*ReplicaInstance) XXX_Marshal added in v1.5.0 

func (m *ReplicaInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaInstance) XXX_Merge added in v1.5.0 

func (m *ReplicaInstance) XXX_Merge(src proto.Message)

func (*ReplicaInstance) XXX_Size added in v1.5.0 

func (m *ReplicaInstance) XXX_Size() int

func (*ReplicaInstance) XXX_Unmarshal added in v1.5.0 

func (m *ReplicaInstance) XXX_Unmarshal(b []byte) error

type SpdkInstanceSpec added in v1.5.0 

type SpdkInstanceSpec struct {
	ReplicaAddressMap    map[string]string `` /* 202-byte string literal not displayed */
	DiskName             string            `protobuf:"bytes,2,opt,name=disk_name,json=diskName,proto3" json:"disk_name,omitempty"`
	DiskUuid             string            `protobuf:"bytes,3,opt,name=disk_uuid,json=diskUuid,proto3" json:"disk_uuid,omitempty"`
	Size                 uint64            `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	ExposeRequired       bool              `protobuf:"varint,5,opt,name=expose_required,json=exposeRequired,proto3" json:"expose_required,omitempty"`
	Frontend             string            `protobuf:"bytes,6,opt,name=frontend,proto3" json:"frontend,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SpdkInstanceSpec) Descriptor added in v1.5.0 

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

func (*SpdkInstanceSpec) GetDiskName added in v1.5.0 

func (m *SpdkInstanceSpec) GetDiskName() string

func (*SpdkInstanceSpec) GetDiskUuid added in v1.5.0 

func (m *SpdkInstanceSpec) GetDiskUuid() string

func (*SpdkInstanceSpec) GetExposeRequired added in v1.5.0 

func (m *SpdkInstanceSpec) GetExposeRequired() bool

func (*SpdkInstanceSpec) GetFrontend added in v1.5.0 

func (m *SpdkInstanceSpec) GetFrontend() string

func (*SpdkInstanceSpec) GetReplicaAddressMap added in v1.5.0 

func (m *SpdkInstanceSpec) GetReplicaAddressMap() map[string]string

func (*SpdkInstanceSpec) GetSize added in v1.5.0 

func (m *SpdkInstanceSpec) GetSize() uint64

func (*SpdkInstanceSpec) ProtoMessage added in v1.5.0 

func (*SpdkInstanceSpec) ProtoMessage()

func (*SpdkInstanceSpec) Reset added in v1.5.0 

func (m *SpdkInstanceSpec) Reset()

func (*SpdkInstanceSpec) String added in v1.5.0 

func (m *SpdkInstanceSpec) String() string

func (*SpdkInstanceSpec) XXX_DiscardUnknown added in v1.5.0 

func (m *SpdkInstanceSpec) XXX_DiscardUnknown()

func (*SpdkInstanceSpec) XXX_Marshal added in v1.5.0 

func (m *SpdkInstanceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpdkInstanceSpec) XXX_Merge added in v1.5.0 

func (m *SpdkInstanceSpec) XXX_Merge(src proto.Message)

func (*SpdkInstanceSpec) XXX_Size added in v1.5.0 

func (m *SpdkInstanceSpec) XXX_Size() int

func (*SpdkInstanceSpec) XXX_Unmarshal added in v1.5.0 

func (m *SpdkInstanceSpec) XXX_Unmarshal(b []byte) error

type UnimplementedDiskServiceServer added in v1.5.0 

type UnimplementedDiskServiceServer struct {
}

UnimplementedDiskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiskServiceServer) DiskCreate added in v1.5.0 

func (*UnimplementedDiskServiceServer) DiskCreate(ctx context.Context, req *DiskCreateRequest) (*Disk, error)

func (*UnimplementedDiskServiceServer) DiskDelete added in v1.5.0 

func (*UnimplementedDiskServiceServer) DiskDelete(ctx context.Context, req *DiskDeleteRequest) (*empty.Empty, error)

func (*UnimplementedDiskServiceServer) DiskGet added in v1.5.0 

func (*UnimplementedDiskServiceServer) DiskGet(ctx context.Context, req *DiskGetRequest) (*Disk, error)

func (*UnimplementedDiskServiceServer) DiskReplicaInstanceDelete added in v1.5.0 

func (*UnimplementedDiskServiceServer) DiskReplicaInstanceDelete(ctx context.Context, req *DiskReplicaInstanceDeleteRequest) (*empty.Empty, error)

func (*UnimplementedDiskServiceServer) DiskReplicaInstanceList added in v1.5.0 

func (*UnimplementedDiskServiceServer) DiskReplicaInstanceList(ctx context.Context, req *DiskReplicaInstanceListRequest) (*DiskReplicaInstanceListResponse, error)

func (*UnimplementedDiskServiceServer) VersionGet added in v1.5.0 

func (*UnimplementedDiskServiceServer) VersionGet(ctx context.Context, req *empty.Empty) (*DiskVersionResponse, error)

type UnimplementedInstanceServiceServer added in v1.5.0 

type UnimplementedInstanceServiceServer struct {
}

UnimplementedInstanceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedInstanceServiceServer) InstanceCreate added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceCreate(ctx context.Context, req *InstanceCreateRequest) (*InstanceResponse, error)

func (*UnimplementedInstanceServiceServer) InstanceDelete added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceDelete(ctx context.Context, req *InstanceDeleteRequest) (*InstanceResponse, error)

func (*UnimplementedInstanceServiceServer) InstanceGet added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceGet(ctx context.Context, req *InstanceGetRequest) (*InstanceResponse, error)

func (*UnimplementedInstanceServiceServer) InstanceList added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceList(ctx context.Context, req *empty.Empty) (*InstanceListResponse, error)

func (*UnimplementedInstanceServiceServer) InstanceLog added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceLog(req *InstanceLogRequest, srv InstanceService_InstanceLogServer) error

func (*UnimplementedInstanceServiceServer) InstanceReplace added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceReplace(ctx context.Context, req *InstanceReplaceRequest) (*InstanceResponse, error)

func (*UnimplementedInstanceServiceServer) InstanceWatch added in v1.5.0 

func (*UnimplementedInstanceServiceServer) InstanceWatch(req *empty.Empty, srv InstanceService_InstanceWatchServer) error

func (*UnimplementedInstanceServiceServer) VersionGet added in v1.5.0 

func (*UnimplementedInstanceServiceServer) VersionGet(ctx context.Context, req *empty.Empty) (*VersionResponse, error)

type UnimplementedProcessManagerServiceServer 

type UnimplementedProcessManagerServiceServer struct {
}

UnimplementedProcessManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessManagerServiceServer) ProcessCreate 

func (*UnimplementedProcessManagerServiceServer) ProcessCreate(ctx context.Context, req *ProcessCreateRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessDelete 

func (*UnimplementedProcessManagerServiceServer) ProcessDelete(ctx context.Context, req *ProcessDeleteRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessGet 

func (*UnimplementedProcessManagerServiceServer) ProcessGet(ctx context.Context, req *ProcessGetRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessList 

func (*UnimplementedProcessManagerServiceServer) ProcessList(ctx context.Context, req *ProcessListRequest) (*ProcessListResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessLog 

func (*UnimplementedProcessManagerServiceServer) ProcessLog(req *LogRequest, srv ProcessManagerService_ProcessLogServer) error

func (*UnimplementedProcessManagerServiceServer) ProcessReplace 

func (*UnimplementedProcessManagerServiceServer) ProcessReplace(ctx context.Context, req *ProcessReplaceRequest) (*ProcessResponse, error)

func (*UnimplementedProcessManagerServiceServer) ProcessWatch 

func (*UnimplementedProcessManagerServiceServer) ProcessWatch(req *empty.Empty, srv ProcessManagerService_ProcessWatchServer) error

func (*UnimplementedProcessManagerServiceServer) VersionGet 

func (*UnimplementedProcessManagerServiceServer) VersionGet(ctx context.Context, req *empty.Empty) (*VersionResponse, error)

type UnimplementedProxyEngineServiceServer 

type UnimplementedProxyEngineServiceServer struct {
}

UnimplementedProxyEngineServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedProxyEngineServiceServer) BackupRestore 

func (*UnimplementedProxyEngineServiceServer) BackupRestore(ctx context.Context, req *EngineBackupRestoreRequest) (*EngineBackupRestoreProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) BackupRestoreStatus 

func (*UnimplementedProxyEngineServiceServer) BackupRestoreStatus(ctx context.Context, req *ProxyEngineRequest) (*EngineBackupRestoreStatusProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) MetricsGet 

func (*UnimplementedProxyEngineServiceServer) MetricsGet(ctx context.Context, req *ProxyEngineRequest) (*EngineMetricsGetProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) ReplicaAdd 

func (*UnimplementedProxyEngineServiceServer) ReplicaAdd(ctx context.Context, req *EngineReplicaAddRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) ReplicaList 

func (*UnimplementedProxyEngineServiceServer) ReplicaList(ctx context.Context, req *ProxyEngineRequest) (*EngineReplicaListProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) ReplicaModeUpdate 

func (*UnimplementedProxyEngineServiceServer) ReplicaModeUpdate(ctx context.Context, req *EngineReplicaModeUpdateRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) ReplicaRebuildingStatus 

func (*UnimplementedProxyEngineServiceServer) ReplicaRebuildingStatus(ctx context.Context, req *ProxyEngineRequest) (*EngineReplicaRebuildStatusProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) ReplicaRemove 

func (*UnimplementedProxyEngineServiceServer) ReplicaRemove(ctx context.Context, req *EngineReplicaRemoveRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) ReplicaVerifyRebuild 

func (*UnimplementedProxyEngineServiceServer) ReplicaVerifyRebuild(ctx context.Context, req *EngineReplicaVerifyRebuildRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) ServerVersionGet 

func (*UnimplementedProxyEngineServiceServer) ServerVersionGet(ctx context.Context, req *ProxyEngineRequest) (*EngineVersionProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotBackup 

func (*UnimplementedProxyEngineServiceServer) SnapshotBackup(ctx context.Context, req *EngineSnapshotBackupRequest) (*EngineSnapshotBackupProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotBackupStatus 

func (*UnimplementedProxyEngineServiceServer) SnapshotBackupStatus(ctx context.Context, req *EngineSnapshotBackupStatusRequest) (*EngineSnapshotBackupStatusProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotClone 

func (*UnimplementedProxyEngineServiceServer) SnapshotClone(ctx context.Context, req *EngineSnapshotCloneRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotCloneStatus 

func (*UnimplementedProxyEngineServiceServer) SnapshotCloneStatus(ctx context.Context, req *ProxyEngineRequest) (*EngineSnapshotCloneStatusProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotHash 

func (*UnimplementedProxyEngineServiceServer) SnapshotHash(ctx context.Context, req *EngineSnapshotHashRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotHashStatus 

func (*UnimplementedProxyEngineServiceServer) SnapshotHashStatus(ctx context.Context, req *EngineSnapshotHashStatusRequest) (*EngineSnapshotHashStatusProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotList 

func (*UnimplementedProxyEngineServiceServer) SnapshotList(ctx context.Context, req *ProxyEngineRequest) (*EngineSnapshotListProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotPurge 

func (*UnimplementedProxyEngineServiceServer) SnapshotPurge(ctx context.Context, req *EngineSnapshotPurgeRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotPurgeStatus 

func (*UnimplementedProxyEngineServiceServer) SnapshotPurgeStatus(ctx context.Context, req *ProxyEngineRequest) (*EngineSnapshotPurgeStatusProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotRemove 

func (*UnimplementedProxyEngineServiceServer) SnapshotRemove(ctx context.Context, req *EngineSnapshotRemoveRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) SnapshotRevert 

func (*UnimplementedProxyEngineServiceServer) SnapshotRevert(ctx context.Context, req *EngineSnapshotRevertRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) VolumeExpand 

func (*UnimplementedProxyEngineServiceServer) VolumeExpand(ctx context.Context, req *EngineVolumeExpandRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) VolumeFrontendShutdown 

func (*UnimplementedProxyEngineServiceServer) VolumeFrontendShutdown(ctx context.Context, req *ProxyEngineRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) VolumeFrontendStart 

func (*UnimplementedProxyEngineServiceServer) VolumeFrontendStart(ctx context.Context, req *EngineVolumeFrontendStartRequest) (*empty.Empty, error)

func (*UnimplementedProxyEngineServiceServer) VolumeGet 

func (*UnimplementedProxyEngineServiceServer) VolumeGet(ctx context.Context, req *ProxyEngineRequest) (*EngineVolumeGetProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) VolumeSnapshot 

func (*UnimplementedProxyEngineServiceServer) VolumeSnapshot(ctx context.Context, req *EngineVolumeSnapshotRequest) (*EngineVolumeSnapshotProxyResponse, error)

func (*UnimplementedProxyEngineServiceServer) VolumeUnmapMarkSnapChainRemovedSet 

func (*UnimplementedProxyEngineServiceServer) VolumeUnmapMarkSnapChainRemovedSet(ctx context.Context, req *EngineVolumeUnmapMarkSnapChainRemovedSetRequest) (*empty.Empty, error)

type VersionResponse 

type VersionResponse struct {
	Version                           string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	GitCommit                         string   `protobuf:"bytes,2,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"`
	BuildDate                         string   `protobuf:"bytes,3,opt,name=buildDate,proto3" json:"buildDate,omitempty"`
	InstanceManagerAPIVersion         int64    `protobuf:"varint,4,opt,name=instanceManagerAPIVersion,proto3" json:"instanceManagerAPIVersion,omitempty"`
	InstanceManagerAPIMinVersion      int64    `protobuf:"varint,5,opt,name=instanceManagerAPIMinVersion,proto3" json:"instanceManagerAPIMinVersion,omitempty"`
	InstanceManagerProxyAPIVersion    int64    `protobuf:"varint,6,opt,name=instanceManagerProxyAPIVersion,proto3" json:"instanceManagerProxyAPIVersion,omitempty"`
	InstanceManagerProxyAPIMinVersion int64    `protobuf:"varint,7,opt,name=instanceManagerProxyAPIMinVersion,proto3" json:"instanceManagerProxyAPIMinVersion,omitempty"`
	XXX_NoUnkeyedLiteral              struct{} `json:"-"`
	XXX_unrecognized                  []byte   `json:"-"`
	XXX_sizecache                     int32    `json:"-"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetBuildDate 

func (m *VersionResponse) GetBuildDate() string

func (*VersionResponse) GetGitCommit 

func (m *VersionResponse) GetGitCommit() string

func (*VersionResponse) GetInstanceManagerAPIMinVersion 

func (m *VersionResponse) GetInstanceManagerAPIMinVersion() int64

func (*VersionResponse) GetInstanceManagerAPIVersion 

func (m *VersionResponse) GetInstanceManagerAPIVersion() int64

func (*VersionResponse) GetInstanceManagerProxyAPIMinVersion 

func (m *VersionResponse) GetInstanceManagerProxyAPIMinVersion() int64

func (*VersionResponse) GetInstanceManagerProxyAPIVersion 

func (m *VersionResponse) GetInstanceManagerProxyAPIVersion() int64

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionResponse) XXX_Merge 

func (m *VersionResponse) XXX_Merge(src proto.Message)

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

func (m *VersionResponse) XXX_Unmarshal(b []byte) error

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.