sdfs

package
v0.1.36 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2021 License: Apache-2.0 Imports: 9 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Syncaction_name = map[int32]string{
		0: "DOWNLOAD",
		1: "WRITE",
		2: "DELETE",
		3: "UPLOAD",
		4: "KEEPALIVE",
	}
	Syncaction_value = map[string]int32{
		"DOWNLOAD":  0,
		"WRITE":     1,
		"DELETE":    2,
		"UPLOAD":    3,
		"KEEPALIVE": 4,
	}
)

Enum value maps for Syncaction.

View Source 
var (
	ErrorCodes_name = map[int32]string{
		0:   "NOERR",
		2:   "ENOENT",
		5:   "EIO",
		11:  "EAGAIN",
		17:  "EEXIST",
		20:  "ENOTDIR",
		61:  "ENODATA",
		119: "ENAVAIL",
		1:   "EPERM",
		28:  "ENOSPC",
		13:  "EACCES",
		39:  "ENOTEMPTY",
		38:  "ENOSYS",
		19:  "ENODEV",
		77:  "EBADFD",
		21:  "EISDIR",
	}
	ErrorCodes_value = map[string]int32{
		"NOERR":     0,
		"ENOENT":    2,
		"EIO":       5,
		"EAGAIN":    11,
		"EEXIST":    17,
		"ENOTDIR":   20,
		"ENODATA":   61,
		"ENAVAIL":   119,
		"EPERM":     1,
		"ENOSPC":    28,
		"EACCES":    13,
		"ENOTEMPTY": 39,
		"ENOSYS":    38,
		"ENODEV":    19,
		"EBADFD":    77,
		"EISDIR":    21,
	}
)

Enum value maps for ErrorCodes.

View Source 
var (
	FileInfoResponseFileType_name = map[int32]string{
		0: "FILE",
		1: "DIR",
	}
	FileInfoResponseFileType_value = map[string]int32{
		"FILE": 0,
		"DIR":  1,
	}
)

Enum value maps for FileInfoResponseFileType.

View Source 
var (
	SetXAttrResponseFlagsenum_name = map[int32]string{
		0: "XATTR_CREATE",
		1: "XATTR_REPLACE",
	}
	SetXAttrResponseFlagsenum_value = map[string]int32{
		"XATTR_CREATE":  0,
		"XATTR_REPLACE": 1,
	}
)

Enum value maps for SetXAttrResponseFlagsenum.

View Source 
var (
	MessageQueueInfoResponse_MQType_name = map[int32]string{
		0: "RabbitMQ",
		1: "PubSub",
	}
	MessageQueueInfoResponse_MQType_value = map[string]int32{
		"RabbitMQ": 0,
		"PubSub":   1,
	}
)

Enum value maps for MessageQueueInfoResponse_MQType.

View Source 
var File_FileInfo_proto protoreflect.FileDescriptor
View Source 
var File_IOService_proto protoreflect.FileDescriptor
View Source 
var File_SDFSEvent_proto protoreflect.FileDescriptor
View Source 
var File_Shutdown_proto protoreflect.FileDescriptor
View Source 
var File_VolumeService_proto protoreflect.FileDescriptor

Functions

func RegisterFileIOServiceServer 

func RegisterFileIOServiceServer(s *grpc.Server, srv FileIOServiceServer)

func RegisterSDFSEventServiceServer added in v0.1.9 

func RegisterSDFSEventServiceServer(s *grpc.Server, srv SDFSEventServiceServer)

func RegisterVolumeServiceServer 

func RegisterVolumeServiceServer(s *grpc.Server, srv VolumeServiceServer)

Types

type AuthenticationRequest added in v0.1.8 

type AuthenticationRequest struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticationRequest) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use AuthenticationRequest.ProtoReflect.Descriptor instead.

func (*AuthenticationRequest) GetPassword added in v0.1.8 

func (x *AuthenticationRequest) GetPassword() string

func (*AuthenticationRequest) GetUsername added in v0.1.8 

func (x *AuthenticationRequest) GetUsername() string

func (*AuthenticationRequest) ProtoMessage added in v0.1.8 

func (*AuthenticationRequest) ProtoMessage()

func (*AuthenticationRequest) ProtoReflect added in v0.1.8 

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

func (*AuthenticationRequest) Reset added in v0.1.8 

func (x *AuthenticationRequest) Reset()

func (*AuthenticationRequest) String added in v0.1.8 

func (x *AuthenticationRequest) String() string

type AuthenticationResponse added in v0.1.8 

type AuthenticationResponse struct {
	Token     string     `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticationResponse) Descriptor deprecated added in v0.1.8 

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

Deprecated: Use AuthenticationResponse.ProtoReflect.Descriptor instead.

func (*AuthenticationResponse) GetError added in v0.1.8 

func (x *AuthenticationResponse) GetError() string

func (*AuthenticationResponse) GetErrorCode added in v0.1.8 

func (x *AuthenticationResponse) GetErrorCode() ErrorCodes

func (*AuthenticationResponse) GetToken added in v0.1.8 

func (x *AuthenticationResponse) GetToken() string

func (*AuthenticationResponse) ProtoMessage added in v0.1.8 

func (*AuthenticationResponse) ProtoMessage()

func (*AuthenticationResponse) ProtoReflect added in v0.1.8 

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

func (*AuthenticationResponse) Reset added in v0.1.8 

func (x *AuthenticationResponse) Reset()

func (*AuthenticationResponse) String added in v0.1.8 

func (x *AuthenticationResponse) String() string

type ChmodRequest added in v0.1.9 

type ChmodRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode int32  `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ChmodRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use ChmodRequest.ProtoReflect.Descriptor instead.

func (*ChmodRequest) GetMode added in v0.1.9 

func (x *ChmodRequest) GetMode() int32

func (*ChmodRequest) GetPath added in v0.1.9 

func (x *ChmodRequest) GetPath() string

func (*ChmodRequest) ProtoMessage added in v0.1.9 

func (*ChmodRequest) ProtoMessage()

func (*ChmodRequest) ProtoReflect added in v0.1.9 

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

func (*ChmodRequest) Reset added in v0.1.9 

func (x *ChmodRequest) Reset()

func (*ChmodRequest) String added in v0.1.9 

func (x *ChmodRequest) String() string

type ChmodResponse added in v0.1.9 

type ChmodResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*ChmodResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use ChmodResponse.ProtoReflect.Descriptor instead.

func (*ChmodResponse) GetError added in v0.1.9 

func (x *ChmodResponse) GetError() string

func (*ChmodResponse) GetErrorCode added in v0.1.9 

func (x *ChmodResponse) GetErrorCode() ErrorCodes

func (*ChmodResponse) ProtoMessage added in v0.1.9 

func (*ChmodResponse) ProtoMessage()

func (*ChmodResponse) ProtoReflect added in v0.1.9 

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

func (*ChmodResponse) Reset added in v0.1.9 

func (x *ChmodResponse) Reset()

func (*ChmodResponse) String added in v0.1.9 

func (x *ChmodResponse) String() string

type ChownRequest added in v0.1.9 

type ChownRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Uid  int32  `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid  int32  `protobuf:"varint,3,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*ChownRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use ChownRequest.ProtoReflect.Descriptor instead.

func (*ChownRequest) GetGid added in v0.1.9 

func (x *ChownRequest) GetGid() int32

func (*ChownRequest) GetPath added in v0.1.9 

func (x *ChownRequest) GetPath() string

func (*ChownRequest) GetUid added in v0.1.9 

func (x *ChownRequest) GetUid() int32

func (*ChownRequest) ProtoMessage added in v0.1.9 

func (*ChownRequest) ProtoMessage()

func (*ChownRequest) ProtoReflect added in v0.1.9 

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

func (*ChownRequest) Reset added in v0.1.9 

func (x *ChownRequest) Reset()

func (*ChownRequest) String added in v0.1.9 

func (x *ChownRequest) String() string

type ChownResponse added in v0.1.9 

type ChownResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*ChownResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use ChownResponse.ProtoReflect.Descriptor instead.

func (*ChownResponse) GetError added in v0.1.9 

func (x *ChownResponse) GetError() string

func (*ChownResponse) GetErrorCode added in v0.1.9 

func (x *ChownResponse) GetErrorCode() ErrorCodes

func (*ChownResponse) ProtoMessage added in v0.1.9 

func (*ChownResponse) ProtoMessage()

func (*ChownResponse) ProtoReflect added in v0.1.9 

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

func (*ChownResponse) Reset added in v0.1.9 

func (x *ChownResponse) Reset()

func (*ChownResponse) String added in v0.1.9 

func (x *ChownResponse) String() string

type CleanStoreRequest added in v0.1.9 

type CleanStoreRequest struct {
	Compact bool `protobuf:"varint,1,opt,name=compact,proto3" json:"compact,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanStoreRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use CleanStoreRequest.ProtoReflect.Descriptor instead.

func (*CleanStoreRequest) GetCompact added in v0.1.9 

func (x *CleanStoreRequest) GetCompact() bool

func (*CleanStoreRequest) ProtoMessage added in v0.1.9 

func (*CleanStoreRequest) ProtoMessage()

func (*CleanStoreRequest) ProtoReflect added in v0.1.9 

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

func (*CleanStoreRequest) Reset added in v0.1.9 

func (x *CleanStoreRequest) Reset()

func (*CleanStoreRequest) String added in v0.1.9 

func (x *CleanStoreRequest) String() string

type CleanStoreResponse added in v0.1.9 

type CleanStoreResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanStoreResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use CleanStoreResponse.ProtoReflect.Descriptor instead.

func (*CleanStoreResponse) GetError added in v0.1.9 

func (x *CleanStoreResponse) GetError() string

func (*CleanStoreResponse) GetErrorCode added in v0.1.9 

func (x *CleanStoreResponse) GetErrorCode() ErrorCodes

func (*CleanStoreResponse) GetEventID added in v0.1.9 

func (x *CleanStoreResponse) GetEventID() string

func (*CleanStoreResponse) ProtoMessage added in v0.1.9 

func (*CleanStoreResponse) ProtoMessage()

func (*CleanStoreResponse) ProtoReflect added in v0.1.9 

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

func (*CleanStoreResponse) Reset added in v0.1.9 

func (x *CleanStoreResponse) Reset()

func (*CleanStoreResponse) String added in v0.1.9 

func (x *CleanStoreResponse) String() string

type CloudVolumesRequest added in v0.1.9 

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

func (*CloudVolumesRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use CloudVolumesRequest.ProtoReflect.Descriptor instead.

func (*CloudVolumesRequest) ProtoMessage added in v0.1.9 

func (*CloudVolumesRequest) ProtoMessage()

func (*CloudVolumesRequest) ProtoReflect added in v0.1.9 

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

func (*CloudVolumesRequest) Reset added in v0.1.9 

func (x *CloudVolumesRequest) Reset()

func (*CloudVolumesRequest) String added in v0.1.9 

func (x *CloudVolumesRequest) String() string

type CloudVolumesResponse added in v0.1.9 

type CloudVolumesResponse struct {
	VolumeInfo []*ConnectedVolumeInfo `protobuf:"bytes,1,rep,name=volumeInfo,proto3" json:"volumeInfo,omitempty"`
	Error      string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode  ErrorCodes             `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudVolumesResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use CloudVolumesResponse.ProtoReflect.Descriptor instead.

func (*CloudVolumesResponse) GetError added in v0.1.9 

func (x *CloudVolumesResponse) GetError() string

func (*CloudVolumesResponse) GetErrorCode added in v0.1.9 

func (x *CloudVolumesResponse) GetErrorCode() ErrorCodes

func (*CloudVolumesResponse) GetVolumeInfo added in v0.1.9 

func (x *CloudVolumesResponse) GetVolumeInfo() []*ConnectedVolumeInfo

func (*CloudVolumesResponse) ProtoMessage added in v0.1.9 

func (*CloudVolumesResponse) ProtoMessage()

func (*CloudVolumesResponse) ProtoReflect added in v0.1.9 

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

func (*CloudVolumesResponse) Reset added in v0.1.9 

func (x *CloudVolumesResponse) Reset()

func (*CloudVolumesResponse) String added in v0.1.9 

func (x *CloudVolumesResponse) String() string

type ConnectedVolumeInfo added in v0.1.9 

type ConnectedVolumeInfo struct {
	Id             int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Local          bool   `protobuf:"varint,2,opt,name=local,proto3" json:"local,omitempty"`
	Hostname       string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port           int32  `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	Size           int64  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	CompressedSize int64  `protobuf:"varint,6,opt,name=compressedSize,proto3" json:"compressedSize,omitempty"`
	SdfsVersion    string `protobuf:"bytes,7,opt,name=sdfsVersion,proto3" json:"sdfsVersion,omitempty"`
	LastUpdate     int64  `protobuf:"varint,8,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	Version        int32  `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectedVolumeInfo) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use ConnectedVolumeInfo.ProtoReflect.Descriptor instead.

func (*ConnectedVolumeInfo) GetCompressedSize added in v0.1.9 

func (x *ConnectedVolumeInfo) GetCompressedSize() int64

func (*ConnectedVolumeInfo) GetHostname added in v0.1.9 

func (x *ConnectedVolumeInfo) GetHostname() string

func (*ConnectedVolumeInfo) GetId added in v0.1.9 

func (x *ConnectedVolumeInfo) GetId() int64

func (*ConnectedVolumeInfo) GetLastUpdate added in v0.1.9 

func (x *ConnectedVolumeInfo) GetLastUpdate() int64

func (*ConnectedVolumeInfo) GetLocal added in v0.1.9 

func (x *ConnectedVolumeInfo) GetLocal() bool

func (*ConnectedVolumeInfo) GetPort added in v0.1.9 

func (x *ConnectedVolumeInfo) GetPort() int32

func (*ConnectedVolumeInfo) GetSdfsVersion added in v0.1.9 

func (x *ConnectedVolumeInfo) GetSdfsVersion() string

func (*ConnectedVolumeInfo) GetSize added in v0.1.9 

func (x *ConnectedVolumeInfo) GetSize() int64

func (*ConnectedVolumeInfo) GetVersion added in v0.1.9 

func (x *ConnectedVolumeInfo) GetVersion() int32

func (*ConnectedVolumeInfo) ProtoMessage added in v0.1.9 

func (*ConnectedVolumeInfo) ProtoMessage()

func (*ConnectedVolumeInfo) ProtoReflect added in v0.1.9 

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

func (*ConnectedVolumeInfo) Reset added in v0.1.9 

func (x *ConnectedVolumeInfo) Reset()

func (*ConnectedVolumeInfo) String added in v0.1.9 

func (x *ConnectedVolumeInfo) String() string

type CopyExtentRequest added in v0.1.4 

type CopyExtentRequest struct {
	SrcFile  string `protobuf:"bytes,1,opt,name=srcFile,proto3" json:"srcFile,omitempty"`
	DstFile  string `protobuf:"bytes,2,opt,name=dstFile,proto3" json:"dstFile,omitempty"`
	SrcStart int64  `protobuf:"varint,3,opt,name=srcStart,proto3" json:"srcStart,omitempty"`
	DstStart int64  `protobuf:"varint,4,opt,name=dstStart,proto3" json:"dstStart,omitempty"`
	Length   int64  `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyExtentRequest) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CopyExtentRequest.ProtoReflect.Descriptor instead.

func (*CopyExtentRequest) GetDstFile added in v0.1.4 

func (x *CopyExtentRequest) GetDstFile() string

func (*CopyExtentRequest) GetDstStart added in v0.1.4 

func (x *CopyExtentRequest) GetDstStart() int64

func (*CopyExtentRequest) GetLength added in v0.1.4 

func (x *CopyExtentRequest) GetLength() int64

func (*CopyExtentRequest) GetSrcFile added in v0.1.4 

func (x *CopyExtentRequest) GetSrcFile() string

func (*CopyExtentRequest) GetSrcStart added in v0.1.4 

func (x *CopyExtentRequest) GetSrcStart() int64

func (*CopyExtentRequest) ProtoMessage added in v0.1.4 

func (*CopyExtentRequest) ProtoMessage()

func (*CopyExtentRequest) ProtoReflect added in v0.1.4 

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

func (*CopyExtentRequest) Reset added in v0.1.4 

func (x *CopyExtentRequest) Reset()

func (*CopyExtentRequest) String added in v0.1.4 

func (x *CopyExtentRequest) String() string

type CopyExtentResponse added in v0.1.4 

type CopyExtentResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	Written   int64      `protobuf:"varint,3,opt,name=written,proto3" json:"written,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyExtentResponse) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use CopyExtentResponse.ProtoReflect.Descriptor instead.

func (*CopyExtentResponse) GetError added in v0.1.4 

func (x *CopyExtentResponse) GetError() string

func (*CopyExtentResponse) GetErrorCode added in v0.1.4 

func (x *CopyExtentResponse) GetErrorCode() ErrorCodes

func (*CopyExtentResponse) GetWritten added in v0.1.4 

func (x *CopyExtentResponse) GetWritten() int64

func (*CopyExtentResponse) ProtoMessage added in v0.1.4 

func (*CopyExtentResponse) ProtoMessage()

func (*CopyExtentResponse) ProtoReflect added in v0.1.4 

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

func (*CopyExtentResponse) Reset added in v0.1.4 

func (x *CopyExtentResponse) Reset()

func (*CopyExtentResponse) String added in v0.1.4 

func (x *CopyExtentResponse) String() string

type DSEInfo added in v0.1.9 

type DSEInfo struct {
	MaxSize         int64  `protobuf:"varint,1,opt,name=maxSize,proto3" json:"maxSize,omitempty"`
	CurrentSize     int64  `protobuf:"varint,2,opt,name=currentSize,proto3" json:"currentSize,omitempty"`
	Entries         int64  `protobuf:"varint,3,opt,name=entries,proto3" json:"entries,omitempty"`
	CompressedSize  int64  `protobuf:"varint,4,opt,name=compressedSize,proto3" json:"compressedSize,omitempty"`
	FreeBlocks      int64  `protobuf:"varint,5,opt,name=freeBlocks,proto3" json:"freeBlocks,omitempty"`
	PageSize        int64  `protobuf:"varint,6,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	StorageType     string `protobuf:"bytes,7,opt,name=storageType,proto3" json:"storageType,omitempty"`
	ListenPort      int32  `protobuf:"varint,8,opt,name=listenPort,proto3" json:"listenPort,omitempty"`
	ListenHost      string `protobuf:"bytes,9,opt,name=listenHost,proto3" json:"listenHost,omitempty"`
	ReadSpeed       int32  `protobuf:"varint,10,opt,name=readSpeed,proto3" json:"readSpeed,omitempty"`
	WriteSpeed      int32  `protobuf:"varint,11,opt,name=writeSpeed,proto3" json:"writeSpeed,omitempty"`
	CacheSize       int64  `protobuf:"varint,12,opt,name=cacheSize,proto3" json:"cacheSize,omitempty"`
	MaxCacheSize    int64  `protobuf:"varint,13,opt,name=maxCacheSize,proto3" json:"maxCacheSize,omitempty"`
	ListenEncrypted bool   `protobuf:"varint,14,opt,name=listenEncrypted,proto3" json:"listenEncrypted,omitempty"`
	EncryptionKey   string `protobuf:"bytes,15,opt,name=encryptionKey,proto3" json:"encryptionKey,omitempty"`
	EncryptionIV    string `protobuf:"bytes,16,opt,name=encryptionIV,proto3" json:"encryptionIV,omitempty"`
	CloudAccessKey  string `protobuf:"bytes,17,opt,name=cloudAccessKey,proto3" json:"cloudAccessKey,omitempty"`
	CloudSecretKey  string `protobuf:"bytes,18,opt,name=cloudSecretKey,proto3" json:"cloudSecretKey,omitempty"`
	// contains filtered or unexported fields
}

func (*DSEInfo) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use DSEInfo.ProtoReflect.Descriptor instead.

func (*DSEInfo) GetCacheSize added in v0.1.9 

func (x *DSEInfo) GetCacheSize() int64

func (*DSEInfo) GetCloudAccessKey added in v0.1.9 

func (x *DSEInfo) GetCloudAccessKey() string

func (*DSEInfo) GetCloudSecretKey added in v0.1.9 

func (x *DSEInfo) GetCloudSecretKey() string

func (*DSEInfo) GetCompressedSize added in v0.1.9 

func (x *DSEInfo) GetCompressedSize() int64

func (*DSEInfo) GetCurrentSize added in v0.1.9 

func (x *DSEInfo) GetCurrentSize() int64

func (*DSEInfo) GetEncryptionIV added in v0.1.9 

func (x *DSEInfo) GetEncryptionIV() string

func (*DSEInfo) GetEncryptionKey added in v0.1.9 

func (x *DSEInfo) GetEncryptionKey() string

func (*DSEInfo) GetEntries added in v0.1.9 

func (x *DSEInfo) GetEntries() int64

func (*DSEInfo) GetFreeBlocks added in v0.1.9 

func (x *DSEInfo) GetFreeBlocks() int64

func (*DSEInfo) GetListenEncrypted added in v0.1.9 

func (x *DSEInfo) GetListenEncrypted() bool

func (*DSEInfo) GetListenHost added in v0.1.9 

func (x *DSEInfo) GetListenHost() string

func (*DSEInfo) GetListenPort added in v0.1.9 

func (x *DSEInfo) GetListenPort() int32

func (*DSEInfo) GetMaxCacheSize added in v0.1.9 

func (x *DSEInfo) GetMaxCacheSize() int64

func (*DSEInfo) GetMaxSize added in v0.1.9 

func (x *DSEInfo) GetMaxSize() int64

func (*DSEInfo) GetPageSize added in v0.1.9 

func (x *DSEInfo) GetPageSize() int64

func (*DSEInfo) GetReadSpeed added in v0.1.9 

func (x *DSEInfo) GetReadSpeed() int32

func (*DSEInfo) GetStorageType added in v0.1.9 

func (x *DSEInfo) GetStorageType() string

func (*DSEInfo) GetWriteSpeed added in v0.1.9 

func (x *DSEInfo) GetWriteSpeed() int32

func (*DSEInfo) ProtoMessage added in v0.1.9 

func (*DSEInfo) ProtoMessage()

func (*DSEInfo) ProtoReflect added in v0.1.9 

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

func (*DSEInfo) Reset added in v0.1.9 

func (x *DSEInfo) Reset()

func (*DSEInfo) String added in v0.1.9 

func (x *DSEInfo) String() string

type DSERequest added in v0.1.9 

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

func (*DSERequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use DSERequest.ProtoReflect.Descriptor instead.

func (*DSERequest) ProtoMessage added in v0.1.9 

func (*DSERequest) ProtoMessage()

func (*DSERequest) ProtoReflect added in v0.1.9 

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

func (*DSERequest) Reset added in v0.1.9 

func (x *DSERequest) Reset()

func (*DSERequest) String added in v0.1.9 

func (x *DSERequest) String() string

type DSEResponse added in v0.1.9 

type DSEResponse struct {
	Info      *DSEInfo   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*DSEResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use DSEResponse.ProtoReflect.Descriptor instead.

func (*DSEResponse) GetError added in v0.1.9 

func (x *DSEResponse) GetError() string

func (*DSEResponse) GetErrorCode added in v0.1.9 

func (x *DSEResponse) GetErrorCode() ErrorCodes

func (*DSEResponse) GetInfo added in v0.1.9 

func (x *DSEResponse) GetInfo() *DSEInfo

func (*DSEResponse) ProtoMessage added in v0.1.9 

func (*DSEResponse) ProtoMessage()

func (*DSEResponse) ProtoReflect added in v0.1.9 

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

func (*DSEResponse) Reset added in v0.1.9 

func (x *DSEResponse) Reset()

func (*DSEResponse) String added in v0.1.9 

func (x *DSEResponse) String() string

type DataReadRequest 

type DataReadRequest struct {
	FileHandle int64 `protobuf:"varint,1,opt,name=fileHandle,proto3" json:"fileHandle,omitempty"`
	Start      int64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	Len        int32 `protobuf:"varint,3,opt,name=len,proto3" json:"len,omitempty"`
	// contains filtered or unexported fields
}

func (*DataReadRequest) Descriptor deprecated 

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

Deprecated: Use DataReadRequest.ProtoReflect.Descriptor instead.

func (*DataReadRequest) GetFileHandle 

func (x *DataReadRequest) GetFileHandle() int64

func (*DataReadRequest) GetLen 

func (x *DataReadRequest) GetLen() int32

func (*DataReadRequest) GetStart 

func (x *DataReadRequest) GetStart() int64

func (*DataReadRequest) ProtoMessage 

func (*DataReadRequest) ProtoMessage()

func (*DataReadRequest) ProtoReflect 

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

func (*DataReadRequest) Reset 

func (x *DataReadRequest) Reset()

func (*DataReadRequest) String 

func (x *DataReadRequest) String() string

type DataReadResponse 

type DataReadResponse struct {
	Data      []byte     `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Read      int32      `protobuf:"varint,2,opt,name=read,proto3" json:"read,omitempty"`
	Error     string     `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,4,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*DataReadResponse) Descriptor deprecated 

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

Deprecated: Use DataReadResponse.ProtoReflect.Descriptor instead.

func (*DataReadResponse) GetData 

func (x *DataReadResponse) GetData() []byte

func (*DataReadResponse) GetError 

func (x *DataReadResponse) GetError() string

func (*DataReadResponse) GetErrorCode 

func (x *DataReadResponse) GetErrorCode() ErrorCodes

func (*DataReadResponse) GetRead 

func (x *DataReadResponse) GetRead() int32

func (*DataReadResponse) ProtoMessage 

func (*DataReadResponse) ProtoMessage()

func (*DataReadResponse) ProtoReflect 

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

func (*DataReadResponse) Reset 

func (x *DataReadResponse) Reset()

func (*DataReadResponse) String 

func (x *DataReadResponse) String() string

type DataWriteRequest 

type DataWriteRequest struct {
	FileHandle int64  `protobuf:"varint,1,opt,name=fileHandle,proto3" json:"fileHandle,omitempty"`
	Start      int64  `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	Len        int32  `protobuf:"varint,3,opt,name=len,proto3" json:"len,omitempty"`
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DataWriteRequest) Descriptor deprecated 

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

Deprecated: Use DataWriteRequest.ProtoReflect.Descriptor instead.

func (*DataWriteRequest) GetData 

func (x *DataWriteRequest) GetData() []byte

func (*DataWriteRequest) GetFileHandle 

func (x *DataWriteRequest) GetFileHandle() int64

func (*DataWriteRequest) GetLen 

func (x *DataWriteRequest) GetLen() int32

func (*DataWriteRequest) GetStart 

func (x *DataWriteRequest) GetStart() int64

func (*DataWriteRequest) ProtoMessage 

func (*DataWriteRequest) ProtoMessage()

func (*DataWriteRequest) ProtoReflect 

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

func (*DataWriteRequest) Reset 

func (x *DataWriteRequest) Reset()

func (*DataWriteRequest) String 

func (x *DataWriteRequest) String() string

type DataWriteResponse 

type DataWriteResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*DataWriteResponse) Descriptor deprecated 

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

Deprecated: Use DataWriteResponse.ProtoReflect.Descriptor instead.

func (*DataWriteResponse) GetError 

func (x *DataWriteResponse) GetError() string

func (*DataWriteResponse) GetErrorCode 

func (x *DataWriteResponse) GetErrorCode() ErrorCodes

func (*DataWriteResponse) ProtoMessage 

func (*DataWriteResponse) ProtoMessage()

func (*DataWriteResponse) ProtoReflect 

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

func (*DataWriteResponse) Reset 

func (x *DataWriteResponse) Reset()

func (*DataWriteResponse) String 

func (x *DataWriteResponse) String() string

type DeleteCloudVolumeRequest added in v0.1.9 

type DeleteCloudVolumeRequest struct {
	Volumeid int64 `protobuf:"varint,1,opt,name=volumeid,proto3" json:"volumeid,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCloudVolumeRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use DeleteCloudVolumeRequest.ProtoReflect.Descriptor instead.

func (*DeleteCloudVolumeRequest) GetVolumeid added in v0.1.9 

func (x *DeleteCloudVolumeRequest) GetVolumeid() int64

func (*DeleteCloudVolumeRequest) ProtoMessage added in v0.1.9 

func (*DeleteCloudVolumeRequest) ProtoMessage()

func (*DeleteCloudVolumeRequest) ProtoReflect added in v0.1.9 

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

func (*DeleteCloudVolumeRequest) Reset added in v0.1.9 

func (x *DeleteCloudVolumeRequest) Reset()

func (*DeleteCloudVolumeRequest) String added in v0.1.9 

func (x *DeleteCloudVolumeRequest) String() string

type DeleteCloudVolumeResponse added in v0.1.9 

type DeleteCloudVolumeResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCloudVolumeResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use DeleteCloudVolumeResponse.ProtoReflect.Descriptor instead.

func (*DeleteCloudVolumeResponse) GetError added in v0.1.9 

func (x *DeleteCloudVolumeResponse) GetError() string

func (*DeleteCloudVolumeResponse) GetErrorCode added in v0.1.9 

func (x *DeleteCloudVolumeResponse) GetErrorCode() ErrorCodes

func (*DeleteCloudVolumeResponse) GetEventID added in v0.1.9 

func (x *DeleteCloudVolumeResponse) GetEventID() string

func (*DeleteCloudVolumeResponse) ProtoMessage added in v0.1.9 

func (*DeleteCloudVolumeResponse) ProtoMessage()

func (*DeleteCloudVolumeResponse) ProtoReflect added in v0.1.9 

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

func (*DeleteCloudVolumeResponse) Reset added in v0.1.9 

func (x *DeleteCloudVolumeResponse) Reset()

func (*DeleteCloudVolumeResponse) String added in v0.1.9 

func (x *DeleteCloudVolumeResponse) String() string

type ErrorCodes 

type ErrorCodes int32
const (
	ErrorCodes_NOERR     ErrorCodes = 0
	ErrorCodes_ENOENT    ErrorCodes = 2
	ErrorCodes_EIO       ErrorCodes = 5
	ErrorCodes_EAGAIN    ErrorCodes = 11
	ErrorCodes_EEXIST    ErrorCodes = 17
	ErrorCodes_ENOTDIR   ErrorCodes = 20
	ErrorCodes_ENODATA   ErrorCodes = 61
	ErrorCodes_ENAVAIL   ErrorCodes = 119
	ErrorCodes_EPERM     ErrorCodes = 1
	ErrorCodes_ENOSPC    ErrorCodes = 28
	ErrorCodes_EACCES    ErrorCodes = 13
	ErrorCodes_ENOTEMPTY ErrorCodes = 39
	ErrorCodes_ENOSYS    ErrorCodes = 38
	ErrorCodes_ENODEV    ErrorCodes = 19
	ErrorCodes_EBADFD    ErrorCodes = 77
	ErrorCodes_EISDIR    ErrorCodes = 21
)

func (ErrorCodes) Descriptor 

func (ErrorCodes) Descriptor() protoreflect.EnumDescriptor

func (ErrorCodes) Enum 

func (x ErrorCodes) Enum() *ErrorCodes

func (ErrorCodes) EnumDescriptor deprecated 

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

Deprecated: Use ErrorCodes.Descriptor instead.

func (ErrorCodes) Number 

func (x ErrorCodes) Number() protoreflect.EnumNumber

func (ErrorCodes) String 

func (x ErrorCodes) String() string

func (ErrorCodes) Type 

func (ErrorCodes) Type() protoreflect.EnumType

type FileAttributes 

type FileAttributes struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FileAttributes) Descriptor deprecated 

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

Deprecated: Use FileAttributes.ProtoReflect.Descriptor instead.

func (*FileAttributes) GetKey 

func (x *FileAttributes) GetKey() string

func (*FileAttributes) GetValue 

func (x *FileAttributes) GetValue() string

func (*FileAttributes) ProtoMessage 

func (*FileAttributes) ProtoMessage()

func (*FileAttributes) ProtoReflect 

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

func (*FileAttributes) Reset 

func (x *FileAttributes) Reset()

func (*FileAttributes) String 

func (x *FileAttributes) String() string

type FileCloseRequest 

type FileCloseRequest struct {
	FileHandle int64 `protobuf:"varint,1,opt,name=fileHandle,proto3" json:"fileHandle,omitempty"`
	// contains filtered or unexported fields
}

func (*FileCloseRequest) Descriptor deprecated 

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

Deprecated: Use FileCloseRequest.ProtoReflect.Descriptor instead.

func (*FileCloseRequest) GetFileHandle 

func (x *FileCloseRequest) GetFileHandle() int64

func (*FileCloseRequest) ProtoMessage 

func (*FileCloseRequest) ProtoMessage()

func (*FileCloseRequest) ProtoReflect 

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

func (*FileCloseRequest) Reset 

func (x *FileCloseRequest) Reset()

func (*FileCloseRequest) String 

func (x *FileCloseRequest) String() string

type FileCloseResponse 

type FileCloseResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*FileCloseResponse) Descriptor deprecated 

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

Deprecated: Use FileCloseResponse.ProtoReflect.Descriptor instead.

func (*FileCloseResponse) GetError 

func (x *FileCloseResponse) GetError() string

func (*FileCloseResponse) GetErrorCode 

func (x *FileCloseResponse) GetErrorCode() ErrorCodes

func (*FileCloseResponse) ProtoMessage 

func (*FileCloseResponse) ProtoMessage()

func (*FileCloseResponse) ProtoReflect 

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

func (*FileCloseResponse) Reset 

func (x *FileCloseResponse) Reset()

func (*FileCloseResponse) String 

func (x *FileCloseResponse) String() string

type FileExistsRequest 

type FileExistsRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*FileExistsRequest) Descriptor deprecated 

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

Deprecated: Use FileExistsRequest.ProtoReflect.Descriptor instead.

func (*FileExistsRequest) GetPath 

func (x *FileExistsRequest) GetPath() string

func (*FileExistsRequest) ProtoMessage 

func (*FileExistsRequest) ProtoMessage()

func (*FileExistsRequest) ProtoReflect 

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

func (*FileExistsRequest) Reset 

func (x *FileExistsRequest) Reset()

func (*FileExistsRequest) String 

func (x *FileExistsRequest) String() string

type FileExistsResponse 

type FileExistsResponse struct {
	Exists    bool       `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*FileExistsResponse) Descriptor deprecated 

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

Deprecated: Use FileExistsResponse.ProtoReflect.Descriptor instead.

func (*FileExistsResponse) GetError 

func (x *FileExistsResponse) GetError() string

func (*FileExistsResponse) GetErrorCode 

func (x *FileExistsResponse) GetErrorCode() ErrorCodes

func (*FileExistsResponse) GetExists 

func (x *FileExistsResponse) GetExists() bool

func (*FileExistsResponse) ProtoMessage 

func (*FileExistsResponse) ProtoMessage()

func (*FileExistsResponse) ProtoReflect 

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

func (*FileExistsResponse) Reset 

func (x *FileExistsResponse) Reset()

func (*FileExistsResponse) String 

func (x *FileExistsResponse) String() string

type FileIOServiceClient 

type FileIOServiceClient interface {
	// Define a RPC operation
	GetXAttrSize(ctx context.Context, in *GetXAttrSizeRequest, opts ...grpc.CallOption) (*GetXAttrSizeResponse, error)
	Fsync(ctx context.Context, in *FsyncRequest, opts ...grpc.CallOption) (*FsyncResponse, error)
	SetXAttr(ctx context.Context, in *SetXAttrRequest, opts ...grpc.CallOption) (*SetXAttrResponse, error)
	RemoveXAttr(ctx context.Context, in *RemoveXAttrRequest, opts ...grpc.CallOption) (*RemoveXAttrResponse, error)
	GetXAttr(ctx context.Context, in *GetXAttrRequest, opts ...grpc.CallOption) (*GetXAttrResponse, error)
	Utime(ctx context.Context, in *UtimeRequest, opts ...grpc.CallOption) (*UtimeResponse, error)
	Truncate(ctx context.Context, in *TruncateRequest, opts ...grpc.CallOption) (*TruncateResponse, error)
	SymLink(ctx context.Context, in *SymLinkRequest, opts ...grpc.CallOption) (*SymLinkResponse, error)
	ReadLink(ctx context.Context, in *LinkRequest, opts ...grpc.CallOption) (*LinkResponse, error)
	GetAttr(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	Chown(ctx context.Context, in *ChownRequest, opts ...grpc.CallOption) (*ChownResponse, error)
	Chmod(ctx context.Context, in *ChmodRequest, opts ...grpc.CallOption) (*ChmodResponse, error)
	MkDir(ctx context.Context, in *MkDirRequest, opts ...grpc.CallOption) (*MkDirResponse, error)
	RmDir(ctx context.Context, in *RmDirRequest, opts ...grpc.CallOption) (*RmDirResponse, error)
	Unlink(ctx context.Context, in *UnlinkRequest, opts ...grpc.CallOption) (*UnlinkResponse, error)
	Write(ctx context.Context, in *DataWriteRequest, opts ...grpc.CallOption) (*DataWriteResponse, error)
	Read(ctx context.Context, in *DataReadRequest, opts ...grpc.CallOption) (*DataReadResponse, error)
	Release(ctx context.Context, in *FileCloseRequest, opts ...grpc.CallOption) (*FileCloseResponse, error)
	Mknod(ctx context.Context, in *MkNodRequest, opts ...grpc.CallOption) (*MkNodResponse, error)
	Open(ctx context.Context, in *FileOpenRequest, opts ...grpc.CallOption) (*FileOpenResponse, error)
	GetFileInfo(ctx context.Context, in *FileInfoRequest, opts ...grpc.CallOption) (*FileMessageResponse, error)
	CreateCopy(ctx context.Context, in *FileSnapshotRequest, opts ...grpc.CallOption) (*FileSnapshotResponse, error)
	FileExists(ctx context.Context, in *FileExistsRequest, opts ...grpc.CallOption) (*FileExistsResponse, error)
	MkDirAll(ctx context.Context, in *MkDirRequest, opts ...grpc.CallOption) (*MkDirResponse, error)
	Stat(ctx context.Context, in *FileInfoRequest, opts ...grpc.CallOption) (*FileMessageResponse, error)
	Rename(ctx context.Context, in *FileRenameRequest, opts ...grpc.CallOption) (*FileRenameResponse, error)
	CopyExtent(ctx context.Context, in *CopyExtentRequest, opts ...grpc.CallOption) (*CopyExtentResponse, error)
	SetUserMetaData(ctx context.Context, in *SetUserMetaDataRequest, opts ...grpc.CallOption) (*SetUserMetaDataResponse, error)
	GetCloudFile(ctx context.Context, in *GetCloudFileRequest, opts ...grpc.CallOption) (*GetCloudFileResponse, error)
	GetCloudMetaFile(ctx context.Context, in *GetCloudFileRequest, opts ...grpc.CallOption) (*GetCloudFileResponse, error)
	StatFS(ctx context.Context, in *StatFSRequest, opts ...grpc.CallOption) (*StatFSResponse, error)
	FileNotification(ctx context.Context, in *SyncNotificationSubscription, opts ...grpc.CallOption) (FileIOService_FileNotificationClient, error)
}

FileIOServiceClient is the client API for FileIOService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFileIOServiceClient 

func NewFileIOServiceClient(cc grpc.ClientConnInterface) FileIOServiceClient

type FileIOServiceServer 

type FileIOServiceServer interface {
	// Define a RPC operation
	GetXAttrSize(context.Context, *GetXAttrSizeRequest) (*GetXAttrSizeResponse, error)
	Fsync(context.Context, *FsyncRequest) (*FsyncResponse, error)
	SetXAttr(context.Context, *SetXAttrRequest) (*SetXAttrResponse, error)
	RemoveXAttr(context.Context, *RemoveXAttrRequest) (*RemoveXAttrResponse, error)
	GetXAttr(context.Context, *GetXAttrRequest) (*GetXAttrResponse, error)
	Utime(context.Context, *UtimeRequest) (*UtimeResponse, error)
	Truncate(context.Context, *TruncateRequest) (*TruncateResponse, error)
	SymLink(context.Context, *SymLinkRequest) (*SymLinkResponse, error)
	ReadLink(context.Context, *LinkRequest) (*LinkResponse, error)
	GetAttr(context.Context, *StatRequest) (*StatResponse, error)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	Chown(context.Context, *ChownRequest) (*ChownResponse, error)
	Chmod(context.Context, *ChmodRequest) (*ChmodResponse, error)
	MkDir(context.Context, *MkDirRequest) (*MkDirResponse, error)
	RmDir(context.Context, *RmDirRequest) (*RmDirResponse, error)
	Unlink(context.Context, *UnlinkRequest) (*UnlinkResponse, error)
	Write(context.Context, *DataWriteRequest) (*DataWriteResponse, error)
	Read(context.Context, *DataReadRequest) (*DataReadResponse, error)
	Release(context.Context, *FileCloseRequest) (*FileCloseResponse, error)
	Mknod(context.Context, *MkNodRequest) (*MkNodResponse, error)
	Open(context.Context, *FileOpenRequest) (*FileOpenResponse, error)
	GetFileInfo(context.Context, *FileInfoRequest) (*FileMessageResponse, error)
	CreateCopy(context.Context, *FileSnapshotRequest) (*FileSnapshotResponse, error)
	FileExists(context.Context, *FileExistsRequest) (*FileExistsResponse, error)
	MkDirAll(context.Context, *MkDirRequest) (*MkDirResponse, error)
	Stat(context.Context, *FileInfoRequest) (*FileMessageResponse, error)
	Rename(context.Context, *FileRenameRequest) (*FileRenameResponse, error)
	CopyExtent(context.Context, *CopyExtentRequest) (*CopyExtentResponse, error)
	SetUserMetaData(context.Context, *SetUserMetaDataRequest) (*SetUserMetaDataResponse, error)
	GetCloudFile(context.Context, *GetCloudFileRequest) (*GetCloudFileResponse, error)
	GetCloudMetaFile(context.Context, *GetCloudFileRequest) (*GetCloudFileResponse, error)
	StatFS(context.Context, *StatFSRequest) (*StatFSResponse, error)
	FileNotification(*SyncNotificationSubscription, FileIOService_FileNotificationServer) error
	// contains filtered or unexported methods
}

FileIOServiceServer is the server API for FileIOService service. All implementations must embed UnimplementedFileIOServiceServer for forward compatibility

type FileIOService_FileNotificationClient added in v0.1.31 

type FileIOService_FileNotificationClient interface {
	Recv() (*FileMessageResponse, error)
	grpc.ClientStream
}

type FileIOService_FileNotificationServer added in v0.1.31 

type FileIOService_FileNotificationServer interface {
	Send(*FileMessageResponse) error
	grpc.ServerStream
}

type FileInfoRequest 

type FileInfoRequest struct {
	FileName      string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	Compact       bool   `protobuf:"varint,2,opt,name=compact,proto3" json:"compact,omitempty"`
	NumberOfFiles int32  `protobuf:"varint,3,opt,name=numberOfFiles,proto3" json:"numberOfFiles,omitempty"`
	ListGuid      string `protobuf:"bytes,4,opt,name=listGuid,proto3" json:"listGuid,omitempty"`
	// contains filtered or unexported fields
}

Request payload

func (*FileInfoRequest) Descriptor deprecated 

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

Deprecated: Use FileInfoRequest.ProtoReflect.Descriptor instead.

func (*FileInfoRequest) GetCompact 

func (x *FileInfoRequest) GetCompact() bool

func (*FileInfoRequest) GetFileName 

func (x *FileInfoRequest) GetFileName() string

func (*FileInfoRequest) GetListGuid 

func (x *FileInfoRequest) GetListGuid() string

func (*FileInfoRequest) GetNumberOfFiles 

func (x *FileInfoRequest) GetNumberOfFiles() int32

func (*FileInfoRequest) ProtoMessage 

func (*FileInfoRequest) ProtoMessage()

func (*FileInfoRequest) ProtoReflect 

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

func (*FileInfoRequest) Reset 

func (x *FileInfoRequest) Reset()

func (*FileInfoRequest) String 

func (x *FileInfoRequest) String() string

type FileInfoResponse 

type FileInfoResponse struct {
	FileName       string                   `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	FilePath       string                   `protobuf:"bytes,2,opt,name=filePath,proto3" json:"filePath,omitempty"`
	Type           FileInfoResponseFileType `protobuf:"varint,3,opt,name=type,proto3,enum=org.opendedup.grpc.FileInfoResponseFileType" json:"type,omitempty"`
	SdfsPath       string                   `protobuf:"bytes,4,opt,name=sdfsPath,proto3" json:"sdfsPath,omitempty"`
	Atime          int64                    `protobuf:"varint,5,opt,name=atime,proto3" json:"atime,omitempty"`
	Mtime          int64                    `protobuf:"varint,6,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Ctime          int64                    `protobuf:"varint,7,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Hidden         bool                     `protobuf:"varint,8,opt,name=hidden,proto3" json:"hidden,omitempty"`
	Size           int64                    `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	Open           bool                     `protobuf:"varint,10,opt,name=open,proto3" json:"open,omitempty"`
	FileGuild      string                   `protobuf:"bytes,11,opt,name=fileGuild,proto3" json:"fileGuild,omitempty"`
	MapGuid        string                   `protobuf:"bytes,12,opt,name=mapGuid,proto3" json:"mapGuid,omitempty"`
	LocalOwner     bool                     `protobuf:"varint,13,opt,name=localOwner,proto3" json:"localOwner,omitempty"`
	Execute        bool                     `protobuf:"varint,14,opt,name=execute,proto3" json:"execute,omitempty"`
	Read           bool                     `protobuf:"varint,15,opt,name=read,proto3" json:"read,omitempty"`
	Write          bool                     `protobuf:"varint,16,opt,name=write,proto3" json:"write,omitempty"`
	Importing      bool                     `protobuf:"varint,17,opt,name=importing,proto3" json:"importing,omitempty"`
	Symlink        bool                     `protobuf:"varint,18,opt,name=symlink,proto3" json:"symlink,omitempty"`
	FileAttributes []*FileAttributes        `protobuf:"bytes,19,rep,name=fileAttributes,proto3" json:"fileAttributes,omitempty"`
	Id             string                   `protobuf:"bytes,20,opt,name=id,proto3" json:"id,omitempty"`
	Files          []*FileInfoResponse      `protobuf:"bytes,21,rep,name=files,proto3" json:"files,omitempty"`
	ParentPath     string                   `protobuf:"bytes,22,opt,name=parentPath,proto3" json:"parentPath,omitempty"`
	Volumeid       string                   `protobuf:"bytes,23,opt,name=volumeid,proto3" json:"volumeid,omitempty"`
	IoMonitor      *IOMonitorResponse       `protobuf:"bytes,24,opt,name=ioMonitor,proto3" json:"ioMonitor,omitempty"`
	SymlinkPath    string                   `protobuf:"bytes,25,opt,name=symlinkPath,proto3" json:"symlinkPath,omitempty"`
	GroupId        int64                    `protobuf:"varint,26,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	UserId         int64                    `protobuf:"varint,27,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Permissions    int32                    `protobuf:"varint,28,opt,name=permissions,proto3" json:"permissions,omitempty"`
	Hashcode       int64                    `protobuf:"varint,29,opt,name=hashcode,proto3" json:"hashcode,omitempty"`
	RetentionLock  int64                    `protobuf:"varint,30,opt,name=retentionLock,proto3" json:"retentionLock,omitempty"`
	Attributes     int64                    `protobuf:"varint,31,opt,name=attributes,proto3" json:"attributes,omitempty"`
	Version        string                   `protobuf:"bytes,32,opt,name=version,proto3" json:"version,omitempty"`
	Mode           int32                    `protobuf:"varint,33,opt,name=mode,proto3" json:"mode,omitempty"`
	DeleteOnClose  bool                     `protobuf:"varint,34,opt,name=delete_on_close,json=deleteOnClose,proto3" json:"delete_on_close,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfoResponse) Descriptor deprecated 

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

Deprecated: Use FileInfoResponse.ProtoReflect.Descriptor instead.

func (*FileInfoResponse) GetAtime 

func (x *FileInfoResponse) GetAtime() int64

func (*FileInfoResponse) GetAttributes added in v0.1.31 

func (x *FileInfoResponse) GetAttributes() int64

func (*FileInfoResponse) GetCtime 

func (x *FileInfoResponse) GetCtime() int64

func (*FileInfoResponse) GetDeleteOnClose added in v0.1.31 

func (x *FileInfoResponse) GetDeleteOnClose() bool

func (*FileInfoResponse) GetExecute 

func (x *FileInfoResponse) GetExecute() bool

func (*FileInfoResponse) GetFileAttributes 

func (x *FileInfoResponse) GetFileAttributes() []*FileAttributes

func (*FileInfoResponse) GetFileGuild 

func (x *FileInfoResponse) GetFileGuild() string

func (*FileInfoResponse) GetFileName 

func (x *FileInfoResponse) GetFileName() string

func (*FileInfoResponse) GetFilePath 

func (x *FileInfoResponse) GetFilePath() string

func (*FileInfoResponse) GetFiles 

func (x *FileInfoResponse) GetFiles() []*FileInfoResponse

func (*FileInfoResponse) GetGroupId 

func (x *FileInfoResponse) GetGroupId() int64

func (*FileInfoResponse) GetHashcode added in v0.1.9 

func (x *FileInfoResponse) GetHashcode() int64

func (*FileInfoResponse) GetHidden 

func (x *FileInfoResponse) GetHidden() bool

func (*FileInfoResponse) GetId 

func (x *FileInfoResponse) GetId() string

func (*FileInfoResponse) GetImporting 

func (x *FileInfoResponse) GetImporting() bool

func (*FileInfoResponse) GetIoMonitor 

func (x *FileInfoResponse) GetIoMonitor() *IOMonitorResponse

func (*FileInfoResponse) GetLocalOwner 

func (x *FileInfoResponse) GetLocalOwner() bool

func (*FileInfoResponse) GetMapGuid 

func (x *FileInfoResponse) GetMapGuid() string

func (*FileInfoResponse) GetMode added in v0.1.31 

func (x *FileInfoResponse) GetMode() int32

func (*FileInfoResponse) GetMtime 

func (x *FileInfoResponse) GetMtime() int64

func (*FileInfoResponse) GetOpen 

func (x *FileInfoResponse) GetOpen() bool

func (*FileInfoResponse) GetParentPath 

func (x *FileInfoResponse) GetParentPath() string

func (*FileInfoResponse) GetPermissions 

func (x *FileInfoResponse) GetPermissions() int32

func (*FileInfoResponse) GetRead 

func (x *FileInfoResponse) GetRead() bool

func (*FileInfoResponse) GetRetentionLock added in v0.1.31 

func (x *FileInfoResponse) GetRetentionLock() int64

func (*FileInfoResponse) GetSdfsPath 

func (x *FileInfoResponse) GetSdfsPath() string

func (*FileInfoResponse) GetSize 

func (x *FileInfoResponse) GetSize() int64
func (x *FileInfoResponse) GetSymlink() bool

func (*FileInfoResponse) GetSymlinkPath 

func (x *FileInfoResponse) GetSymlinkPath() string

func (*FileInfoResponse) GetType 

func (x *FileInfoResponse) GetType() FileInfoResponseFileType

func (*FileInfoResponse) GetUserId 

func (x *FileInfoResponse) GetUserId() int64

func (*FileInfoResponse) GetVersion added in v0.1.31 

func (x *FileInfoResponse) GetVersion() string

func (*FileInfoResponse) GetVolumeid 

func (x *FileInfoResponse) GetVolumeid() string

func (*FileInfoResponse) GetWrite 

func (x *FileInfoResponse) GetWrite() bool

func (*FileInfoResponse) ProtoMessage 

func (*FileInfoResponse) ProtoMessage()

func (*FileInfoResponse) ProtoReflect 

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

func (*FileInfoResponse) Reset 

func (x *FileInfoResponse) Reset()

func (*FileInfoResponse) String 

func (x *FileInfoResponse) String() string

type FileInfoResponseFileType 

type FileInfoResponseFileType int32
const (
	FileInfoResponse_FILE FileInfoResponseFileType = 0
	FileInfoResponse_DIR  FileInfoResponseFileType = 1
)

func (FileInfoResponseFileType) Descriptor 

func (FileInfoResponseFileType) Descriptor() protoreflect.EnumDescriptor

func (FileInfoResponseFileType) Enum 

func (x FileInfoResponseFileType) Enum() *FileInfoResponseFileType

func (FileInfoResponseFileType) EnumDescriptor deprecated 

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

Deprecated: Use FileInfoResponseFileType.Descriptor instead.

func (FileInfoResponseFileType) Number 

func (x FileInfoResponseFileType) Number() protoreflect.EnumNumber

func (FileInfoResponseFileType) String 

func (x FileInfoResponseFileType) String() string

func (FileInfoResponseFileType) Type 

func (FileInfoResponseFileType) Type() protoreflect.EnumType

type FileMessageResponse 

type FileMessageResponse struct {
	Error            string              `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ListGuid         string              `protobuf:"bytes,2,opt,name=listGuid,proto3" json:"listGuid,omitempty"`
	Response         []*FileInfoResponse `protobuf:"bytes,3,rep,name=response,proto3" json:"response,omitempty"`
	ErrorCode        ErrorCodes          `protobuf:"varint,4,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	MaxNumberOfFiles int32               `protobuf:"varint,5,opt,name=maxNumberOfFiles,proto3" json:"maxNumberOfFiles,omitempty"`
	Action           Syncaction          `protobuf:"varint,6,opt,name=action,proto3,enum=org.opendedup.grpc.Syncaction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*FileMessageResponse) Descriptor deprecated 

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

Deprecated: Use FileMessageResponse.ProtoReflect.Descriptor instead.

func (*FileMessageResponse) GetAction added in v0.1.31 

func (x *FileMessageResponse) GetAction() Syncaction

func (*FileMessageResponse) GetError 

func (x *FileMessageResponse) GetError() string

func (*FileMessageResponse) GetErrorCode 

func (x *FileMessageResponse) GetErrorCode() ErrorCodes

func (*FileMessageResponse) GetListGuid 

func (x *FileMessageResponse) GetListGuid() string

func (*FileMessageResponse) GetMaxNumberOfFiles 

func (x *FileMessageResponse) GetMaxNumberOfFiles() int32

func (*FileMessageResponse) GetResponse 

func (x *FileMessageResponse) GetResponse() []*FileInfoResponse

func (*FileMessageResponse) ProtoMessage 

func (*FileMessageResponse) ProtoMessage()

func (*FileMessageResponse) ProtoReflect 

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

func (*FileMessageResponse) Reset 

func (x *FileMessageResponse) Reset()

func (*FileMessageResponse) String 

func (x *FileMessageResponse) String() string

type FileOpenRequest 

type FileOpenRequest struct {
	Path  string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Flags int32  `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*FileOpenRequest) Descriptor deprecated 

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

Deprecated: Use FileOpenRequest.ProtoReflect.Descriptor instead.

func (*FileOpenRequest) GetFlags added in v0.1.20 

func (x *FileOpenRequest) GetFlags() int32

func (*FileOpenRequest) GetPath 

func (x *FileOpenRequest) GetPath() string

func (*FileOpenRequest) ProtoMessage 

func (*FileOpenRequest) ProtoMessage()

func (*FileOpenRequest) ProtoReflect 

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

func (*FileOpenRequest) Reset 

func (x *FileOpenRequest) Reset()

func (*FileOpenRequest) String 

func (x *FileOpenRequest) String() string

type FileOpenResponse 

type FileOpenResponse struct {
	FileHandle int64      `protobuf:"varint,1,opt,name=fileHandle,proto3" json:"fileHandle,omitempty"`
	Error      string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode  ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*FileOpenResponse) Descriptor deprecated 

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

Deprecated: Use FileOpenResponse.ProtoReflect.Descriptor instead.

func (*FileOpenResponse) GetError 

func (x *FileOpenResponse) GetError() string

func (*FileOpenResponse) GetErrorCode 

func (x *FileOpenResponse) GetErrorCode() ErrorCodes

func (*FileOpenResponse) GetFileHandle 

func (x *FileOpenResponse) GetFileHandle() int64

func (*FileOpenResponse) ProtoMessage 

func (*FileOpenResponse) ProtoMessage()

func (*FileOpenResponse) ProtoReflect 

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

func (*FileOpenResponse) Reset 

func (x *FileOpenResponse) Reset()

func (*FileOpenResponse) String 

func (x *FileOpenResponse) String() string

type FileRenameRequest 

type FileRenameRequest struct {
	Src  string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dest string `protobuf:"bytes,2,opt,name=dest,proto3" json:"dest,omitempty"`
	// contains filtered or unexported fields
}

func (*FileRenameRequest) Descriptor deprecated 

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

Deprecated: Use FileRenameRequest.ProtoReflect.Descriptor instead.

func (*FileRenameRequest) GetDest 

func (x *FileRenameRequest) GetDest() string

func (*FileRenameRequest) GetSrc 

func (x *FileRenameRequest) GetSrc() string

func (*FileRenameRequest) ProtoMessage 

func (*FileRenameRequest) ProtoMessage()

func (*FileRenameRequest) ProtoReflect 

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

func (*FileRenameRequest) Reset 

func (x *FileRenameRequest) Reset()

func (*FileRenameRequest) String 

func (x *FileRenameRequest) String() string

type FileRenameResponse 

type FileRenameResponse struct {
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*FileRenameResponse) Descriptor deprecated 

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

Deprecated: Use FileRenameResponse.ProtoReflect.Descriptor instead.

func (*FileRenameResponse) GetError 

func (x *FileRenameResponse) GetError() string

func (*FileRenameResponse) GetErrorCode 

func (x *FileRenameResponse) GetErrorCode() ErrorCodes

func (*FileRenameResponse) ProtoMessage 

func (*FileRenameResponse) ProtoMessage()

func (*FileRenameResponse) ProtoReflect 

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

func (*FileRenameResponse) Reset 

func (x *FileRenameResponse) Reset()

func (*FileRenameResponse) String 

func (x *FileRenameResponse) String() string

type FileSnapshotRequest 

type FileSnapshotRequest struct {
	Src  string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dest string `protobuf:"bytes,2,opt,name=dest,proto3" json:"dest,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use FileSnapshotRequest.ProtoReflect.Descriptor instead.

func (*FileSnapshotRequest) GetDest 

func (x *FileSnapshotRequest) GetDest() string

func (*FileSnapshotRequest) GetSrc 

func (x *FileSnapshotRequest) GetSrc() string

func (*FileSnapshotRequest) ProtoMessage 

func (*FileSnapshotRequest) ProtoMessage()

func (*FileSnapshotRequest) ProtoReflect 

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

func (*FileSnapshotRequest) Reset 

func (x *FileSnapshotRequest) Reset()

func (*FileSnapshotRequest) String 

func (x *FileSnapshotRequest) String() string

type FileSnapshotResponse 

type FileSnapshotResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	EventID   string     `protobuf:"bytes,3,opt,name=eventID,proto3" json:"eventID,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use FileSnapshotResponse.ProtoReflect.Descriptor instead.

func (*FileSnapshotResponse) GetError 

func (x *FileSnapshotResponse) GetError() string

func (*FileSnapshotResponse) GetErrorCode 

func (x *FileSnapshotResponse) GetErrorCode() ErrorCodes

func (*FileSnapshotResponse) GetEventID added in v0.1.9 

func (x *FileSnapshotResponse) GetEventID() string

func (*FileSnapshotResponse) ProtoMessage 

func (*FileSnapshotResponse) ProtoMessage()

func (*FileSnapshotResponse) ProtoReflect 

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

func (*FileSnapshotResponse) Reset 

func (x *FileSnapshotResponse) Reset()

func (*FileSnapshotResponse) String 

func (x *FileSnapshotResponse) String() string

type FlushRequest added in v0.1.9 

type FlushRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Fd   int64  `protobuf:"varint,2,opt,name=fd,proto3" json:"fd,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.

func (*FlushRequest) GetFd added in v0.1.9 

func (x *FlushRequest) GetFd() int64

func (*FlushRequest) GetPath added in v0.1.9 

func (x *FlushRequest) GetPath() string

func (*FlushRequest) ProtoMessage added in v0.1.9 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) ProtoReflect added in v0.1.9 

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

func (*FlushRequest) Reset added in v0.1.9 

func (x *FlushRequest) Reset()

func (*FlushRequest) String added in v0.1.9 

func (x *FlushRequest) String() string

type FlushResponse added in v0.1.9 

type FlushResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) GetError added in v0.1.9 

func (x *FlushResponse) GetError() string

func (*FlushResponse) GetErrorCode added in v0.1.9 

func (x *FlushResponse) GetErrorCode() ErrorCodes

func (*FlushResponse) ProtoMessage added in v0.1.9 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect added in v0.1.9 

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

func (*FlushResponse) Reset added in v0.1.9 

func (x *FlushResponse) Reset()

func (*FlushResponse) String added in v0.1.9 

func (x *FlushResponse) String() string

type FsyncRequest added in v0.1.9 

type FsyncRequest struct {
	Path     string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Fh       int64  `protobuf:"varint,2,opt,name=fh,proto3" json:"fh,omitempty"`
	Datasync bool   `protobuf:"varint,3,opt,name=datasync,proto3" json:"datasync,omitempty"`
	// contains filtered or unexported fields
}

func (*FsyncRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use FsyncRequest.ProtoReflect.Descriptor instead.

func (*FsyncRequest) GetDatasync added in v0.1.9 

func (x *FsyncRequest) GetDatasync() bool

func (*FsyncRequest) GetFh added in v0.1.9 

func (x *FsyncRequest) GetFh() int64

func (*FsyncRequest) GetPath added in v0.1.9 

func (x *FsyncRequest) GetPath() string

func (*FsyncRequest) ProtoMessage added in v0.1.9 

func (*FsyncRequest) ProtoMessage()

func (*FsyncRequest) ProtoReflect added in v0.1.9 

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

func (*FsyncRequest) Reset added in v0.1.9 

func (x *FsyncRequest) Reset()

func (*FsyncRequest) String added in v0.1.9 

func (x *FsyncRequest) String() string

type FsyncResponse added in v0.1.9 

type FsyncResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*FsyncResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use FsyncResponse.ProtoReflect.Descriptor instead.

func (*FsyncResponse) GetError added in v0.1.9 

func (x *FsyncResponse) GetError() string

func (*FsyncResponse) GetErrorCode added in v0.1.9 

func (x *FsyncResponse) GetErrorCode() ErrorCodes

func (*FsyncResponse) ProtoMessage added in v0.1.9 

func (*FsyncResponse) ProtoMessage()

func (*FsyncResponse) ProtoReflect added in v0.1.9 

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

func (*FsyncResponse) Reset added in v0.1.9 

func (x *FsyncResponse) Reset()

func (*FsyncResponse) String added in v0.1.9 

func (x *FsyncResponse) String() string

type GCScheduleRequest added in v0.1.9 

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

func (*GCScheduleRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GCScheduleRequest.ProtoReflect.Descriptor instead.

func (*GCScheduleRequest) ProtoMessage added in v0.1.9 

func (*GCScheduleRequest) ProtoMessage()

func (*GCScheduleRequest) ProtoReflect added in v0.1.9 

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

func (*GCScheduleRequest) Reset added in v0.1.9 

func (x *GCScheduleRequest) Reset()

func (*GCScheduleRequest) String added in v0.1.9 

func (x *GCScheduleRequest) String() string

type GCScheduleResponse added in v0.1.9 

type GCScheduleResponse struct {
	Schedule  string     `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*GCScheduleResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GCScheduleResponse.ProtoReflect.Descriptor instead.

func (*GCScheduleResponse) GetError added in v0.1.9 

func (x *GCScheduleResponse) GetError() string

func (*GCScheduleResponse) GetErrorCode added in v0.1.9 

func (x *GCScheduleResponse) GetErrorCode() ErrorCodes

func (*GCScheduleResponse) GetSchedule added in v0.1.9 

func (x *GCScheduleResponse) GetSchedule() string

func (*GCScheduleResponse) ProtoMessage added in v0.1.9 

func (*GCScheduleResponse) ProtoMessage()

func (*GCScheduleResponse) ProtoReflect added in v0.1.9 

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

func (*GCScheduleResponse) Reset added in v0.1.9 

func (x *GCScheduleResponse) Reset()

func (*GCScheduleResponse) String added in v0.1.9 

func (x *GCScheduleResponse) String() string

type GetCloudFileRequest added in v0.1.9 

type GetCloudFileRequest struct {
	File      string `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Dstfile   string `protobuf:"bytes,2,opt,name=dstfile,proto3" json:"dstfile,omitempty"`
	Overwrite bool   `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	Changeid  string `protobuf:"bytes,4,opt,name=changeid,proto3" json:"changeid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCloudFileRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GetCloudFileRequest.ProtoReflect.Descriptor instead.

func (*GetCloudFileRequest) GetChangeid added in v0.1.9 

func (x *GetCloudFileRequest) GetChangeid() string

func (*GetCloudFileRequest) GetDstfile added in v0.1.9 

func (x *GetCloudFileRequest) GetDstfile() string

func (*GetCloudFileRequest) GetFile added in v0.1.9 

func (x *GetCloudFileRequest) GetFile() string

func (*GetCloudFileRequest) GetOverwrite added in v0.1.9 

func (x *GetCloudFileRequest) GetOverwrite() bool

func (*GetCloudFileRequest) ProtoMessage added in v0.1.9 

func (*GetCloudFileRequest) ProtoMessage()

func (*GetCloudFileRequest) ProtoReflect added in v0.1.9 

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

func (*GetCloudFileRequest) Reset added in v0.1.9 

func (x *GetCloudFileRequest) Reset()

func (*GetCloudFileRequest) String added in v0.1.9 

func (x *GetCloudFileRequest) String() string

type GetCloudFileResponse added in v0.1.9 

type GetCloudFileResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCloudFileResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GetCloudFileResponse.ProtoReflect.Descriptor instead.

func (*GetCloudFileResponse) GetError added in v0.1.9 

func (x *GetCloudFileResponse) GetError() string

func (*GetCloudFileResponse) GetErrorCode added in v0.1.9 

func (x *GetCloudFileResponse) GetErrorCode() ErrorCodes

func (*GetCloudFileResponse) GetEventID added in v0.1.9 

func (x *GetCloudFileResponse) GetEventID() string

func (*GetCloudFileResponse) ProtoMessage added in v0.1.9 

func (*GetCloudFileResponse) ProtoMessage()

func (*GetCloudFileResponse) ProtoReflect added in v0.1.9 

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

func (*GetCloudFileResponse) Reset added in v0.1.9 

func (x *GetCloudFileResponse) Reset()

func (*GetCloudFileResponse) String added in v0.1.9 

func (x *GetCloudFileResponse) String() string

type GetXAttrRequest added in v0.1.9 

type GetXAttrRequest struct {
	Attr string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXAttrRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GetXAttrRequest.ProtoReflect.Descriptor instead.

func (*GetXAttrRequest) GetAttr added in v0.1.9 

func (x *GetXAttrRequest) GetAttr() string

func (*GetXAttrRequest) GetPath added in v0.1.9 

func (x *GetXAttrRequest) GetPath() string

func (*GetXAttrRequest) ProtoMessage added in v0.1.9 

func (*GetXAttrRequest) ProtoMessage()

func (*GetXAttrRequest) ProtoReflect added in v0.1.9 

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

func (*GetXAttrRequest) Reset added in v0.1.9 

func (x *GetXAttrRequest) Reset()

func (*GetXAttrRequest) String added in v0.1.9 

func (x *GetXAttrRequest) String() string

type GetXAttrResponse added in v0.1.9 

type GetXAttrResponse struct {
	Value     string     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXAttrResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GetXAttrResponse.ProtoReflect.Descriptor instead.

func (*GetXAttrResponse) GetError added in v0.1.9 

func (x *GetXAttrResponse) GetError() string

func (*GetXAttrResponse) GetErrorCode added in v0.1.9 

func (x *GetXAttrResponse) GetErrorCode() ErrorCodes

func (*GetXAttrResponse) GetValue added in v0.1.9 

func (x *GetXAttrResponse) GetValue() string

func (*GetXAttrResponse) ProtoMessage added in v0.1.9 

func (*GetXAttrResponse) ProtoMessage()

func (*GetXAttrResponse) ProtoReflect added in v0.1.9 

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

func (*GetXAttrResponse) Reset added in v0.1.9 

func (x *GetXAttrResponse) Reset()

func (*GetXAttrResponse) String added in v0.1.9 

func (x *GetXAttrResponse) String() string

type GetXAttrSizeRequest added in v0.1.9 

type GetXAttrSizeRequest struct {
	Attr string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXAttrSizeRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GetXAttrSizeRequest.ProtoReflect.Descriptor instead.

func (*GetXAttrSizeRequest) GetAttr added in v0.1.9 

func (x *GetXAttrSizeRequest) GetAttr() string

func (*GetXAttrSizeRequest) GetPath added in v0.1.9 

func (x *GetXAttrSizeRequest) GetPath() string

func (*GetXAttrSizeRequest) ProtoMessage added in v0.1.9 

func (*GetXAttrSizeRequest) ProtoMessage()

func (*GetXAttrSizeRequest) ProtoReflect added in v0.1.9 

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

func (*GetXAttrSizeRequest) Reset added in v0.1.9 

func (x *GetXAttrSizeRequest) Reset()

func (*GetXAttrSizeRequest) String added in v0.1.9 

func (x *GetXAttrSizeRequest) String() string

type GetXAttrSizeResponse added in v0.1.9 

type GetXAttrSizeResponse struct {
	Length    int32      `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXAttrSizeResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use GetXAttrSizeResponse.ProtoReflect.Descriptor instead.

func (*GetXAttrSizeResponse) GetError added in v0.1.9 

func (x *GetXAttrSizeResponse) GetError() string

func (*GetXAttrSizeResponse) GetErrorCode added in v0.1.9 

func (x *GetXAttrSizeResponse) GetErrorCode() ErrorCodes

func (*GetXAttrSizeResponse) GetLength added in v0.1.9 

func (x *GetXAttrSizeResponse) GetLength() int32

func (*GetXAttrSizeResponse) ProtoMessage added in v0.1.9 

func (*GetXAttrSizeResponse) ProtoMessage()

func (*GetXAttrSizeResponse) ProtoReflect added in v0.1.9 

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

func (*GetXAttrSizeResponse) Reset added in v0.1.9 

func (x *GetXAttrSizeResponse) Reset()

func (*GetXAttrSizeResponse) String added in v0.1.9 

func (x *GetXAttrSizeResponse) String() string

type IOMonitorResponse 

type IOMonitorResponse struct {
	VirtualBytesWritten int64  `protobuf:"varint,1,opt,name=virtualBytesWritten,proto3" json:"virtualBytesWritten,omitempty"`
	ActualBytesWritten  int64  `protobuf:"varint,2,opt,name=actualBytesWritten,proto3" json:"actualBytesWritten,omitempty"`
	BytesRead           int64  `protobuf:"varint,3,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"`
	DuplicateBlocks     int64  `protobuf:"varint,4,opt,name=duplicateBlocks,proto3" json:"duplicateBlocks,omitempty"`
	WriteOpts           int64  `protobuf:"varint,5,opt,name=writeOpts,proto3" json:"writeOpts,omitempty"`
	ReadOpts            int64  `protobuf:"varint,6,opt,name=readOpts,proto3" json:"readOpts,omitempty"`
	MaxReadOps          int64  `protobuf:"varint,7,opt,name=maxReadOps,proto3" json:"maxReadOps,omitempty"`
	MaxWriteOps         int64  `protobuf:"varint,8,opt,name=maxWriteOps,proto3" json:"maxWriteOps,omitempty"`
	MaxIops             int64  `protobuf:"varint,9,opt,name=maxIops,proto3" json:"maxIops,omitempty"`
	MaxReadMbps         int64  `protobuf:"varint,10,opt,name=maxReadMbps,proto3" json:"maxReadMbps,omitempty"`
	MaxWriteMbps        int64  `protobuf:"varint,11,opt,name=maxWriteMbps,proto3" json:"maxWriteMbps,omitempty"`
	MaxMbps             int64  `protobuf:"varint,12,opt,name=maxMbps,proto3" json:"maxMbps,omitempty"`
	IoQos               int32  `protobuf:"varint,13,opt,name=ioQos,proto3" json:"ioQos,omitempty"`
	IoProfile           string `protobuf:"bytes,14,opt,name=ioProfile,proto3" json:"ioProfile,omitempty"`
	MaxRbps             int64  `protobuf:"varint,15,opt,name=maxRbps,proto3" json:"maxRbps,omitempty"`
	MaxWbps             int64  `protobuf:"varint,16,opt,name=maxWbps,proto3" json:"maxWbps,omitempty"`
	MaxBps              int64  `protobuf:"varint,17,opt,name=maxBps,proto3" json:"maxBps,omitempty"`
	// contains filtered or unexported fields
}

func (*IOMonitorResponse) Descriptor deprecated 

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

Deprecated: Use IOMonitorResponse.ProtoReflect.Descriptor instead.

func (*IOMonitorResponse) GetActualBytesWritten 

func (x *IOMonitorResponse) GetActualBytesWritten() int64

func (*IOMonitorResponse) GetBytesRead 

func (x *IOMonitorResponse) GetBytesRead() int64

func (*IOMonitorResponse) GetDuplicateBlocks 

func (x *IOMonitorResponse) GetDuplicateBlocks() int64

func (*IOMonitorResponse) GetIoProfile 

func (x *IOMonitorResponse) GetIoProfile() string

func (*IOMonitorResponse) GetIoQos 

func (x *IOMonitorResponse) GetIoQos() int32

func (*IOMonitorResponse) GetMaxBps added in v0.1.31 

func (x *IOMonitorResponse) GetMaxBps() int64

func (*IOMonitorResponse) GetMaxIops 

func (x *IOMonitorResponse) GetMaxIops() int64

func (*IOMonitorResponse) GetMaxMbps 

func (x *IOMonitorResponse) GetMaxMbps() int64

func (*IOMonitorResponse) GetMaxRbps added in v0.1.31 

func (x *IOMonitorResponse) GetMaxRbps() int64

func (*IOMonitorResponse) GetMaxReadMbps 

func (x *IOMonitorResponse) GetMaxReadMbps() int64

func (*IOMonitorResponse) GetMaxReadOps 

func (x *IOMonitorResponse) GetMaxReadOps() int64

func (*IOMonitorResponse) GetMaxWbps added in v0.1.31 

func (x *IOMonitorResponse) GetMaxWbps() int64

func (*IOMonitorResponse) GetMaxWriteMbps 

func (x *IOMonitorResponse) GetMaxWriteMbps() int64

func (*IOMonitorResponse) GetMaxWriteOps 

func (x *IOMonitorResponse) GetMaxWriteOps() int64

func (*IOMonitorResponse) GetReadOpts 

func (x *IOMonitorResponse) GetReadOpts() int64

func (*IOMonitorResponse) GetVirtualBytesWritten 

func (x *IOMonitorResponse) GetVirtualBytesWritten() int64

func (*IOMonitorResponse) GetWriteOpts 

func (x *IOMonitorResponse) GetWriteOpts() int64

func (*IOMonitorResponse) ProtoMessage 

func (*IOMonitorResponse) ProtoMessage()

func (*IOMonitorResponse) ProtoReflect 

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

func (*IOMonitorResponse) Reset 

func (x *IOMonitorResponse) Reset()

func (*IOMonitorResponse) String 

func (x *IOMonitorResponse) String() string

type LinkRequest added in v0.1.9 

type LinkRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use LinkRequest.ProtoReflect.Descriptor instead.

func (*LinkRequest) GetPath added in v0.1.9 

func (x *LinkRequest) GetPath() string

func (*LinkRequest) ProtoMessage added in v0.1.9 

func (*LinkRequest) ProtoMessage()

func (*LinkRequest) ProtoReflect added in v0.1.9 

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

func (*LinkRequest) Reset added in v0.1.9 

func (x *LinkRequest) Reset()

func (*LinkRequest) String added in v0.1.9 

func (x *LinkRequest) String() string

type LinkResponse added in v0.1.9 

type LinkResponse struct {
	LinkPath  string     `protobuf:"bytes,1,opt,name=linkPath,proto3" json:"linkPath,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use LinkResponse.ProtoReflect.Descriptor instead.

func (*LinkResponse) GetError added in v0.1.9 

func (x *LinkResponse) GetError() string

func (*LinkResponse) GetErrorCode added in v0.1.9 

func (x *LinkResponse) GetErrorCode() ErrorCodes

func (*LinkResponse) GetLinkPath added in v0.1.9 

func (x *LinkResponse) GetLinkPath() string

func (*LinkResponse) ProtoMessage added in v0.1.9 

func (*LinkResponse) ProtoMessage()

func (*LinkResponse) ProtoReflect added in v0.1.9 

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

func (*LinkResponse) Reset added in v0.1.9 

func (x *LinkResponse) Reset()

func (*LinkResponse) String added in v0.1.9 

func (x *LinkResponse) String() string

type MessageQueueInfoResponse 

type MessageQueueInfoResponse struct {
	HostName string                          `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
	MqType   MessageQueueInfoResponse_MQType `protobuf:"varint,2,opt,name=mqType,proto3,enum=org.opendedup.grpc.MessageQueueInfoResponse_MQType" json:"mqType,omitempty"`
	Port     int32                           `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Topic    string                          `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	AuthInfo string                          `protobuf:"bytes,5,opt,name=authInfo,proto3" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageQueueInfoResponse) Descriptor deprecated 

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

Deprecated: Use MessageQueueInfoResponse.ProtoReflect.Descriptor instead.

func (*MessageQueueInfoResponse) GetAuthInfo 

func (x *MessageQueueInfoResponse) GetAuthInfo() string

func (*MessageQueueInfoResponse) GetHostName 

func (x *MessageQueueInfoResponse) GetHostName() string

func (*MessageQueueInfoResponse) GetMqType 

func (x *MessageQueueInfoResponse) GetMqType() MessageQueueInfoResponse_MQType

func (*MessageQueueInfoResponse) GetPort 

func (x *MessageQueueInfoResponse) GetPort() int32

func (*MessageQueueInfoResponse) GetTopic 

func (x *MessageQueueInfoResponse) GetTopic() string

func (*MessageQueueInfoResponse) ProtoMessage 

func (*MessageQueueInfoResponse) ProtoMessage()

func (*MessageQueueInfoResponse) ProtoReflect 

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

func (*MessageQueueInfoResponse) Reset 

func (x *MessageQueueInfoResponse) Reset()

func (*MessageQueueInfoResponse) String 

func (x *MessageQueueInfoResponse) String() string

type MessageQueueInfoResponse_MQType 

type MessageQueueInfoResponse_MQType int32
const (
	MessageQueueInfoResponse_RabbitMQ MessageQueueInfoResponse_MQType = 0
	MessageQueueInfoResponse_PubSub   MessageQueueInfoResponse_MQType = 1
)

func (MessageQueueInfoResponse_MQType) Descriptor 

func (MessageQueueInfoResponse_MQType) Descriptor() protoreflect.EnumDescriptor

func (MessageQueueInfoResponse_MQType) Enum 

func (x MessageQueueInfoResponse_MQType) Enum() *MessageQueueInfoResponse_MQType

func (MessageQueueInfoResponse_MQType) EnumDescriptor deprecated 

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

Deprecated: Use MessageQueueInfoResponse_MQType.Descriptor instead.

func (MessageQueueInfoResponse_MQType) Number 

func (x MessageQueueInfoResponse_MQType) Number() protoreflect.EnumNumber

func (MessageQueueInfoResponse_MQType) String 

func (x MessageQueueInfoResponse_MQType) String() string

func (MessageQueueInfoResponse_MQType) Type 

func (MessageQueueInfoResponse_MQType) Type() protoreflect.EnumType

type MkDirRequest 

type MkDirRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode int32  `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*MkDirRequest) Descriptor deprecated 

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

Deprecated: Use MkDirRequest.ProtoReflect.Descriptor instead.

func (*MkDirRequest) GetMode added in v0.1.22 

func (x *MkDirRequest) GetMode() int32

func (*MkDirRequest) GetPath 

func (x *MkDirRequest) GetPath() string

func (*MkDirRequest) ProtoMessage 

func (*MkDirRequest) ProtoMessage()

func (*MkDirRequest) ProtoReflect 

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

func (*MkDirRequest) Reset 

func (x *MkDirRequest) Reset()

func (*MkDirRequest) String 

func (x *MkDirRequest) String() string

type MkDirResponse 

type MkDirResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*MkDirResponse) Descriptor deprecated 

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

Deprecated: Use MkDirResponse.ProtoReflect.Descriptor instead.

func (*MkDirResponse) GetError 

func (x *MkDirResponse) GetError() string

func (*MkDirResponse) GetErrorCode 

func (x *MkDirResponse) GetErrorCode() ErrorCodes

func (*MkDirResponse) ProtoMessage 

func (*MkDirResponse) ProtoMessage()

func (*MkDirResponse) ProtoReflect 

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

func (*MkDirResponse) Reset 

func (x *MkDirResponse) Reset()

func (*MkDirResponse) String 

func (x *MkDirResponse) String() string

type MkNodRequest 

type MkNodRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode int32  `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	Rdev int32  `protobuf:"varint,3,opt,name=rdev,proto3" json:"rdev,omitempty"`
	// contains filtered or unexported fields
}

func (*MkNodRequest) Descriptor deprecated 

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

Deprecated: Use MkNodRequest.ProtoReflect.Descriptor instead.

func (*MkNodRequest) GetMode added in v0.1.19 

func (x *MkNodRequest) GetMode() int32

func (*MkNodRequest) GetPath 

func (x *MkNodRequest) GetPath() string

func (*MkNodRequest) GetRdev added in v0.1.19 

func (x *MkNodRequest) GetRdev() int32

func (*MkNodRequest) ProtoMessage 

func (*MkNodRequest) ProtoMessage()

func (*MkNodRequest) ProtoReflect 

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

func (*MkNodRequest) Reset 

func (x *MkNodRequest) Reset()

func (*MkNodRequest) String 

func (x *MkNodRequest) String() string

type MkNodResponse 

type MkNodResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*MkNodResponse) Descriptor deprecated 

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

Deprecated: Use MkNodResponse.ProtoReflect.Descriptor instead.

func (*MkNodResponse) GetError 

func (x *MkNodResponse) GetError() string

func (*MkNodResponse) GetErrorCode 

func (x *MkNodResponse) GetErrorCode() ErrorCodes

func (*MkNodResponse) ProtoMessage 

func (*MkNodResponse) ProtoMessage()

func (*MkNodResponse) ProtoReflect 

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

func (*MkNodResponse) Reset 

func (x *MkNodResponse) Reset()

func (*MkNodResponse) String 

func (x *MkNodResponse) String() string

type RFileAttributesRequest 

type RFileAttributesRequest struct {
	FilePath string `protobuf:"bytes,1,opt,name=filePath,proto3" json:"filePath,omitempty"`
	// contains filtered or unexported fields
}

func (*RFileAttributesRequest) Descriptor deprecated 

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

Deprecated: Use RFileAttributesRequest.ProtoReflect.Descriptor instead.

func (*RFileAttributesRequest) GetFilePath 

func (x *RFileAttributesRequest) GetFilePath() string

func (*RFileAttributesRequest) ProtoMessage 

func (*RFileAttributesRequest) ProtoMessage()

func (*RFileAttributesRequest) ProtoReflect 

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

func (*RFileAttributesRequest) Reset 

func (x *RFileAttributesRequest) Reset()

func (*RFileAttributesRequest) String 

func (x *RFileAttributesRequest) String() string

type RFileAttributesResponse 

type RFileAttributesResponse struct {
	FileAttributes []*FileAttributes `protobuf:"bytes,1,rep,name=fileAttributes,proto3" json:"fileAttributes,omitempty"`
	Error          string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode      ErrorCodes        `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*RFileAttributesResponse) Descriptor deprecated 

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

Deprecated: Use RFileAttributesResponse.ProtoReflect.Descriptor instead.

func (*RFileAttributesResponse) GetError 

func (x *RFileAttributesResponse) GetError() string

func (*RFileAttributesResponse) GetErrorCode 

func (x *RFileAttributesResponse) GetErrorCode() ErrorCodes

func (*RFileAttributesResponse) GetFileAttributes 

func (x *RFileAttributesResponse) GetFileAttributes() []*FileAttributes

func (*RFileAttributesResponse) ProtoMessage 

func (*RFileAttributesResponse) ProtoMessage()

func (*RFileAttributesResponse) ProtoReflect 

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

func (*RFileAttributesResponse) Reset 

func (x *RFileAttributesResponse) Reset()

func (*RFileAttributesResponse) String 

func (x *RFileAttributesResponse) String() string

type RemoveXAttrRequest added in v0.1.9 

type RemoveXAttrRequest struct {
	Attr string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveXAttrRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use RemoveXAttrRequest.ProtoReflect.Descriptor instead.

func (*RemoveXAttrRequest) GetAttr added in v0.1.9 

func (x *RemoveXAttrRequest) GetAttr() string

func (*RemoveXAttrRequest) GetPath added in v0.1.9 

func (x *RemoveXAttrRequest) GetPath() string

func (*RemoveXAttrRequest) ProtoMessage added in v0.1.9 

func (*RemoveXAttrRequest) ProtoMessage()

func (*RemoveXAttrRequest) ProtoReflect added in v0.1.9 

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

func (*RemoveXAttrRequest) Reset added in v0.1.9 

func (x *RemoveXAttrRequest) Reset()

func (*RemoveXAttrRequest) String added in v0.1.9 

func (x *RemoveXAttrRequest) String() string

type RemoveXAttrResponse added in v0.1.9 

type RemoveXAttrResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveXAttrResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use RemoveXAttrResponse.ProtoReflect.Descriptor instead.

func (*RemoveXAttrResponse) GetError added in v0.1.9 

func (x *RemoveXAttrResponse) GetError() string

func (*RemoveXAttrResponse) GetErrorCode added in v0.1.9 

func (x *RemoveXAttrResponse) GetErrorCode() ErrorCodes

func (*RemoveXAttrResponse) ProtoMessage added in v0.1.9 

func (*RemoveXAttrResponse) ProtoMessage()

func (*RemoveXAttrResponse) ProtoReflect added in v0.1.9 

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

func (*RemoveXAttrResponse) Reset added in v0.1.9 

func (x *RemoveXAttrResponse) Reset()

func (*RemoveXAttrResponse) String added in v0.1.9 

func (x *RemoveXAttrResponse) String() string

type RmDirRequest 

type RmDirRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RmDirRequest) Descriptor deprecated 

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

Deprecated: Use RmDirRequest.ProtoReflect.Descriptor instead.

func (*RmDirRequest) GetPath 

func (x *RmDirRequest) GetPath() string

func (*RmDirRequest) ProtoMessage 

func (*RmDirRequest) ProtoMessage()

func (*RmDirRequest) ProtoReflect 

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

func (*RmDirRequest) Reset 

func (x *RmDirRequest) Reset()

func (*RmDirRequest) String 

func (x *RmDirRequest) String() string

type RmDirResponse 

type RmDirResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*RmDirResponse) Descriptor deprecated 

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

Deprecated: Use RmDirResponse.ProtoReflect.Descriptor instead.

func (*RmDirResponse) GetError 

func (x *RmDirResponse) GetError() string

func (*RmDirResponse) GetErrorCode 

func (x *RmDirResponse) GetErrorCode() ErrorCodes

func (*RmDirResponse) ProtoMessage 

func (*RmDirResponse) ProtoMessage()

func (*RmDirResponse) ProtoReflect 

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

func (*RmDirResponse) Reset 

func (x *RmDirResponse) Reset()

func (*RmDirResponse) String 

func (x *RmDirResponse) String() string

type SDFSEvent added in v0.1.9 

type SDFSEvent struct {
	StartTime       int64             `protobuf:"varint,1,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime         int64             `protobuf:"varint,2,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Level           string            `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`
	Type            string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Target          string            `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
	ShortMsg        string            `protobuf:"bytes,6,opt,name=shortMsg,proto3" json:"shortMsg,omitempty"`
	LongMsg         string            `protobuf:"bytes,7,opt,name=longMsg,proto3" json:"longMsg,omitempty"`
	PercentComplete float64           `protobuf:"fixed64,8,opt,name=percentComplete,proto3" json:"percentComplete,omitempty"`
	MaxCount        int64             `protobuf:"varint,9,opt,name=maxCount,proto3" json:"maxCount,omitempty"`
	CurrentCount    int64             `protobuf:"varint,10,opt,name=currentCount,proto3" json:"currentCount,omitempty"`
	Uuid            string            `protobuf:"bytes,11,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ParentUuid      string            `protobuf:"bytes,12,opt,name=parentUuid,proto3" json:"parentUuid,omitempty"`
	ExtendedInfo    string            `protobuf:"bytes,13,opt,name=extendedInfo,proto3" json:"extendedInfo,omitempty"`
	ChildrenUUid    []string          `protobuf:"bytes,14,rep,name=childrenUUid,proto3" json:"childrenUUid,omitempty"`
	Success         bool              `protobuf:"varint,15,opt,name=success,proto3" json:"success,omitempty"`
	Attributes      map[string]string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SDFSEvent) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SDFSEvent.ProtoReflect.Descriptor instead.

func (*SDFSEvent) GetAttributes added in v0.1.9 

func (x *SDFSEvent) GetAttributes() map[string]string

func (*SDFSEvent) GetChildrenUUid added in v0.1.9 

func (x *SDFSEvent) GetChildrenUUid() []string

func (*SDFSEvent) GetCurrentCount added in v0.1.9 

func (x *SDFSEvent) GetCurrentCount() int64

func (*SDFSEvent) GetEndTime added in v0.1.9 

func (x *SDFSEvent) GetEndTime() int64

func (*SDFSEvent) GetExtendedInfo added in v0.1.9 

func (x *SDFSEvent) GetExtendedInfo() string

func (*SDFSEvent) GetLevel added in v0.1.9 

func (x *SDFSEvent) GetLevel() string

func (*SDFSEvent) GetLongMsg added in v0.1.9 

func (x *SDFSEvent) GetLongMsg() string

func (*SDFSEvent) GetMaxCount added in v0.1.9 

func (x *SDFSEvent) GetMaxCount() int64

func (*SDFSEvent) GetParentUuid added in v0.1.9 

func (x *SDFSEvent) GetParentUuid() string

func (*SDFSEvent) GetPercentComplete added in v0.1.9 

func (x *SDFSEvent) GetPercentComplete() float64

func (*SDFSEvent) GetShortMsg added in v0.1.9 

func (x *SDFSEvent) GetShortMsg() string

func (*SDFSEvent) GetStartTime added in v0.1.9 

func (x *SDFSEvent) GetStartTime() int64

func (*SDFSEvent) GetSuccess added in v0.1.9 

func (x *SDFSEvent) GetSuccess() bool

func (*SDFSEvent) GetTarget added in v0.1.9 

func (x *SDFSEvent) GetTarget() string

func (*SDFSEvent) GetType added in v0.1.9 

func (x *SDFSEvent) GetType() string

func (*SDFSEvent) GetUuid added in v0.1.9 

func (x *SDFSEvent) GetUuid() string

func (*SDFSEvent) ProtoMessage added in v0.1.9 

func (*SDFSEvent) ProtoMessage()

func (*SDFSEvent) ProtoReflect added in v0.1.9 

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

func (*SDFSEvent) Reset added in v0.1.9 

func (x *SDFSEvent) Reset()

func (*SDFSEvent) String added in v0.1.9 

func (x *SDFSEvent) String() string

type SDFSEventListRequest added in v0.1.9 

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

func (*SDFSEventListRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SDFSEventListRequest.ProtoReflect.Descriptor instead.

func (*SDFSEventListRequest) ProtoMessage added in v0.1.9 

func (*SDFSEventListRequest) ProtoMessage()

func (*SDFSEventListRequest) ProtoReflect added in v0.1.9 

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

func (*SDFSEventListRequest) Reset added in v0.1.9 

func (x *SDFSEventListRequest) Reset()

func (*SDFSEventListRequest) String added in v0.1.9 

func (x *SDFSEventListRequest) String() string

type SDFSEventListResponse added in v0.1.9 

type SDFSEventListResponse struct {
	Error     string       `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes   `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	Events    []*SDFSEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*SDFSEventListResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SDFSEventListResponse.ProtoReflect.Descriptor instead.

func (*SDFSEventListResponse) GetError added in v0.1.9 

func (x *SDFSEventListResponse) GetError() string

func (*SDFSEventListResponse) GetErrorCode added in v0.1.9 

func (x *SDFSEventListResponse) GetErrorCode() ErrorCodes

func (*SDFSEventListResponse) GetEvents added in v0.1.9 

func (x *SDFSEventListResponse) GetEvents() []*SDFSEvent

func (*SDFSEventListResponse) ProtoMessage added in v0.1.9 

func (*SDFSEventListResponse) ProtoMessage()

func (*SDFSEventListResponse) ProtoReflect added in v0.1.9 

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

func (*SDFSEventListResponse) Reset added in v0.1.9 

func (x *SDFSEventListResponse) Reset()

func (*SDFSEventListResponse) String added in v0.1.9 

func (x *SDFSEventListResponse) String() string

type SDFSEventRequest added in v0.1.9 

type SDFSEventRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*SDFSEventRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SDFSEventRequest.ProtoReflect.Descriptor instead.

func (*SDFSEventRequest) GetUuid added in v0.1.9 

func (x *SDFSEventRequest) GetUuid() string

func (*SDFSEventRequest) ProtoMessage added in v0.1.9 

func (*SDFSEventRequest) ProtoMessage()

func (*SDFSEventRequest) ProtoReflect added in v0.1.9 

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

func (*SDFSEventRequest) Reset added in v0.1.9 

func (x *SDFSEventRequest) Reset()

func (*SDFSEventRequest) String added in v0.1.9 

func (x *SDFSEventRequest) String() string

type SDFSEventResponse added in v0.1.9 

type SDFSEventResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	Event     *SDFSEvent `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*SDFSEventResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SDFSEventResponse.ProtoReflect.Descriptor instead.

func (*SDFSEventResponse) GetError added in v0.1.9 

func (x *SDFSEventResponse) GetError() string

func (*SDFSEventResponse) GetErrorCode added in v0.1.9 

func (x *SDFSEventResponse) GetErrorCode() ErrorCodes

func (*SDFSEventResponse) GetEvent added in v0.1.9 

func (x *SDFSEventResponse) GetEvent() *SDFSEvent

func (*SDFSEventResponse) ProtoMessage added in v0.1.9 

func (*SDFSEventResponse) ProtoMessage()

func (*SDFSEventResponse) ProtoReflect added in v0.1.9 

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

func (*SDFSEventResponse) Reset added in v0.1.9 

func (x *SDFSEventResponse) Reset()

func (*SDFSEventResponse) String added in v0.1.9 

func (x *SDFSEventResponse) String() string

type SDFSEventServiceClient added in v0.1.9 

type SDFSEventServiceClient interface {
	GetEvent(ctx context.Context, in *SDFSEventRequest, opts ...grpc.CallOption) (*SDFSEventResponse, error)
	ListEvents(ctx context.Context, in *SDFSEventListRequest, opts ...grpc.CallOption) (*SDFSEventListResponse, error)
	SubscribeEvent(ctx context.Context, in *SDFSEventRequest, opts ...grpc.CallOption) (SDFSEventService_SubscribeEventClient, error)
}

SDFSEventServiceClient is the client API for SDFSEventService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSDFSEventServiceClient added in v0.1.9 

func NewSDFSEventServiceClient(cc grpc.ClientConnInterface) SDFSEventServiceClient

type SDFSEventServiceServer added in v0.1.9 

type SDFSEventServiceServer interface {
	GetEvent(context.Context, *SDFSEventRequest) (*SDFSEventResponse, error)
	ListEvents(context.Context, *SDFSEventListRequest) (*SDFSEventListResponse, error)
	SubscribeEvent(*SDFSEventRequest, SDFSEventService_SubscribeEventServer) error
	// contains filtered or unexported methods
}

SDFSEventServiceServer is the server API for SDFSEventService service. All implementations must embed UnimplementedSDFSEventServiceServer for forward compatibility

type SDFSEventService_SubscribeEventClient added in v0.1.9 

type SDFSEventService_SubscribeEventClient interface {
	Recv() (*SDFSEventResponse, error)
	grpc.ClientStream
}

type SDFSEventService_SubscribeEventServer added in v0.1.9 

type SDFSEventService_SubscribeEventServer interface {
	Send(*SDFSEventResponse) error
	grpc.ServerStream
}

type SetCacheSizeRequest added in v0.1.9 

type SetCacheSizeRequest struct {
	CacheSize int64 `protobuf:"varint,1,opt,name=cacheSize,proto3" json:"cacheSize,omitempty"`
	// contains filtered or unexported fields
}

func (*SetCacheSizeRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetCacheSizeRequest.ProtoReflect.Descriptor instead.

func (*SetCacheSizeRequest) GetCacheSize added in v0.1.9 

func (x *SetCacheSizeRequest) GetCacheSize() int64

func (*SetCacheSizeRequest) ProtoMessage added in v0.1.9 

func (*SetCacheSizeRequest) ProtoMessage()

func (*SetCacheSizeRequest) ProtoReflect added in v0.1.9 

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

func (*SetCacheSizeRequest) Reset added in v0.1.9 

func (x *SetCacheSizeRequest) Reset()

func (*SetCacheSizeRequest) String added in v0.1.9 

func (x *SetCacheSizeRequest) String() string

type SetCacheSizeResponse added in v0.1.9 

type SetCacheSizeResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SetCacheSizeResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetCacheSizeResponse.ProtoReflect.Descriptor instead.

func (*SetCacheSizeResponse) GetError added in v0.1.9 

func (x *SetCacheSizeResponse) GetError() string

func (*SetCacheSizeResponse) GetErrorCode added in v0.1.9 

func (x *SetCacheSizeResponse) GetErrorCode() ErrorCodes

func (*SetCacheSizeResponse) GetEventID added in v0.1.9 

func (x *SetCacheSizeResponse) GetEventID() string

func (*SetCacheSizeResponse) ProtoMessage added in v0.1.9 

func (*SetCacheSizeResponse) ProtoMessage()

func (*SetCacheSizeResponse) ProtoReflect added in v0.1.9 

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

func (*SetCacheSizeResponse) Reset added in v0.1.9 

func (x *SetCacheSizeResponse) Reset()

func (*SetCacheSizeResponse) String added in v0.1.9 

func (x *SetCacheSizeResponse) String() string

type SetPasswordRequest added in v0.1.9 

type SetPasswordRequest struct {
	Password string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*SetPasswordRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetPasswordRequest.ProtoReflect.Descriptor instead.

func (*SetPasswordRequest) GetPassword added in v0.1.9 

func (x *SetPasswordRequest) GetPassword() string

func (*SetPasswordRequest) ProtoMessage added in v0.1.9 

func (*SetPasswordRequest) ProtoMessage()

func (*SetPasswordRequest) ProtoReflect added in v0.1.9 

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

func (*SetPasswordRequest) Reset added in v0.1.9 

func (x *SetPasswordRequest) Reset()

func (*SetPasswordRequest) String added in v0.1.9 

func (x *SetPasswordRequest) String() string

type SetPasswordResponse added in v0.1.9 

type SetPasswordResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SetPasswordResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetPasswordResponse.ProtoReflect.Descriptor instead.

func (*SetPasswordResponse) GetError added in v0.1.9 

func (x *SetPasswordResponse) GetError() string

func (*SetPasswordResponse) GetErrorCode added in v0.1.9 

func (x *SetPasswordResponse) GetErrorCode() ErrorCodes

func (*SetPasswordResponse) ProtoMessage added in v0.1.9 

func (*SetPasswordResponse) ProtoMessage()

func (*SetPasswordResponse) ProtoReflect added in v0.1.9 

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

func (*SetPasswordResponse) Reset added in v0.1.9 

func (x *SetPasswordResponse) Reset()

func (*SetPasswordResponse) String added in v0.1.9 

func (x *SetPasswordResponse) String() string

type SetUserMetaDataRequest added in v0.1.7 

type SetUserMetaDataRequest struct {
	FileAttributes []*FileAttributes `protobuf:"bytes,1,rep,name=fileAttributes,proto3" json:"fileAttributes,omitempty"`
	Path           string            `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUserMetaDataRequest) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use SetUserMetaDataRequest.ProtoReflect.Descriptor instead.

func (*SetUserMetaDataRequest) GetFileAttributes added in v0.1.7 

func (x *SetUserMetaDataRequest) GetFileAttributes() []*FileAttributes

func (*SetUserMetaDataRequest) GetPath added in v0.1.7 

func (x *SetUserMetaDataRequest) GetPath() string

func (*SetUserMetaDataRequest) ProtoMessage added in v0.1.7 

func (*SetUserMetaDataRequest) ProtoMessage()

func (*SetUserMetaDataRequest) ProtoReflect added in v0.1.7 

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

func (*SetUserMetaDataRequest) Reset added in v0.1.7 

func (x *SetUserMetaDataRequest) Reset()

func (*SetUserMetaDataRequest) String added in v0.1.7 

func (x *SetUserMetaDataRequest) String() string

type SetUserMetaDataResponse added in v0.1.7 

type SetUserMetaDataResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SetUserMetaDataResponse) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use SetUserMetaDataResponse.ProtoReflect.Descriptor instead.

func (*SetUserMetaDataResponse) GetError added in v0.1.7 

func (x *SetUserMetaDataResponse) GetError() string

func (*SetUserMetaDataResponse) GetErrorCode added in v0.1.7 

func (x *SetUserMetaDataResponse) GetErrorCode() ErrorCodes

func (*SetUserMetaDataResponse) ProtoMessage added in v0.1.7 

func (*SetUserMetaDataResponse) ProtoMessage()

func (*SetUserMetaDataResponse) ProtoReflect added in v0.1.7 

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

func (*SetUserMetaDataResponse) Reset added in v0.1.7 

func (x *SetUserMetaDataResponse) Reset()

func (*SetUserMetaDataResponse) String added in v0.1.7 

func (x *SetUserMetaDataResponse) String() string

type SetVolumeCapacityRequest added in v0.1.9 

type SetVolumeCapacityRequest struct {
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*SetVolumeCapacityRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetVolumeCapacityRequest.ProtoReflect.Descriptor instead.

func (*SetVolumeCapacityRequest) GetSize added in v0.1.9 

func (x *SetVolumeCapacityRequest) GetSize() int64

func (*SetVolumeCapacityRequest) ProtoMessage added in v0.1.9 

func (*SetVolumeCapacityRequest) ProtoMessage()

func (*SetVolumeCapacityRequest) ProtoReflect added in v0.1.9 

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

func (*SetVolumeCapacityRequest) Reset added in v0.1.9 

func (x *SetVolumeCapacityRequest) Reset()

func (*SetVolumeCapacityRequest) String added in v0.1.9 

func (x *SetVolumeCapacityRequest) String() string

type SetVolumeCapacityResponse added in v0.1.9 

type SetVolumeCapacityResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SetVolumeCapacityResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetVolumeCapacityResponse.ProtoReflect.Descriptor instead.

func (*SetVolumeCapacityResponse) GetError added in v0.1.9 

func (x *SetVolumeCapacityResponse) GetError() string

func (*SetVolumeCapacityResponse) GetErrorCode added in v0.1.9 

func (x *SetVolumeCapacityResponse) GetErrorCode() ErrorCodes

func (*SetVolumeCapacityResponse) ProtoMessage added in v0.1.9 

func (*SetVolumeCapacityResponse) ProtoMessage()

func (*SetVolumeCapacityResponse) ProtoReflect added in v0.1.9 

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

func (*SetVolumeCapacityResponse) Reset added in v0.1.9 

func (x *SetVolumeCapacityResponse) Reset()

func (*SetVolumeCapacityResponse) String added in v0.1.9 

func (x *SetVolumeCapacityResponse) String() string

type SetXAttrRequest added in v0.1.9 

type SetXAttrRequest struct {
	Attr  string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Path  string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*SetXAttrRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetXAttrRequest.ProtoReflect.Descriptor instead.

func (*SetXAttrRequest) GetAttr added in v0.1.9 

func (x *SetXAttrRequest) GetAttr() string

func (*SetXAttrRequest) GetPath added in v0.1.9 

func (x *SetXAttrRequest) GetPath() string

func (*SetXAttrRequest) GetValue added in v0.1.9 

func (x *SetXAttrRequest) GetValue() string

func (*SetXAttrRequest) ProtoMessage added in v0.1.9 

func (*SetXAttrRequest) ProtoMessage()

func (*SetXAttrRequest) ProtoReflect added in v0.1.9 

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

func (*SetXAttrRequest) Reset added in v0.1.9 

func (x *SetXAttrRequest) Reset()

func (*SetXAttrRequest) String added in v0.1.9 

func (x *SetXAttrRequest) String() string

type SetXAttrResponse added in v0.1.9 

type SetXAttrResponse struct {
	Error     string                    `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes                `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	Flags     SetXAttrResponseFlagsenum `protobuf:"varint,3,opt,name=flags,proto3,enum=org.opendedup.grpc.SetXAttrResponseFlagsenum" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*SetXAttrResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SetXAttrResponse.ProtoReflect.Descriptor instead.

func (*SetXAttrResponse) GetError added in v0.1.9 

func (x *SetXAttrResponse) GetError() string

func (*SetXAttrResponse) GetErrorCode added in v0.1.9 

func (x *SetXAttrResponse) GetErrorCode() ErrorCodes

func (*SetXAttrResponse) GetFlags added in v0.1.9 

func (x *SetXAttrResponse) GetFlags() SetXAttrResponseFlagsenum

func (*SetXAttrResponse) ProtoMessage added in v0.1.9 

func (*SetXAttrResponse) ProtoMessage()

func (*SetXAttrResponse) ProtoReflect added in v0.1.9 

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

func (*SetXAttrResponse) Reset added in v0.1.9 

func (x *SetXAttrResponse) Reset()

func (*SetXAttrResponse) String added in v0.1.9 

func (x *SetXAttrResponse) String() string

type SetXAttrResponseFlagsenum added in v0.1.9 

type SetXAttrResponseFlagsenum int32
const (
	SetXAttrResponse_XATTR_CREATE  SetXAttrResponseFlagsenum = 0
	SetXAttrResponse_XATTR_REPLACE SetXAttrResponseFlagsenum = 1
)

func (SetXAttrResponseFlagsenum) Descriptor added in v0.1.9 

func (SetXAttrResponseFlagsenum) Descriptor() protoreflect.EnumDescriptor

func (SetXAttrResponseFlagsenum) Enum added in v0.1.9 

func (x SetXAttrResponseFlagsenum) Enum() *SetXAttrResponseFlagsenum

func (SetXAttrResponseFlagsenum) EnumDescriptor deprecated added in v0.1.9 

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

Deprecated: Use SetXAttrResponseFlagsenum.Descriptor instead.

func (SetXAttrResponseFlagsenum) Number added in v0.1.9 

func (x SetXAttrResponseFlagsenum) Number() protoreflect.EnumNumber

func (SetXAttrResponseFlagsenum) String added in v0.1.9 

func (x SetXAttrResponseFlagsenum) String() string

func (SetXAttrResponseFlagsenum) Type added in v0.1.9 

func (SetXAttrResponseFlagsenum) Type() protoreflect.EnumType

type ShutdownRequest 

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

Request payload

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

type ShutdownResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,4,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) GetError 

func (x *ShutdownResponse) GetError() string

func (*ShutdownResponse) GetErrorCode 

func (x *ShutdownResponse) GetErrorCode() ErrorCodes

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type SpeedRequest added in v0.1.9 

type SpeedRequest struct {
	RequestedSpeed int32 `protobuf:"varint,1,opt,name=requestedSpeed,proto3" json:"requestedSpeed,omitempty"`
	// contains filtered or unexported fields
}

func (*SpeedRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SpeedRequest.ProtoReflect.Descriptor instead.

func (*SpeedRequest) GetRequestedSpeed added in v0.1.9 

func (x *SpeedRequest) GetRequestedSpeed() int32

func (*SpeedRequest) ProtoMessage added in v0.1.9 

func (*SpeedRequest) ProtoMessage()

func (*SpeedRequest) ProtoReflect added in v0.1.9 

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

func (*SpeedRequest) Reset added in v0.1.9 

func (x *SpeedRequest) Reset()

func (*SpeedRequest) String added in v0.1.9 

func (x *SpeedRequest) String() string

type SpeedResponse added in v0.1.9 

type SpeedResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SpeedResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SpeedResponse.ProtoReflect.Descriptor instead.

func (*SpeedResponse) GetError added in v0.1.9 

func (x *SpeedResponse) GetError() string

func (*SpeedResponse) GetErrorCode added in v0.1.9 

func (x *SpeedResponse) GetErrorCode() ErrorCodes

func (*SpeedResponse) GetEventID added in v0.1.9 

func (x *SpeedResponse) GetEventID() string

func (*SpeedResponse) ProtoMessage added in v0.1.9 

func (*SpeedResponse) ProtoMessage()

func (*SpeedResponse) ProtoReflect added in v0.1.9 

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

func (*SpeedResponse) Reset added in v0.1.9 

func (x *SpeedResponse) Reset()

func (*SpeedResponse) String added in v0.1.9 

func (x *SpeedResponse) String() string

type Stat added in v0.1.9 

type Stat struct {
	Dev     int64 `protobuf:"varint,1,opt,name=dev,proto3" json:"dev,omitempty"`         // ID of device containing file
	Ino     int64 `protobuf:"varint,2,opt,name=ino,proto3" json:"ino,omitempty"`         // Inode number
	Mode    int32 `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`       // File type and mode
	Nlink   int32 `protobuf:"varint,4,opt,name=nlink,proto3" json:"nlink,omitempty"`     // Number of hard links
	Uid     int32 `protobuf:"varint,5,opt,name=uid,proto3" json:"uid,omitempty"`         // User ID of owner
	Gid     int32 `protobuf:"varint,6,opt,name=gid,proto3" json:"gid,omitempty"`         // Group ID of owner
	Rdev    int32 `protobuf:"varint,7,opt,name=rdev,proto3" json:"rdev,omitempty"`       // Device ID (if special file)
	Size    int64 `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`       // Total size, in bytes
	Blksize int32 `protobuf:"varint,9,opt,name=blksize,proto3" json:"blksize,omitempty"` // Block size for filesystem I/O
	Blocks  int64 `protobuf:"varint,10,opt,name=blocks,proto3" json:"blocks,omitempty"`  // Number of 512B blocks allocated
	Atime   int64 `protobuf:"varint,11,opt,name=atime,proto3" json:"atime,omitempty"`    // Time of last access
	Mtim    int64 `protobuf:"varint,12,opt,name=mtim,proto3" json:"mtim,omitempty"`      // Time of last modification
	Ctim    int64 `protobuf:"varint,13,opt,name=ctim,proto3" json:"ctim,omitempty"`      // Time of last status change
	// contains filtered or unexported fields
}

func (*Stat) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use Stat.ProtoReflect.Descriptor instead.

func (*Stat) GetAtime added in v0.1.9 

func (x *Stat) GetAtime() int64

func (*Stat) GetBlksize added in v0.1.9 

func (x *Stat) GetBlksize() int32

func (*Stat) GetBlocks added in v0.1.9 

func (x *Stat) GetBlocks() int64

func (*Stat) GetCtim added in v0.1.9 

func (x *Stat) GetCtim() int64

func (*Stat) GetDev added in v0.1.9 

func (x *Stat) GetDev() int64

func (*Stat) GetGid added in v0.1.9 

func (x *Stat) GetGid() int32

func (*Stat) GetIno added in v0.1.9 

func (x *Stat) GetIno() int64

func (*Stat) GetMode added in v0.1.9 

func (x *Stat) GetMode() int32

func (*Stat) GetMtim added in v0.1.9 

func (x *Stat) GetMtim() int64
func (x *Stat) GetNlink() int32

func (*Stat) GetRdev added in v0.1.9 

func (x *Stat) GetRdev() int32

func (*Stat) GetSize added in v0.1.9 

func (x *Stat) GetSize() int64

func (*Stat) GetUid added in v0.1.9 

func (x *Stat) GetUid() int32

func (*Stat) ProtoMessage added in v0.1.9 

func (*Stat) ProtoMessage()

func (*Stat) ProtoReflect added in v0.1.9 

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

func (*Stat) Reset added in v0.1.9 

func (x *Stat) Reset()

func (*Stat) String added in v0.1.9 

func (x *Stat) String() string

type StatFS added in v0.1.9 

type StatFS struct {
	Bsize   int32 `protobuf:"varint,1,opt,name=bsize,proto3" json:"bsize,omitempty"`     // Optimal transfer block size
	Blocks  int64 `protobuf:"varint,2,opt,name=blocks,proto3" json:"blocks,omitempty"`   // Total data blocks in filesystem
	Bfree   int64 `protobuf:"varint,3,opt,name=bfree,proto3" json:"bfree,omitempty"`     // Free blocks in filesystem
	Bavail  int64 `protobuf:"varint,4,opt,name=bavail,proto3" json:"bavail,omitempty"`   // Free blocks available to unprivileged user
	Files   int64 `protobuf:"varint,5,opt,name=files,proto3" json:"files,omitempty"`     // Total inodes in filesystem
	Ffree   int64 `protobuf:"varint,6,opt,name=ffree,proto3" json:"ffree,omitempty"`     // Free inodes in filesystem
	Fsid    int64 `protobuf:"varint,7,opt,name=fsid,proto3" json:"fsid,omitempty"`       // Filesystem ID
	Namelen int32 `protobuf:"varint,8,opt,name=namelen,proto3" json:"namelen,omitempty"` // Maximum length of filenames
	Frsize  int32 `protobuf:"varint,9,opt,name=frsize,proto3" json:"frsize,omitempty"`   // Fragment size (since Linux 2.6)
	Flags   int32 `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"`    // Mount flags of filesystem
	Type    int32 `protobuf:"varint,11,opt,name=type,proto3" json:"type,omitempty"`      // Type of filesystem (see below)
	// contains filtered or unexported fields
}

func (*StatFS) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use StatFS.ProtoReflect.Descriptor instead.

func (*StatFS) GetBavail added in v0.1.9 

func (x *StatFS) GetBavail() int64

func (*StatFS) GetBfree added in v0.1.9 

func (x *StatFS) GetBfree() int64

func (*StatFS) GetBlocks added in v0.1.9 

func (x *StatFS) GetBlocks() int64

func (*StatFS) GetBsize added in v0.1.9 

func (x *StatFS) GetBsize() int32

func (*StatFS) GetFfree added in v0.1.9 

func (x *StatFS) GetFfree() int64

func (*StatFS) GetFiles added in v0.1.9 

func (x *StatFS) GetFiles() int64

func (*StatFS) GetFlags added in v0.1.9 

func (x *StatFS) GetFlags() int32

func (*StatFS) GetFrsize added in v0.1.9 

func (x *StatFS) GetFrsize() int32

func (*StatFS) GetFsid added in v0.1.9 

func (x *StatFS) GetFsid() int64

func (*StatFS) GetNamelen added in v0.1.9 

func (x *StatFS) GetNamelen() int32

func (*StatFS) GetType added in v0.1.9 

func (x *StatFS) GetType() int32

func (*StatFS) ProtoMessage added in v0.1.9 

func (*StatFS) ProtoMessage()

func (*StatFS) ProtoReflect added in v0.1.9 

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

func (*StatFS) Reset added in v0.1.9 

func (x *StatFS) Reset()

func (*StatFS) String added in v0.1.9 

func (x *StatFS) String() string

type StatFSRequest added in v0.1.9 

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

func (*StatFSRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use StatFSRequest.ProtoReflect.Descriptor instead.

func (*StatFSRequest) ProtoMessage added in v0.1.9 

func (*StatFSRequest) ProtoMessage()

func (*StatFSRequest) ProtoReflect added in v0.1.9 

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

func (*StatFSRequest) Reset added in v0.1.9 

func (x *StatFSRequest) Reset()

func (*StatFSRequest) String added in v0.1.9 

func (x *StatFSRequest) String() string

type StatFSResponse added in v0.1.9 

type StatFSResponse struct {
	Stat      *StatFS    `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*StatFSResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use StatFSResponse.ProtoReflect.Descriptor instead.

func (*StatFSResponse) GetError added in v0.1.9 

func (x *StatFSResponse) GetError() string

func (*StatFSResponse) GetErrorCode added in v0.1.9 

func (x *StatFSResponse) GetErrorCode() ErrorCodes

func (*StatFSResponse) GetStat added in v0.1.9 

func (x *StatFSResponse) GetStat() *StatFS

func (*StatFSResponse) ProtoMessage added in v0.1.9 

func (*StatFSResponse) ProtoMessage()

func (*StatFSResponse) ProtoReflect added in v0.1.9 

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

func (*StatFSResponse) Reset added in v0.1.9 

func (x *StatFSResponse) Reset()

func (*StatFSResponse) String added in v0.1.9 

func (x *StatFSResponse) String() string

type StatRequest added in v0.1.9 

type StatRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*StatRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use StatRequest.ProtoReflect.Descriptor instead.

func (*StatRequest) GetPath added in v0.1.9 

func (x *StatRequest) GetPath() string

func (*StatRequest) ProtoMessage added in v0.1.9 

func (*StatRequest) ProtoMessage()

func (*StatRequest) ProtoReflect added in v0.1.9 

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

func (*StatRequest) Reset added in v0.1.9 

func (x *StatRequest) Reset()

func (*StatRequest) String added in v0.1.9 

func (x *StatRequest) String() string

type StatResponse added in v0.1.9 

type StatResponse struct {
	Stat      *Stat      `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*StatResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use StatResponse.ProtoReflect.Descriptor instead.

func (*StatResponse) GetError added in v0.1.9 

func (x *StatResponse) GetError() string

func (*StatResponse) GetErrorCode added in v0.1.9 

func (x *StatResponse) GetErrorCode() ErrorCodes

func (*StatResponse) GetStat added in v0.1.9 

func (x *StatResponse) GetStat() *Stat

func (*StatResponse) ProtoMessage added in v0.1.9 

func (*StatResponse) ProtoMessage()

func (*StatResponse) ProtoReflect added in v0.1.9 

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

func (*StatResponse) Reset added in v0.1.9 

func (x *StatResponse) Reset()

func (*StatResponse) String added in v0.1.9 

func (x *StatResponse) String() string

type SymLinkRequest added in v0.1.9 

type SymLinkRequest struct {
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To   string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*SymLinkRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SymLinkRequest.ProtoReflect.Descriptor instead.

func (*SymLinkRequest) GetFrom added in v0.1.9 

func (x *SymLinkRequest) GetFrom() string

func (*SymLinkRequest) GetTo added in v0.1.9 

func (x *SymLinkRequest) GetTo() string

func (*SymLinkRequest) ProtoMessage added in v0.1.9 

func (*SymLinkRequest) ProtoMessage()

func (*SymLinkRequest) ProtoReflect added in v0.1.9 

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

func (*SymLinkRequest) Reset added in v0.1.9 

func (x *SymLinkRequest) Reset()

func (*SymLinkRequest) String added in v0.1.9 

func (x *SymLinkRequest) String() string

type SymLinkResponse added in v0.1.9 

type SymLinkResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SymLinkResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SymLinkResponse.ProtoReflect.Descriptor instead.

func (*SymLinkResponse) GetError added in v0.1.9 

func (x *SymLinkResponse) GetError() string

func (*SymLinkResponse) GetErrorCode added in v0.1.9 

func (x *SymLinkResponse) GetErrorCode() ErrorCodes

func (*SymLinkResponse) ProtoMessage added in v0.1.9 

func (*SymLinkResponse) ProtoMessage()

func (*SymLinkResponse) ProtoReflect added in v0.1.9 

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

func (*SymLinkResponse) Reset added in v0.1.9 

func (x *SymLinkResponse) Reset()

func (*SymLinkResponse) String added in v0.1.9 

func (x *SymLinkResponse) String() string

type SyncFromVolRequest added in v0.1.9 

type SyncFromVolRequest struct {
	Volumeid int64 `protobuf:"varint,1,opt,name=volumeid,proto3" json:"volumeid,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncFromVolRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SyncFromVolRequest.ProtoReflect.Descriptor instead.

func (*SyncFromVolRequest) GetVolumeid added in v0.1.9 

func (x *SyncFromVolRequest) GetVolumeid() int64

func (*SyncFromVolRequest) ProtoMessage added in v0.1.9 

func (*SyncFromVolRequest) ProtoMessage()

func (*SyncFromVolRequest) ProtoReflect added in v0.1.9 

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

func (*SyncFromVolRequest) Reset added in v0.1.9 

func (x *SyncFromVolRequest) Reset()

func (*SyncFromVolRequest) String added in v0.1.9 

func (x *SyncFromVolRequest) String() string

type SyncFromVolResponse added in v0.1.9 

type SyncFromVolResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncFromVolResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SyncFromVolResponse.ProtoReflect.Descriptor instead.

func (*SyncFromVolResponse) GetError added in v0.1.9 

func (x *SyncFromVolResponse) GetError() string

func (*SyncFromVolResponse) GetErrorCode added in v0.1.9 

func (x *SyncFromVolResponse) GetErrorCode() ErrorCodes

func (*SyncFromVolResponse) GetEventID added in v0.1.9 

func (x *SyncFromVolResponse) GetEventID() string

func (*SyncFromVolResponse) ProtoMessage added in v0.1.9 

func (*SyncFromVolResponse) ProtoMessage()

func (*SyncFromVolResponse) ProtoReflect added in v0.1.9 

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

func (*SyncFromVolResponse) Reset added in v0.1.9 

func (x *SyncFromVolResponse) Reset()

func (*SyncFromVolResponse) String added in v0.1.9 

func (x *SyncFromVolResponse) String() string

type SyncNotificationSubscription added in v0.1.31 

type SyncNotificationSubscription struct {
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncNotificationSubscription) Descriptor deprecated added in v0.1.31 

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

Deprecated: Use SyncNotificationSubscription.ProtoReflect.Descriptor instead.

func (*SyncNotificationSubscription) GetUid added in v0.1.31 

func (x *SyncNotificationSubscription) GetUid() string

func (*SyncNotificationSubscription) ProtoMessage added in v0.1.31 

func (*SyncNotificationSubscription) ProtoMessage()

func (*SyncNotificationSubscription) ProtoReflect added in v0.1.31 

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

func (*SyncNotificationSubscription) Reset added in v0.1.31 

func (x *SyncNotificationSubscription) Reset()

func (*SyncNotificationSubscription) String added in v0.1.31 

func (x *SyncNotificationSubscription) String() string

type SyncVolRequest added in v0.1.9 

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

func (*SyncVolRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SyncVolRequest.ProtoReflect.Descriptor instead.

func (*SyncVolRequest) ProtoMessage added in v0.1.9 

func (*SyncVolRequest) ProtoMessage()

func (*SyncVolRequest) ProtoReflect added in v0.1.9 

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

func (*SyncVolRequest) Reset added in v0.1.9 

func (x *SyncVolRequest) Reset()

func (*SyncVolRequest) String added in v0.1.9 

func (x *SyncVolRequest) String() string

type SyncVolResponse added in v0.1.9 

type SyncVolResponse struct {
	EventID   string     `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncVolResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SyncVolResponse.ProtoReflect.Descriptor instead.

func (*SyncVolResponse) GetError added in v0.1.9 

func (x *SyncVolResponse) GetError() string

func (*SyncVolResponse) GetErrorCode added in v0.1.9 

func (x *SyncVolResponse) GetErrorCode() ErrorCodes

func (*SyncVolResponse) GetEventID added in v0.1.9 

func (x *SyncVolResponse) GetEventID() string

func (*SyncVolResponse) ProtoMessage added in v0.1.9 

func (*SyncVolResponse) ProtoMessage()

func (*SyncVolResponse) ProtoReflect added in v0.1.9 

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

func (*SyncVolResponse) Reset added in v0.1.9 

func (x *SyncVolResponse) Reset()

func (*SyncVolResponse) String added in v0.1.9 

func (x *SyncVolResponse) String() string

type Syncaction added in v0.1.32 

type Syncaction int32
const (
	Syncaction_DOWNLOAD  Syncaction = 0 //Sync from Cloud
	Syncaction_WRITE     Syncaction = 1 //Write Locally
	Syncaction_DELETE    Syncaction = 2 //Delete
	Syncaction_UPLOAD    Syncaction = 3 //Upload Data To Cloud
	Syncaction_KEEPALIVE Syncaction = 4 //A Keepalive message
)

func (Syncaction) Descriptor added in v0.1.32 

func (Syncaction) Descriptor() protoreflect.EnumDescriptor

func (Syncaction) Enum added in v0.1.32 

func (x Syncaction) Enum() *Syncaction

func (Syncaction) EnumDescriptor deprecated added in v0.1.32 

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

Deprecated: Use Syncaction.Descriptor instead.

func (Syncaction) Number added in v0.1.32 

func (x Syncaction) Number() protoreflect.EnumNumber

func (Syncaction) String added in v0.1.32 

func (x Syncaction) String() string

func (Syncaction) Type added in v0.1.32 

func (Syncaction) Type() protoreflect.EnumType

type SystemInfo added in v0.1.9 

type SystemInfo struct {
	ActiveThreads   int32   `protobuf:"varint,1,opt,name=activeThreads,proto3" json:"activeThreads,omitempty"`
	BlocksStored    int32   `protobuf:"varint,2,opt,name=blocksStored,proto3" json:"blocksStored,omitempty"`
	MaxBlocksStored int32   `protobuf:"varint,3,opt,name=maxBlocksStored,proto3" json:"maxBlocksStored,omitempty"`
	TotalSpace      int64   `protobuf:"varint,4,opt,name=totalSpace,proto3" json:"totalSpace,omitempty"`
	FreeSpace       int64   `protobuf:"varint,5,opt,name=freeSpace,proto3" json:"freeSpace,omitempty"`
	TotalCpuLoad    float64 `protobuf:"fixed64,6,opt,name=totalCpuLoad,proto3" json:"totalCpuLoad,omitempty"`
	CpuCores        float64 `protobuf:"fixed64,7,opt,name=cpuCores,proto3" json:"cpuCores,omitempty"`
	SdfsCpuLoad     float64 `protobuf:"fixed64,8,opt,name=sdfsCpuLoad,proto3" json:"sdfsCpuLoad,omitempty"`
	TotalMemory     float64 `protobuf:"fixed64,10,opt,name=totalMemory,proto3" json:"totalMemory,omitempty"`
	FreeMemory      float64 `protobuf:"fixed64,11,opt,name=freeMemory,proto3" json:"freeMemory,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemInfo) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SystemInfo.ProtoReflect.Descriptor instead.

func (*SystemInfo) GetActiveThreads added in v0.1.9 

func (x *SystemInfo) GetActiveThreads() int32

func (*SystemInfo) GetBlocksStored added in v0.1.9 

func (x *SystemInfo) GetBlocksStored() int32

func (*SystemInfo) GetCpuCores added in v0.1.9 

func (x *SystemInfo) GetCpuCores() float64

func (*SystemInfo) GetFreeMemory added in v0.1.9 

func (x *SystemInfo) GetFreeMemory() float64

func (*SystemInfo) GetFreeSpace added in v0.1.9 

func (x *SystemInfo) GetFreeSpace() int64

func (*SystemInfo) GetMaxBlocksStored added in v0.1.9 

func (x *SystemInfo) GetMaxBlocksStored() int32

func (*SystemInfo) GetSdfsCpuLoad added in v0.1.9 

func (x *SystemInfo) GetSdfsCpuLoad() float64

func (*SystemInfo) GetTotalCpuLoad added in v0.1.9 

func (x *SystemInfo) GetTotalCpuLoad() float64

func (*SystemInfo) GetTotalMemory added in v0.1.9 

func (x *SystemInfo) GetTotalMemory() float64

func (*SystemInfo) GetTotalSpace added in v0.1.9 

func (x *SystemInfo) GetTotalSpace() int64

func (*SystemInfo) ProtoMessage added in v0.1.9 

func (*SystemInfo) ProtoMessage()

func (*SystemInfo) ProtoReflect added in v0.1.9 

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

func (*SystemInfo) Reset added in v0.1.9 

func (x *SystemInfo) Reset()

func (*SystemInfo) String added in v0.1.9 

func (x *SystemInfo) String() string

type SystemInfoRequest added in v0.1.9 

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

func (*SystemInfoRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SystemInfoRequest.ProtoReflect.Descriptor instead.

func (*SystemInfoRequest) ProtoMessage added in v0.1.9 

func (*SystemInfoRequest) ProtoMessage()

func (*SystemInfoRequest) ProtoReflect added in v0.1.9 

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

func (*SystemInfoRequest) Reset added in v0.1.9 

func (x *SystemInfoRequest) Reset()

func (*SystemInfoRequest) String added in v0.1.9 

func (x *SystemInfoRequest) String() string

type SystemInfoResponse added in v0.1.9 

type SystemInfoResponse struct {
	Info      *SystemInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Error     string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes  `protobuf:"varint,3,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemInfoResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use SystemInfoResponse.ProtoReflect.Descriptor instead.

func (*SystemInfoResponse) GetError added in v0.1.9 

func (x *SystemInfoResponse) GetError() string

func (*SystemInfoResponse) GetErrorCode added in v0.1.9 

func (x *SystemInfoResponse) GetErrorCode() ErrorCodes

func (*SystemInfoResponse) GetInfo added in v0.1.9 

func (x *SystemInfoResponse) GetInfo() *SystemInfo

func (*SystemInfoResponse) ProtoMessage added in v0.1.9 

func (*SystemInfoResponse) ProtoMessage()

func (*SystemInfoResponse) ProtoReflect added in v0.1.9 

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

func (*SystemInfoResponse) Reset added in v0.1.9 

func (x *SystemInfoResponse) Reset()

func (*SystemInfoResponse) String added in v0.1.9 

func (x *SystemInfoResponse) String() string

type TruncateRequest added in v0.1.9 

type TruncateRequest struct {
	Path   string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Length int64  `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use TruncateRequest.ProtoReflect.Descriptor instead.

func (*TruncateRequest) GetLength added in v0.1.9 

func (x *TruncateRequest) GetLength() int64

func (*TruncateRequest) GetPath added in v0.1.9 

func (x *TruncateRequest) GetPath() string

func (*TruncateRequest) ProtoMessage added in v0.1.9 

func (*TruncateRequest) ProtoMessage()

func (*TruncateRequest) ProtoReflect added in v0.1.9 

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

func (*TruncateRequest) Reset added in v0.1.9 

func (x *TruncateRequest) Reset()

func (*TruncateRequest) String added in v0.1.9 

func (x *TruncateRequest) String() string

type TruncateResponse added in v0.1.9 

type TruncateResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use TruncateResponse.ProtoReflect.Descriptor instead.

func (*TruncateResponse) GetError added in v0.1.9 

func (x *TruncateResponse) GetError() string

func (*TruncateResponse) GetErrorCode added in v0.1.9 

func (x *TruncateResponse) GetErrorCode() ErrorCodes

func (*TruncateResponse) ProtoMessage added in v0.1.9 

func (*TruncateResponse) ProtoMessage()

func (*TruncateResponse) ProtoReflect added in v0.1.9 

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

func (*TruncateResponse) Reset added in v0.1.9 

func (x *TruncateResponse) Reset()

func (*TruncateResponse) String added in v0.1.9 

func (x *TruncateResponse) String() string

type UnimplementedFileIOServiceServer 

type UnimplementedFileIOServiceServer struct {
}

UnimplementedFileIOServiceServer must be embedded to have forward compatible implementations.

func (*UnimplementedFileIOServiceServer) Chmod added in v0.1.9 

func (*UnimplementedFileIOServiceServer) Chmod(context.Context, *ChmodRequest) (*ChmodResponse, error)

func (*UnimplementedFileIOServiceServer) Chown added in v0.1.9 

func (*UnimplementedFileIOServiceServer) Chown(context.Context, *ChownRequest) (*ChownResponse, error)

func (*UnimplementedFileIOServiceServer) CopyExtent added in v0.1.4 

func (*UnimplementedFileIOServiceServer) CopyExtent(context.Context, *CopyExtentRequest) (*CopyExtentResponse, error)

func (*UnimplementedFileIOServiceServer) CreateCopy 

func (*UnimplementedFileIOServiceServer) CreateCopy(context.Context, *FileSnapshotRequest) (*FileSnapshotResponse, error)

func (*UnimplementedFileIOServiceServer) FileExists 

func (*UnimplementedFileIOServiceServer) FileExists(context.Context, *FileExistsRequest) (*FileExistsResponse, error)

func (*UnimplementedFileIOServiceServer) FileNotification added in v0.1.31 

func (*UnimplementedFileIOServiceServer) FileNotification(*SyncNotificationSubscription, FileIOService_FileNotificationServer) error

func (*UnimplementedFileIOServiceServer) Flush added in v0.1.9 

func (*UnimplementedFileIOServiceServer) Flush(context.Context, *FlushRequest) (*FlushResponse, error)

func (*UnimplementedFileIOServiceServer) Fsync added in v0.1.9 

func (*UnimplementedFileIOServiceServer) Fsync(context.Context, *FsyncRequest) (*FsyncResponse, error)

func (*UnimplementedFileIOServiceServer) GetAttr added in v0.1.9 

func (*UnimplementedFileIOServiceServer) GetAttr(context.Context, *StatRequest) (*StatResponse, error)

func (*UnimplementedFileIOServiceServer) GetCloudFile added in v0.1.9 

func (*UnimplementedFileIOServiceServer) GetCloudFile(context.Context, *GetCloudFileRequest) (*GetCloudFileResponse, error)

func (*UnimplementedFileIOServiceServer) GetCloudMetaFile added in v0.1.9 

func (*UnimplementedFileIOServiceServer) GetCloudMetaFile(context.Context, *GetCloudFileRequest) (*GetCloudFileResponse, error)

func (*UnimplementedFileIOServiceServer) GetFileInfo 

func (*UnimplementedFileIOServiceServer) GetFileInfo(context.Context, *FileInfoRequest) (*FileMessageResponse, error)

func (*UnimplementedFileIOServiceServer) GetXAttr added in v0.1.9 

func (*UnimplementedFileIOServiceServer) GetXAttr(context.Context, *GetXAttrRequest) (*GetXAttrResponse, error)

func (*UnimplementedFileIOServiceServer) GetXAttrSize added in v0.1.9 

func (*UnimplementedFileIOServiceServer) GetXAttrSize(context.Context, *GetXAttrSizeRequest) (*GetXAttrSizeResponse, error)

func (*UnimplementedFileIOServiceServer) MkDir 

func (*UnimplementedFileIOServiceServer) MkDir(context.Context, *MkDirRequest) (*MkDirResponse, error)

func (*UnimplementedFileIOServiceServer) MkDirAll 

func (*UnimplementedFileIOServiceServer) MkDirAll(context.Context, *MkDirRequest) (*MkDirResponse, error)

func (*UnimplementedFileIOServiceServer) Mknod 

func (*UnimplementedFileIOServiceServer) Mknod(context.Context, *MkNodRequest) (*MkNodResponse, error)

func (*UnimplementedFileIOServiceServer) Open 

func (*UnimplementedFileIOServiceServer) Open(context.Context, *FileOpenRequest) (*FileOpenResponse, error)

func (*UnimplementedFileIOServiceServer) Read 

func (*UnimplementedFileIOServiceServer) Read(context.Context, *DataReadRequest) (*DataReadResponse, error)
func (*UnimplementedFileIOServiceServer) ReadLink(context.Context, *LinkRequest) (*LinkResponse, error)

func (*UnimplementedFileIOServiceServer) Release 

func (*UnimplementedFileIOServiceServer) Release(context.Context, *FileCloseRequest) (*FileCloseResponse, error)

func (*UnimplementedFileIOServiceServer) RemoveXAttr added in v0.1.9 

func (*UnimplementedFileIOServiceServer) RemoveXAttr(context.Context, *RemoveXAttrRequest) (*RemoveXAttrResponse, error)

func (*UnimplementedFileIOServiceServer) Rename 

func (*UnimplementedFileIOServiceServer) Rename(context.Context, *FileRenameRequest) (*FileRenameResponse, error)

func (*UnimplementedFileIOServiceServer) RmDir 

func (*UnimplementedFileIOServiceServer) RmDir(context.Context, *RmDirRequest) (*RmDirResponse, error)

func (*UnimplementedFileIOServiceServer) SetUserMetaData added in v0.1.7 

func (*UnimplementedFileIOServiceServer) SetUserMetaData(context.Context, *SetUserMetaDataRequest) (*SetUserMetaDataResponse, error)

func (*UnimplementedFileIOServiceServer) SetXAttr added in v0.1.9 

func (*UnimplementedFileIOServiceServer) SetXAttr(context.Context, *SetXAttrRequest) (*SetXAttrResponse, error)

func (*UnimplementedFileIOServiceServer) Stat 

func (*UnimplementedFileIOServiceServer) Stat(context.Context, *FileInfoRequest) (*FileMessageResponse, error)

func (*UnimplementedFileIOServiceServer) StatFS added in v0.1.16 

func (*UnimplementedFileIOServiceServer) StatFS(context.Context, *StatFSRequest) (*StatFSResponse, error)
func (*UnimplementedFileIOServiceServer) SymLink(context.Context, *SymLinkRequest) (*SymLinkResponse, error)

func (*UnimplementedFileIOServiceServer) Truncate added in v0.1.9 

func (*UnimplementedFileIOServiceServer) Truncate(context.Context, *TruncateRequest) (*TruncateResponse, error)
func (*UnimplementedFileIOServiceServer) Unlink(context.Context, *UnlinkRequest) (*UnlinkResponse, error)

func (*UnimplementedFileIOServiceServer) Utime added in v0.1.9 

func (*UnimplementedFileIOServiceServer) Utime(context.Context, *UtimeRequest) (*UtimeResponse, error)

func (*UnimplementedFileIOServiceServer) Write 

func (*UnimplementedFileIOServiceServer) Write(context.Context, *DataWriteRequest) (*DataWriteResponse, error)

type UnimplementedSDFSEventServiceServer added in v0.1.9 

type UnimplementedSDFSEventServiceServer struct {
}

UnimplementedSDFSEventServiceServer must be embedded to have forward compatible implementations.

func (*UnimplementedSDFSEventServiceServer) GetEvent added in v0.1.9 

func (*UnimplementedSDFSEventServiceServer) GetEvent(context.Context, *SDFSEventRequest) (*SDFSEventResponse, error)

func (*UnimplementedSDFSEventServiceServer) ListEvents added in v0.1.9 

func (*UnimplementedSDFSEventServiceServer) ListEvents(context.Context, *SDFSEventListRequest) (*SDFSEventListResponse, error)

func (*UnimplementedSDFSEventServiceServer) SubscribeEvent added in v0.1.9 

func (*UnimplementedSDFSEventServiceServer) SubscribeEvent(*SDFSEventRequest, SDFSEventService_SubscribeEventServer) error

type UnimplementedVolumeServiceServer 

type UnimplementedVolumeServiceServer struct {
}

UnimplementedVolumeServiceServer must be embedded to have forward compatible implementations.

func (*UnimplementedVolumeServiceServer) AuthenticateUser added in v0.1.8 

func (*UnimplementedVolumeServiceServer) AuthenticateUser(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)

func (*UnimplementedVolumeServiceServer) CleanStore added in v0.1.9 

func (*UnimplementedVolumeServiceServer) CleanStore(context.Context, *CleanStoreRequest) (*CleanStoreResponse, error)

func (*UnimplementedVolumeServiceServer) DSEInfo added in v0.1.9 

func (*UnimplementedVolumeServiceServer) DSEInfo(context.Context, *DSERequest) (*DSEResponse, error)

func (*UnimplementedVolumeServiceServer) DeleteCloudVolume added in v0.1.9 

func (*UnimplementedVolumeServiceServer) DeleteCloudVolume(context.Context, *DeleteCloudVolumeRequest) (*DeleteCloudVolumeResponse, error)

func (*UnimplementedVolumeServiceServer) GetConnectedVolumes added in v0.1.9 

func (*UnimplementedVolumeServiceServer) GetConnectedVolumes(context.Context, *CloudVolumesRequest) (*CloudVolumesResponse, error)

func (*UnimplementedVolumeServiceServer) GetGCSchedule added in v0.1.9 

func (*UnimplementedVolumeServiceServer) GetGCSchedule(context.Context, *GCScheduleRequest) (*GCScheduleResponse, error)

func (*UnimplementedVolumeServiceServer) GetVolumeInfo 

func (*UnimplementedVolumeServiceServer) GetVolumeInfo(context.Context, *VolumeInfoRequest) (*VolumeInfoResponse, error)

func (*UnimplementedVolumeServiceServer) SetCacheSize added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SetCacheSize(context.Context, *SetCacheSizeRequest) (*SetCacheSizeResponse, error)

func (*UnimplementedVolumeServiceServer) SetPassword added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SetPassword(context.Context, *SetPasswordRequest) (*SetPasswordResponse, error)

func (*UnimplementedVolumeServiceServer) SetReadSpeed added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SetReadSpeed(context.Context, *SpeedRequest) (*SpeedResponse, error)

func (*UnimplementedVolumeServiceServer) SetVolumeCapacity added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SetVolumeCapacity(context.Context, *SetVolumeCapacityRequest) (*SetVolumeCapacityResponse, error)

func (*UnimplementedVolumeServiceServer) SetWriteSpeed added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SetWriteSpeed(context.Context, *SpeedRequest) (*SpeedResponse, error)

func (*UnimplementedVolumeServiceServer) ShutdownVolume 

func (*UnimplementedVolumeServiceServer) ShutdownVolume(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (*UnimplementedVolumeServiceServer) SyncCloudVolume added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SyncCloudVolume(context.Context, *SyncVolRequest) (*SyncVolResponse, error)

func (*UnimplementedVolumeServiceServer) SyncFromCloudVolume added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SyncFromCloudVolume(context.Context, *SyncFromVolRequest) (*SyncFromVolResponse, error)

func (*UnimplementedVolumeServiceServer) SystemInfo added in v0.1.9 

func (*UnimplementedVolumeServiceServer) SystemInfo(context.Context, *SystemInfoRequest) (*SystemInfoResponse, error)

type UnlinkRequest 

type UnlinkRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlinkRequest) Descriptor deprecated 

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

Deprecated: Use UnlinkRequest.ProtoReflect.Descriptor instead.

func (*UnlinkRequest) GetPath 

func (x *UnlinkRequest) GetPath() string

func (*UnlinkRequest) ProtoMessage 

func (*UnlinkRequest) ProtoMessage()

func (*UnlinkRequest) ProtoReflect 

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

func (*UnlinkRequest) Reset 

func (x *UnlinkRequest) Reset()

func (*UnlinkRequest) String 

func (x *UnlinkRequest) String() string

type UnlinkResponse 

type UnlinkResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlinkResponse) Descriptor deprecated 

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

Deprecated: Use UnlinkResponse.ProtoReflect.Descriptor instead.

func (*UnlinkResponse) GetError 

func (x *UnlinkResponse) GetError() string

func (*UnlinkResponse) GetErrorCode 

func (x *UnlinkResponse) GetErrorCode() ErrorCodes

func (*UnlinkResponse) ProtoMessage 

func (*UnlinkResponse) ProtoMessage()

func (*UnlinkResponse) ProtoReflect 

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

func (*UnlinkResponse) Reset 

func (x *UnlinkResponse) Reset()

func (*UnlinkResponse) String 

func (x *UnlinkResponse) String() string

type UtimeRequest added in v0.1.9 

type UtimeRequest struct {
	Path  string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Atime int64  `protobuf:"varint,2,opt,name=atime,proto3" json:"atime,omitempty"`
	Mtime int64  `protobuf:"varint,3,opt,name=mtime,proto3" json:"mtime,omitempty"`
	// contains filtered or unexported fields
}

func (*UtimeRequest) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use UtimeRequest.ProtoReflect.Descriptor instead.

func (*UtimeRequest) GetAtime added in v0.1.9 

func (x *UtimeRequest) GetAtime() int64

func (*UtimeRequest) GetMtime added in v0.1.9 

func (x *UtimeRequest) GetMtime() int64

func (*UtimeRequest) GetPath added in v0.1.9 

func (x *UtimeRequest) GetPath() string

func (*UtimeRequest) ProtoMessage added in v0.1.9 

func (*UtimeRequest) ProtoMessage()

func (*UtimeRequest) ProtoReflect added in v0.1.9 

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

func (*UtimeRequest) Reset added in v0.1.9 

func (x *UtimeRequest) Reset()

func (*UtimeRequest) String added in v0.1.9 

func (x *UtimeRequest) String() string

type UtimeResponse added in v0.1.9 

type UtimeResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*UtimeResponse) Descriptor deprecated added in v0.1.9 

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

Deprecated: Use UtimeResponse.ProtoReflect.Descriptor instead.

func (*UtimeResponse) GetError added in v0.1.9 

func (x *UtimeResponse) GetError() string

func (*UtimeResponse) GetErrorCode added in v0.1.9 

func (x *UtimeResponse) GetErrorCode() ErrorCodes

func (*UtimeResponse) ProtoMessage added in v0.1.9 

func (*UtimeResponse) ProtoMessage()

func (*UtimeResponse) ProtoReflect added in v0.1.9 

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

func (*UtimeResponse) Reset added in v0.1.9 

func (x *UtimeResponse) Reset()

func (*UtimeResponse) String added in v0.1.9 

func (x *UtimeResponse) String() string

type VolumeInfoRequest 

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

Request payload

func (*VolumeInfoRequest) Descriptor deprecated 

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

Deprecated: Use VolumeInfoRequest.ProtoReflect.Descriptor instead.

func (*VolumeInfoRequest) ProtoMessage 

func (*VolumeInfoRequest) ProtoMessage()

func (*VolumeInfoRequest) ProtoReflect 

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

func (*VolumeInfoRequest) Reset 

func (x *VolumeInfoRequest) Reset()

func (*VolumeInfoRequest) String 

func (x *VolumeInfoRequest) String() string

type VolumeInfoResponse 

type VolumeInfoResponse struct {
	Path                string                      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Name                string                      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CurrentSize         int64                       `protobuf:"varint,3,opt,name=currentSize,proto3" json:"currentSize,omitempty"`
	Capactity           int64                       `protobuf:"varint,4,opt,name=capactity,proto3" json:"capactity,omitempty"`
	MaxPercentageFull   float64                     `protobuf:"fixed64,5,opt,name=maxPercentageFull,proto3" json:"maxPercentageFull,omitempty"`
	DuplicateBytes      int64                       `protobuf:"varint,6,opt,name=duplicateBytes,proto3" json:"duplicateBytes,omitempty"`
	ReadBytes           float64                     `protobuf:"fixed64,7,opt,name=readBytes,proto3" json:"readBytes,omitempty"`
	WriteBytes          int64                       `protobuf:"varint,8,opt,name=writeBytes,proto3" json:"writeBytes,omitempty"`
	SerialNumber        int64                       `protobuf:"varint,9,opt,name=serialNumber,proto3" json:"serialNumber,omitempty"`
	DseSize             int64                       `protobuf:"varint,10,opt,name=dseSize,proto3" json:"dseSize,omitempty"`
	DseCompSize         int64                       `protobuf:"varint,11,opt,name=dseCompSize,proto3" json:"dseCompSize,omitempty"`
	ReadOps             float64                     `protobuf:"fixed64,12,opt,name=readOps,proto3" json:"readOps,omitempty"`
	WriteOps            float64                     `protobuf:"fixed64,13,opt,name=writeOps,proto3" json:"writeOps,omitempty"`
	ReadErrors          int64                       `protobuf:"varint,14,opt,name=readErrors,proto3" json:"readErrors,omitempty"`
	WriteErrors         int64                       `protobuf:"varint,15,opt,name=writeErrors,proto3" json:"writeErrors,omitempty"`
	Files               int64                       `protobuf:"varint,16,opt,name=files,proto3" json:"files,omitempty"`
	ClosedGracefully    bool                        `protobuf:"varint,17,opt,name=closedGracefully,proto3" json:"closedGracefully,omitempty"`
	AllowExternalLinks  bool                        `protobuf:"varint,18,opt,name=allowExternalLinks,proto3" json:"allowExternalLinks,omitempty"`
	UsePerfMon          bool                        `protobuf:"varint,19,opt,name=usePerfMon,proto3" json:"usePerfMon,omitempty"`
	ClusterId           string                      `protobuf:"bytes,20,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	VolumeClustered     bool                        `protobuf:"varint,21,opt,name=VolumeClustered,proto3" json:"VolumeClustered,omitempty"`
	ReadTimeoutSeconds  int32                       `protobuf:"varint,22,opt,name=readTimeoutSeconds,proto3" json:"readTimeoutSeconds,omitempty"`
	WriteTimeoutSeconds int32                       `protobuf:"varint,23,opt,name=writeTimeoutSeconds,proto3" json:"writeTimeoutSeconds,omitempty"`
	CompressedMetaData  bool                        `protobuf:"varint,24,opt,name=compressedMetaData,proto3" json:"compressedMetaData,omitempty"`
	SyncFiles           bool                        `protobuf:"varint,25,opt,name=syncFiles,proto3" json:"syncFiles,omitempty"`
	MaxPageSize         int64                       `protobuf:"varint,26,opt,name=maxPageSize,proto3" json:"maxPageSize,omitempty"`
	MessageQueue        []*MessageQueueInfoResponse `protobuf:"bytes,27,rep,name=messageQueue,proto3" json:"messageQueue,omitempty"`
	PerfMonFile         string                      `protobuf:"bytes,28,opt,name=perfMonFile,proto3" json:"perfMonFile,omitempty"`
	Offline             bool                        `protobuf:"varint,29,opt,name=offline,proto3" json:"offline,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeInfoResponse) Descriptor deprecated 

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

Deprecated: Use VolumeInfoResponse.ProtoReflect.Descriptor instead. 

func (x *VolumeInfoResponse) GetAllowExternalLinks() bool

func (*VolumeInfoResponse) GetCapactity 

func (x *VolumeInfoResponse) GetCapactity() int64

func (*VolumeInfoResponse) GetClosedGracefully 

func (x *VolumeInfoResponse) GetClosedGracefully() bool

func (*VolumeInfoResponse) GetClusterId 

func (x *VolumeInfoResponse) GetClusterId() string

func (*VolumeInfoResponse) GetCompressedMetaData 

func (x *VolumeInfoResponse) GetCompressedMetaData() bool

func (*VolumeInfoResponse) GetCurrentSize 

func (x *VolumeInfoResponse) GetCurrentSize() int64

func (*VolumeInfoResponse) GetDseCompSize 

func (x *VolumeInfoResponse) GetDseCompSize() int64

func (*VolumeInfoResponse) GetDseSize 

func (x *VolumeInfoResponse) GetDseSize() int64

func (*VolumeInfoResponse) GetDuplicateBytes 

func (x *VolumeInfoResponse) GetDuplicateBytes() int64

func (*VolumeInfoResponse) GetFiles 

func (x *VolumeInfoResponse) GetFiles() int64

func (*VolumeInfoResponse) GetMaxPageSize 

func (x *VolumeInfoResponse) GetMaxPageSize() int64

func (*VolumeInfoResponse) GetMaxPercentageFull 

func (x *VolumeInfoResponse) GetMaxPercentageFull() float64

func (*VolumeInfoResponse) GetMessageQueue 

func (x *VolumeInfoResponse) GetMessageQueue() []*MessageQueueInfoResponse

func (*VolumeInfoResponse) GetName 

func (x *VolumeInfoResponse) GetName() string

func (*VolumeInfoResponse) GetOffline 

func (x *VolumeInfoResponse) GetOffline() bool

func (*VolumeInfoResponse) GetPath 

func (x *VolumeInfoResponse) GetPath() string

func (*VolumeInfoResponse) GetPerfMonFile 

func (x *VolumeInfoResponse) GetPerfMonFile() string

func (*VolumeInfoResponse) GetReadBytes 

func (x *VolumeInfoResponse) GetReadBytes() float64

func (*VolumeInfoResponse) GetReadErrors 

func (x *VolumeInfoResponse) GetReadErrors() int64

func (*VolumeInfoResponse) GetReadOps 

func (x *VolumeInfoResponse) GetReadOps() float64

func (*VolumeInfoResponse) GetReadTimeoutSeconds 

func (x *VolumeInfoResponse) GetReadTimeoutSeconds() int32

func (*VolumeInfoResponse) GetSerialNumber 

func (x *VolumeInfoResponse) GetSerialNumber() int64

func (*VolumeInfoResponse) GetSyncFiles 

func (x *VolumeInfoResponse) GetSyncFiles() bool

func (*VolumeInfoResponse) GetUsePerfMon 

func (x *VolumeInfoResponse) GetUsePerfMon() bool

func (*VolumeInfoResponse) GetVolumeClustered 

func (x *VolumeInfoResponse) GetVolumeClustered() bool

func (*VolumeInfoResponse) GetWriteBytes 

func (x *VolumeInfoResponse) GetWriteBytes() int64

func (*VolumeInfoResponse) GetWriteErrors 

func (x *VolumeInfoResponse) GetWriteErrors() int64

func (*VolumeInfoResponse) GetWriteOps 

func (x *VolumeInfoResponse) GetWriteOps() float64

func (*VolumeInfoResponse) GetWriteTimeoutSeconds 

func (x *VolumeInfoResponse) GetWriteTimeoutSeconds() int32

func (*VolumeInfoResponse) ProtoMessage 

func (*VolumeInfoResponse) ProtoMessage()

func (*VolumeInfoResponse) ProtoReflect 

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

func (*VolumeInfoResponse) Reset 

func (x *VolumeInfoResponse) Reset()

func (*VolumeInfoResponse) String 

func (x *VolumeInfoResponse) String() string

type VolumeServiceClient 

type VolumeServiceClient interface {
	AuthenticateUser(ctx context.Context, in *AuthenticationRequest, opts ...grpc.CallOption) (*AuthenticationResponse, error)
	GetVolumeInfo(ctx context.Context, in *VolumeInfoRequest, opts ...grpc.CallOption) (*VolumeInfoResponse, error)
	ShutdownVolume(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
	CleanStore(ctx context.Context, in *CleanStoreRequest, opts ...grpc.CallOption) (*CleanStoreResponse, error)
	DeleteCloudVolume(ctx context.Context, in *DeleteCloudVolumeRequest, opts ...grpc.CallOption) (*DeleteCloudVolumeResponse, error)
	DSEInfo(ctx context.Context, in *DSERequest, opts ...grpc.CallOption) (*DSEResponse, error)
	SystemInfo(ctx context.Context, in *SystemInfoRequest, opts ...grpc.CallOption) (*SystemInfoResponse, error)
	SetVolumeCapacity(ctx context.Context, in *SetVolumeCapacityRequest, opts ...grpc.CallOption) (*SetVolumeCapacityResponse, error)
	GetConnectedVolumes(ctx context.Context, in *CloudVolumesRequest, opts ...grpc.CallOption) (*CloudVolumesResponse, error)
	GetGCSchedule(ctx context.Context, in *GCScheduleRequest, opts ...grpc.CallOption) (*GCScheduleResponse, error)
	SetCacheSize(ctx context.Context, in *SetCacheSizeRequest, opts ...grpc.CallOption) (*SetCacheSizeResponse, error)
	SetPassword(ctx context.Context, in *SetPasswordRequest, opts ...grpc.CallOption) (*SetPasswordResponse, error)
	SetReadSpeed(ctx context.Context, in *SpeedRequest, opts ...grpc.CallOption) (*SpeedResponse, error)
	SetWriteSpeed(ctx context.Context, in *SpeedRequest, opts ...grpc.CallOption) (*SpeedResponse, error)
	SyncFromCloudVolume(ctx context.Context, in *SyncFromVolRequest, opts ...grpc.CallOption) (*SyncFromVolResponse, error)
	SyncCloudVolume(ctx context.Context, in *SyncVolRequest, opts ...grpc.CallOption) (*SyncVolResponse, error)
}

VolumeServiceClient is the client API for VolumeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVolumeServiceClient 

func NewVolumeServiceClient(cc grpc.ClientConnInterface) VolumeServiceClient

type VolumeServiceServer 

type VolumeServiceServer interface {
	AuthenticateUser(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)
	GetVolumeInfo(context.Context, *VolumeInfoRequest) (*VolumeInfoResponse, error)
	ShutdownVolume(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	CleanStore(context.Context, *CleanStoreRequest) (*CleanStoreResponse, error)
	DeleteCloudVolume(context.Context, *DeleteCloudVolumeRequest) (*DeleteCloudVolumeResponse, error)
	DSEInfo(context.Context, *DSERequest) (*DSEResponse, error)
	SystemInfo(context.Context, *SystemInfoRequest) (*SystemInfoResponse, error)
	SetVolumeCapacity(context.Context, *SetVolumeCapacityRequest) (*SetVolumeCapacityResponse, error)
	GetConnectedVolumes(context.Context, *CloudVolumesRequest) (*CloudVolumesResponse, error)
	GetGCSchedule(context.Context, *GCScheduleRequest) (*GCScheduleResponse, error)
	SetCacheSize(context.Context, *SetCacheSizeRequest) (*SetCacheSizeResponse, error)
	SetPassword(context.Context, *SetPasswordRequest) (*SetPasswordResponse, error)
	SetReadSpeed(context.Context, *SpeedRequest) (*SpeedResponse, error)
	SetWriteSpeed(context.Context, *SpeedRequest) (*SpeedResponse, error)
	SyncFromCloudVolume(context.Context, *SyncFromVolRequest) (*SyncFromVolResponse, error)
	SyncCloudVolume(context.Context, *SyncVolRequest) (*SyncVolResponse, error)
	// contains filtered or unexported methods
}

VolumeServiceServer is the server API for VolumeService service. All implementations must embed UnimplementedVolumeServiceServer for forward compatibility

type WFileAttributesRequest 

type WFileAttributesRequest struct {
	FileAttributes []*FileAttributes `protobuf:"bytes,1,rep,name=fileAttributes,proto3" json:"fileAttributes,omitempty"`
	FilePath       string            `protobuf:"bytes,2,opt,name=filePath,proto3" json:"filePath,omitempty"`
	// contains filtered or unexported fields
}

func (*WFileAttributesRequest) Descriptor deprecated 

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

Deprecated: Use WFileAttributesRequest.ProtoReflect.Descriptor instead.

func (*WFileAttributesRequest) GetFileAttributes 

func (x *WFileAttributesRequest) GetFileAttributes() []*FileAttributes

func (*WFileAttributesRequest) GetFilePath 

func (x *WFileAttributesRequest) GetFilePath() string

func (*WFileAttributesRequest) ProtoMessage 

func (*WFileAttributesRequest) ProtoMessage()

func (*WFileAttributesRequest) ProtoReflect 

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

func (*WFileAttributesRequest) Reset 

func (x *WFileAttributesRequest) Reset()

func (*WFileAttributesRequest) String 

func (x *WFileAttributesRequest) String() string

type WFileAttributesResponse 

type WFileAttributesResponse struct {
	Error     string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorCode ErrorCodes `protobuf:"varint,2,opt,name=errorCode,proto3,enum=org.opendedup.grpc.ErrorCodes" json:"errorCode,omitempty"`
	// contains filtered or unexported fields
}

func (*WFileAttributesResponse) Descriptor deprecated 

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

Deprecated: Use WFileAttributesResponse.ProtoReflect.Descriptor instead.

func (*WFileAttributesResponse) GetError 

func (x *WFileAttributesResponse) GetError() string

func (*WFileAttributesResponse) GetErrorCode 

func (x *WFileAttributesResponse) GetErrorCode() ErrorCodes

func (*WFileAttributesResponse) ProtoMessage 

func (*WFileAttributesResponse) ProtoMessage()

func (*WFileAttributesResponse) ProtoReflect 

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

func (*WFileAttributesResponse) Reset 

func (x *WFileAttributesResponse) Reset()

func (*WFileAttributesResponse) String 

func (x *WFileAttributesResponse) String() string

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.