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 (*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

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.

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 (*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) Enum

func (FileInfoResponseFileType) EnumDescriptor deprecated

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

Deprecated: Use FileInfoResponseFileType.Descriptor instead.

func (FileInfoResponseFileType) Number

func (FileInfoResponseFileType) String

func (x FileInfoResponseFileType) String() string

func (FileInfoResponseFileType) Type

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 (*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) Enum

func (MessageQueueInfoResponse_MQType) EnumDescriptor deprecated

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

Deprecated: Use MessageQueueInfoResponse_MQType.Descriptor instead.

func (MessageQueueInfoResponse_MQType) Number

func (MessageQueueInfoResponse_MQType) String

func (MessageQueueInfoResponse_MQType) Type

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 (*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 (*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) Enum added in v0.1.9

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 (SetXAttrResponseFlagsenum) String added in v0.1.9

func (x SetXAttrResponseFlagsenum) String() string

func (SetXAttrResponseFlagsenum) Type added in v0.1.9

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 (*SyncNotificationSubscription) ProtoMessage added in v0.1.31

func (*SyncNotificationSubscription) ProtoMessage()

func (*SyncNotificationSubscription) ProtoReflect added in v0.1.31

func (*SyncNotificationSubscription) Reset added in v0.1.31

func (x *SyncNotificationSubscription) Reset()

func (*SyncNotificationSubscription) String added in v0.1.31

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

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) Chown added in v0.1.9

func (*UnimplementedFileIOServiceServer) CopyExtent added in v0.1.4

func (*UnimplementedFileIOServiceServer) CreateCopy

func (*UnimplementedFileIOServiceServer) FileExists

func (*UnimplementedFileIOServiceServer) FileNotification added in v0.1.31

func (*UnimplementedFileIOServiceServer) Flush added in v0.1.9

func (*UnimplementedFileIOServiceServer) Fsync added in v0.1.9

func (*UnimplementedFileIOServiceServer) GetAttr added in v0.1.9

func (*UnimplementedFileIOServiceServer) GetCloudFile added in v0.1.9

func (*UnimplementedFileIOServiceServer) GetCloudMetaFile added in v0.1.9

func (*UnimplementedFileIOServiceServer) GetFileInfo

func (*UnimplementedFileIOServiceServer) GetXAttr added in v0.1.9

func (*UnimplementedFileIOServiceServer) GetXAttrSize added in v0.1.9

func (*UnimplementedFileIOServiceServer) MkDir

func (*UnimplementedFileIOServiceServer) MkDirAll

func (*UnimplementedFileIOServiceServer) Mknod

func (*UnimplementedFileIOServiceServer) Open

func (*UnimplementedFileIOServiceServer) Read

func (*UnimplementedFileIOServiceServer) Release

func (*UnimplementedFileIOServiceServer) RemoveXAttr added in v0.1.9

func (*UnimplementedFileIOServiceServer) Rename

func (*UnimplementedFileIOServiceServer) RmDir

func (*UnimplementedFileIOServiceServer) SetUserMetaData added in v0.1.7

func (*UnimplementedFileIOServiceServer) SetXAttr added in v0.1.9

func (*UnimplementedFileIOServiceServer) Stat

func (*UnimplementedFileIOServiceServer) StatFS added in v0.1.16

func (*UnimplementedFileIOServiceServer) Truncate added in v0.1.9

func (*UnimplementedFileIOServiceServer) Utime added in v0.1.9

func (*UnimplementedFileIOServiceServer) Write

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) ListEvents added in v0.1.9

func (*UnimplementedSDFSEventServiceServer) SubscribeEvent added in v0.1.9

type UnimplementedVolumeServiceServer

type UnimplementedVolumeServiceServer struct {
}

UnimplementedVolumeServiceServer must be embedded to have forward compatible implementations.

func (*UnimplementedVolumeServiceServer) AuthenticateUser added in v0.1.8

func (*UnimplementedVolumeServiceServer) CleanStore added in v0.1.9

func (*UnimplementedVolumeServiceServer) DSEInfo added in v0.1.9

func (*UnimplementedVolumeServiceServer) DeleteCloudVolume added in v0.1.9

func (*UnimplementedVolumeServiceServer) GetConnectedVolumes added in v0.1.9

func (*UnimplementedVolumeServiceServer) GetGCSchedule added in v0.1.9

func (*UnimplementedVolumeServiceServer) GetVolumeInfo

func (*UnimplementedVolumeServiceServer) SetCacheSize added in v0.1.9

func (*UnimplementedVolumeServiceServer) SetPassword added in v0.1.9

func (*UnimplementedVolumeServiceServer) SetReadSpeed added in v0.1.9

func (*UnimplementedVolumeServiceServer) SetVolumeCapacity added in v0.1.9

func (*UnimplementedVolumeServiceServer) SetWriteSpeed added in v0.1.9

func (*UnimplementedVolumeServiceServer) ShutdownVolume

func (*UnimplementedVolumeServiceServer) SyncCloudVolume added in v0.1.9

func (*UnimplementedVolumeServiceServer) SyncFromCloudVolume added in v0.1.9

func (*UnimplementedVolumeServiceServer) SystemInfo added in v0.1.9

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.

type VolumeServiceServer

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL