proto

package
v0.0.0-...-7551d1f Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0:  "SUCCESS",
		1:  "ERROR",
		2:  "ERROR_CHECKSUM",
		4:  "ERROR_EXISTS",
		6:  "CHECKSUM_OK",
		12: "IN_PROGRESS",
	}
	Status_value = map[string]int32{
		"SUCCESS":        0,
		"ERROR":          1,
		"ERROR_CHECKSUM": 2,
		"ERROR_EXISTS":   4,
		"CHECKSUM_OK":    6,
		"IN_PROGRESS":    12,
	}
)

Enum value maps for Status.

View Source 
var (
	ClientWriteBlockProto_PipelineStatus_name = map[int32]string{
		0: "PIPELINE_SETUP_APPEND",
		1: "PIPELINE_DATA_STREAMING",
		2: "PIPELINE_CLOSE",
	}
	ClientWriteBlockProto_PipelineStatus_value = map[string]int32{
		"PIPELINE_SETUP_APPEND":   0,
		"PIPELINE_DATA_STREAMING": 1,
		"PIPELINE_CLOSE":          2,
	}
)

Enum value maps for ClientWriteBlockProto_PipelineStatus.

View Source 
var File_proto_client_namenode_proto protoreflect.FileDescriptor
View Source 
var File_proto_datanode_namenode_proto protoreflect.FileDescriptor
View Source 
var File_proto_datatransfer_proto protoreflect.FileDescriptor
View Source 
var File_proto_hdfs_proto protoreflect.FileDescriptor

Functions

func RegisterClientNameNodeServer 

func RegisterClientNameNodeServer(s *grpc.Server, srv ClientNameNodeServer)

func RegisterDataNodeNameNodeServer 

func RegisterDataNodeNameNodeServer(s *grpc.Server, srv DataNodeNameNodeServer)

Types

type BlockInfoProto 

type BlockInfoProto struct {
	FilePathInFS    string   `protobuf:"bytes,1,opt,name=FilePathInFS,proto3" json:"FilePathInFS,omitempty"`
	BlockIndex      uint32   `protobuf:"varint,2,opt,name=BlockIndex,proto3" json:"BlockIndex,omitempty"`
	LastBlockInFile bool     `protobuf:"varint,3,opt,name=LastBlockInFile,proto3" json:"LastBlockInFile,omitempty"`
	BlockIPs        []string `protobuf:"bytes,4,rep,name=BlockIPs,proto3" json:"BlockIPs,omitempty"`
	// contains filtered or unexported fields
}

BlockIP is the IP of block

func (*BlockInfoProto) Descriptor deprecated 

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

Deprecated: Use BlockInfoProto.ProtoReflect.Descriptor instead.

func (*BlockInfoProto) GetBlockIPs 

func (x *BlockInfoProto) GetBlockIPs() []string

func (*BlockInfoProto) GetBlockIndex 

func (x *BlockInfoProto) GetBlockIndex() uint32

func (*BlockInfoProto) GetFilePathInFS 

func (x *BlockInfoProto) GetFilePathInFS() string

func (*BlockInfoProto) GetLastBlockInFile 

func (x *BlockInfoProto) GetLastBlockInFile() bool

func (*BlockInfoProto) ProtoMessage 

func (*BlockInfoProto) ProtoMessage()

func (*BlockInfoProto) ProtoReflect 

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

func (*BlockInfoProto) Reset 

func (x *BlockInfoProto) Reset()

func (*BlockInfoProto) String 

func (x *BlockInfoProto) String() string

type ChunkProto 

type ChunkProto struct {
	Checksum uint32 `protobuf:"varint,1,opt,name=Checksum,proto3" json:"Checksum,omitempty"`
	Content  []byte `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	// contains filtered or unexported fields
}

Chunk(516 bytes) = checksum(4 bytes) + content(512 bytes)

func (*ChunkProto) Descriptor deprecated 

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

Deprecated: Use ChunkProto.ProtoReflect.Descriptor instead.

func (*ChunkProto) GetChecksum 

func (x *ChunkProto) GetChecksum() uint32

func (*ChunkProto) GetContent 

func (x *ChunkProto) GetContent() []byte

func (*ChunkProto) ProtoMessage 

func (*ChunkProto) ProtoMessage()

func (*ChunkProto) ProtoReflect 

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

func (*ChunkProto) Reset 

func (x *ChunkProto) Reset()

func (*ChunkProto) String 

func (x *ChunkProto) String() string

type ClientNameNodeClient 

type ClientNameNodeClient interface {
	GetFileBlocksLocation(ctx context.Context, in *GetFileBlocksLocationRequestProto, opts ...grpc.CallOption) (*GetFileBlocksLocationResponseProto, error)
	CreateFile(ctx context.Context, in *CreateFileRequestProto, opts ...grpc.CallOption) (*CreateFileResponseProto, error)
	DeleteFile(ctx context.Context, in *DeleteFileRequestProto, opts ...grpc.CallOption) (*DeleteFileResponseProto, error)
}

ClientNameNodeClient is the client API for ClientNameNode service.

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

func NewClientNameNodeClient 

func NewClientNameNodeClient(cc grpc.ClientConnInterface) ClientNameNodeClient

type ClientNameNodeServer 

type ClientNameNodeServer interface {
	GetFileBlocksLocation(context.Context, *GetFileBlocksLocationRequestProto) (*GetFileBlocksLocationResponseProto, error)
	CreateFile(context.Context, *CreateFileRequestProto) (*CreateFileResponseProto, error)
	DeleteFile(context.Context, *DeleteFileRequestProto) (*DeleteFileResponseProto, error)
}

ClientNameNodeServer is the server API for ClientNameNode service.

type ClientOperationHeaderProto 

type ClientOperationHeaderProto struct {
	Block    *ExtendedBlockInfoProto `protobuf:"bytes,1,opt,name=Block,proto3" json:"Block,omitempty"`
	ClientIP string                  `protobuf:"bytes,2,opt,name=ClientIP,proto3" json:"ClientIP,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientOperationHeaderProto) Descriptor deprecated 

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

Deprecated: Use ClientOperationHeaderProto.ProtoReflect.Descriptor instead.

func (*ClientOperationHeaderProto) GetBlock 

func (x *ClientOperationHeaderProto) GetBlock() *ExtendedBlockInfoProto

func (*ClientOperationHeaderProto) GetClientIP 

func (x *ClientOperationHeaderProto) GetClientIP() string

func (*ClientOperationHeaderProto) ProtoMessage 

func (*ClientOperationHeaderProto) ProtoMessage()

func (*ClientOperationHeaderProto) ProtoReflect 

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

func (*ClientOperationHeaderProto) Reset 

func (x *ClientOperationHeaderProto) Reset()

func (*ClientOperationHeaderProto) String 

func (x *ClientOperationHeaderProto) String() string

type ClientReadBlockProto 

type ClientReadBlockProto struct {
	Header *ClientOperationHeaderProto `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	Offset uint32                      `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Length uint32                      `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientReadBlockProto) Descriptor deprecated 

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

Deprecated: Use ClientReadBlockProto.ProtoReflect.Descriptor instead.

func (*ClientReadBlockProto) GetHeader 

func (x *ClientReadBlockProto) GetHeader() *ClientOperationHeaderProto

func (*ClientReadBlockProto) GetLength 

func (x *ClientReadBlockProto) GetLength() uint32

func (*ClientReadBlockProto) GetOffset 

func (x *ClientReadBlockProto) GetOffset() uint32

func (*ClientReadBlockProto) ProtoMessage 

func (*ClientReadBlockProto) ProtoMessage()

func (*ClientReadBlockProto) ProtoReflect 

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

func (*ClientReadBlockProto) Reset 

func (x *ClientReadBlockProto) Reset()

func (*ClientReadBlockProto) String 

func (x *ClientReadBlockProto) String() string

type ClientWriteBlockProto 

type ClientWriteBlockProto struct {
	Header *ClientOperationHeaderProto `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	// for Client send this proto(ClientWriteBlockProto)
	// thus, the first elem in Targets is the first DataNode
	Targets []*DataNodeIDProto `protobuf:"bytes,2,rep,name=Targets,proto3" json:"Targets,omitempty"`
	// BlockIdInSFS will be written into DataNode,
	// in order to serve for heart-beat.
	BlockIdInSFS uint32                               `protobuf:"varint,3,opt,name=BlockIdInSFS,proto3" json:"BlockIdInSFS,omitempty"`
	Status       ClientWriteBlockProto_PipelineStatus `protobuf:"varint,4,opt,name=Status,proto3,enum=proto.ClientWriteBlockProto_PipelineStatus" json:"Status,omitempty"`
	PipelineSize uint32                               `protobuf:"varint,5,opt,name=PipelineSize,proto3" json:"PipelineSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientWriteBlockProto) Descriptor deprecated 

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

Deprecated: Use ClientWriteBlockProto.ProtoReflect.Descriptor instead.

func (*ClientWriteBlockProto) GetBlockIdInSFS 

func (x *ClientWriteBlockProto) GetBlockIdInSFS() uint32

func (*ClientWriteBlockProto) GetHeader 

func (x *ClientWriteBlockProto) GetHeader() *ClientOperationHeaderProto

func (*ClientWriteBlockProto) GetPipelineSize 

func (x *ClientWriteBlockProto) GetPipelineSize() uint32

func (*ClientWriteBlockProto) GetStatus 

func (x *ClientWriteBlockProto) GetStatus() ClientWriteBlockProto_PipelineStatus

func (*ClientWriteBlockProto) GetTargets 

func (x *ClientWriteBlockProto) GetTargets() []*DataNodeIDProto

func (*ClientWriteBlockProto) ProtoMessage 

func (*ClientWriteBlockProto) ProtoMessage()

func (*ClientWriteBlockProto) ProtoReflect 

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

func (*ClientWriteBlockProto) Reset 

func (x *ClientWriteBlockProto) Reset()

func (*ClientWriteBlockProto) String 

func (x *ClientWriteBlockProto) String() string

type ClientWriteBlockProto_PipelineStatus 

type ClientWriteBlockProto_PipelineStatus int32
const (
	ClientWriteBlockProto_PIPELINE_SETUP_APPEND   ClientWriteBlockProto_PipelineStatus = 0 // is setting up
	ClientWriteBlockProto_PIPELINE_DATA_STREAMING ClientWriteBlockProto_PipelineStatus = 1 // work well
	ClientWriteBlockProto_PIPELINE_CLOSE          ClientWriteBlockProto_PipelineStatus = 2 // pipeline end working
)

func (ClientWriteBlockProto_PipelineStatus) Descriptor 

func (ClientWriteBlockProto_PipelineStatus) Descriptor() protoreflect.EnumDescriptor

func (ClientWriteBlockProto_PipelineStatus) Enum 

func (x ClientWriteBlockProto_PipelineStatus) Enum() *ClientWriteBlockProto_PipelineStatus

func (ClientWriteBlockProto_PipelineStatus) EnumDescriptor deprecated 

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

Deprecated: Use ClientWriteBlockProto_PipelineStatus.Descriptor instead.

func (ClientWriteBlockProto_PipelineStatus) Number 

func (x ClientWriteBlockProto_PipelineStatus) Number() protoreflect.EnumNumber

func (ClientWriteBlockProto_PipelineStatus) String 

func (x ClientWriteBlockProto_PipelineStatus) String() string

func (ClientWriteBlockProto_PipelineStatus) Type 

func (ClientWriteBlockProto_PipelineStatus) Type() protoreflect.EnumType

type CreateFileRequestProto 

type CreateFileRequestProto struct {
	FilePath string `protobuf:"bytes,1,opt,name=FilePath,proto3" json:"FilePath,omitempty"`
	BlockNum uint32 `protobuf:"varint,2,opt,name=BlockNum,proto3" json:"BlockNum,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileRequestProto) Descriptor deprecated 

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

Deprecated: Use CreateFileRequestProto.ProtoReflect.Descriptor instead.

func (*CreateFileRequestProto) GetBlockNum 

func (x *CreateFileRequestProto) GetBlockNum() uint32

func (*CreateFileRequestProto) GetFilePath 

func (x *CreateFileRequestProto) GetFilePath() string

func (*CreateFileRequestProto) ProtoMessage 

func (*CreateFileRequestProto) ProtoMessage()

func (*CreateFileRequestProto) ProtoReflect 

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

func (*CreateFileRequestProto) Reset 

func (x *CreateFileRequestProto) Reset()

func (*CreateFileRequestProto) String 

func (x *CreateFileRequestProto) String() string

type CreateFileResponseProto 

type CreateFileResponseProto struct {
	Result string `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	// BlocksIdInSFS represents Blocks in SFS
	// its number according to CreateFileRequestProto.BlockNum
	BlocksIdInSFS []uint32 `protobuf:"varint,2,rep,packed,name=BlocksIdInSFS,proto3" json:"BlocksIdInSFS,omitempty"`
	// Client will get DataNodes' detail in order to begin writing
	DataNodes []*DataNodeInfoProto `protobuf:"bytes,3,rep,name=DataNodes,proto3" json:"DataNodes,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileResponseProto) Descriptor deprecated 

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

Deprecated: Use CreateFileResponseProto.ProtoReflect.Descriptor instead.

func (*CreateFileResponseProto) GetBlocksIdInSFS 

func (x *CreateFileResponseProto) GetBlocksIdInSFS() []uint32

func (*CreateFileResponseProto) GetDataNodes 

func (x *CreateFileResponseProto) GetDataNodes() []*DataNodeInfoProto

func (*CreateFileResponseProto) GetResult 

func (x *CreateFileResponseProto) GetResult() string

func (*CreateFileResponseProto) ProtoMessage 

func (*CreateFileResponseProto) ProtoMessage()

func (*CreateFileResponseProto) ProtoReflect 

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

func (*CreateFileResponseProto) Reset 

func (x *CreateFileResponseProto) Reset()

func (*CreateFileResponseProto) String 

func (x *CreateFileResponseProto) String() string

type DataNodeBlockInfoProto 

type DataNodeBlockInfoProto struct {
	BlockIdInSFS uint32 `protobuf:"varint,1,opt,name=BlockIdInSFS,proto3" json:"BlockIdInSFS,omitempty"`
	// BlockName = Prefix + Body
	BlockNamePrefix   string `protobuf:"bytes,2,opt,name=BlockNamePrefix,proto3" json:"BlockNamePrefix,omitempty"`
	BlockNameBody     string `protobuf:"bytes,3,opt,name=BlockNameBody,proto3" json:"BlockNameBody,omitempty"`
	BlockFailed       bool   `protobuf:"varint,4,opt,name=BlockFailed,proto3" json:"BlockFailed,omitempty"`
	BlockOffsetInFile uint32 `protobuf:"varint,5,opt,name=BlockOffsetInFile,proto3" json:"BlockOffsetInFile,omitempty"`
	// contains filtered or unexported fields
}

DataNodeBlockInfo represents only one Block in DataNode. This Proto do not need FileName of each Block. DataNode only maintain "Blocks", reporting its status. Service (FilePath/Name => Blocks) is provided in NameNode.

func (*DataNodeBlockInfoProto) Descriptor deprecated 

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

Deprecated: Use DataNodeBlockInfoProto.ProtoReflect.Descriptor instead.

func (*DataNodeBlockInfoProto) GetBlockFailed 

func (x *DataNodeBlockInfoProto) GetBlockFailed() bool

func (*DataNodeBlockInfoProto) GetBlockIdInSFS 

func (x *DataNodeBlockInfoProto) GetBlockIdInSFS() uint32

func (*DataNodeBlockInfoProto) GetBlockNameBody 

func (x *DataNodeBlockInfoProto) GetBlockNameBody() string

func (*DataNodeBlockInfoProto) GetBlockNamePrefix 

func (x *DataNodeBlockInfoProto) GetBlockNamePrefix() string

func (*DataNodeBlockInfoProto) GetBlockOffsetInFile 

func (x *DataNodeBlockInfoProto) GetBlockOffsetInFile() uint32

func (*DataNodeBlockInfoProto) ProtoMessage 

func (*DataNodeBlockInfoProto) ProtoMessage()

func (*DataNodeBlockInfoProto) ProtoReflect 

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

func (*DataNodeBlockInfoProto) Reset 

func (x *DataNodeBlockInfoProto) Reset()

func (*DataNodeBlockInfoProto) String 

func (x *DataNodeBlockInfoProto) String() string

type DataNodeIDProto 

type DataNodeIDProto struct {
	IP           string `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Host         string `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	TransferPort uint32 `protobuf:"varint,3,opt,name=TransferPort,proto3" json:"TransferPort,omitempty"`
	InfoPort     uint32 `protobuf:"varint,4,opt,name=InfoPort,proto3" json:"InfoPort,omitempty"`
	// contains filtered or unexported fields
}

func (*DataNodeIDProto) Descriptor deprecated 

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

Deprecated: Use DataNodeIDProto.ProtoReflect.Descriptor instead.

func (*DataNodeIDProto) GetHost 

func (x *DataNodeIDProto) GetHost() string

func (*DataNodeIDProto) GetIP 

func (x *DataNodeIDProto) GetIP() string

func (*DataNodeIDProto) GetInfoPort 

func (x *DataNodeIDProto) GetInfoPort() uint32

func (*DataNodeIDProto) GetTransferPort 

func (x *DataNodeIDProto) GetTransferPort() uint32

func (*DataNodeIDProto) ProtoMessage 

func (*DataNodeIDProto) ProtoMessage()

func (*DataNodeIDProto) ProtoReflect 

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

func (*DataNodeIDProto) Reset 

func (x *DataNodeIDProto) Reset()

func (*DataNodeIDProto) String 

func (x *DataNodeIDProto) String() string

type DataNodeInfoProto 

type DataNodeInfoProto struct {
	ID             *DataNodeIDProto `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	BlocksTotalNum uint32           `protobuf:"varint,2,opt,name=BlocksTotalNum,proto3" json:"BlocksTotalNum,omitempty"` // BlocksTotalNum is capacity of blcks in DataNode
	BlocksUsedNum  uint32           `protobuf:"varint,3,opt,name=BlocksUsedNum,proto3" json:"BlocksUsedNum,omitempty"`   // BlocksUsedNum is the number of used blocks in DataNode
	// contains filtered or unexported fields
}

func (*DataNodeInfoProto) Descriptor deprecated 

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

Deprecated: Use DataNodeInfoProto.ProtoReflect.Descriptor instead.

func (*DataNodeInfoProto) GetBlocksTotalNum 

func (x *DataNodeInfoProto) GetBlocksTotalNum() uint32

func (*DataNodeInfoProto) GetBlocksUsedNum 

func (x *DataNodeInfoProto) GetBlocksUsedNum() uint32

func (*DataNodeInfoProto) GetID 

func (x *DataNodeInfoProto) GetID() *DataNodeIDProto

func (*DataNodeInfoProto) ProtoMessage 

func (*DataNodeInfoProto) ProtoMessage()

func (*DataNodeInfoProto) ProtoReflect 

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

func (*DataNodeInfoProto) Reset 

func (x *DataNodeInfoProto) Reset()

func (*DataNodeInfoProto) String 

func (x *DataNodeInfoProto) String() string

type DataNodeNameNodeClient 

type DataNodeNameNodeClient interface {
	RegisterDataNode(ctx context.Context, in *RegisterDataNodeRequestProto, opts ...grpc.CallOption) (*RegisterDataNodeResponseProto, error)
	SendHeartbeat(ctx context.Context, in *HeartbeatRequestProto, opts ...grpc.CallOption) (*HeartbeatResponseProto, error)
}

DataNodeNameNodeClient is the client API for DataNodeNameNode service.

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

func NewDataNodeNameNodeClient 

func NewDataNodeNameNodeClient(cc grpc.ClientConnInterface) DataNodeNameNodeClient

type DataNodeNameNodeServer 

type DataNodeNameNodeServer interface {
	RegisterDataNode(context.Context, *RegisterDataNodeRequestProto) (*RegisterDataNodeResponseProto, error)
	SendHeartbeat(context.Context, *HeartbeatRequestProto) (*HeartbeatResponseProto, error)
}

DataNodeNameNodeServer is the server API for DataNodeNameNode service.

type DataNodeRegistrationProto 

type DataNodeRegistrationProto struct {
	ID      *DataNodeIDProto    `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Storage *StorageReportProto `protobuf:"bytes,2,opt,name=Storage,proto3" json:"Storage,omitempty"`
	// contains filtered or unexported fields
}

func (*DataNodeRegistrationProto) Descriptor deprecated 

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

Deprecated: Use DataNodeRegistrationProto.ProtoReflect.Descriptor instead.

func (*DataNodeRegistrationProto) GetID 

func (x *DataNodeRegistrationProto) GetID() *DataNodeIDProto

func (*DataNodeRegistrationProto) GetStorage 

func (x *DataNodeRegistrationProto) GetStorage() *StorageReportProto

func (*DataNodeRegistrationProto) ProtoMessage 

func (*DataNodeRegistrationProto) ProtoMessage()

func (*DataNodeRegistrationProto) ProtoReflect 

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

func (*DataNodeRegistrationProto) Reset 

func (x *DataNodeRegistrationProto) Reset()

func (*DataNodeRegistrationProto) String 

func (x *DataNodeRegistrationProto) String() string

type DataNodeTransferBlockProto 

type DataNodeTransferBlockProto struct {
	Header *ClientOperationHeaderProto `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	// the first elem in Targets is the next DataNode
	Targets []*DataNodeIDProto `protobuf:"bytes,2,rep,name=Targets,proto3" json:"Targets,omitempty"`
	// contains filtered or unexported fields
}

func (*DataNodeTransferBlockProto) Descriptor deprecated 

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

Deprecated: Use DataNodeTransferBlockProto.ProtoReflect.Descriptor instead.

func (*DataNodeTransferBlockProto) GetHeader 

func (x *DataNodeTransferBlockProto) GetHeader() *ClientOperationHeaderProto

func (*DataNodeTransferBlockProto) GetTargets 

func (x *DataNodeTransferBlockProto) GetTargets() []*DataNodeIDProto

func (*DataNodeTransferBlockProto) ProtoMessage 

func (*DataNodeTransferBlockProto) ProtoMessage()

func (*DataNodeTransferBlockProto) ProtoReflect 

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

func (*DataNodeTransferBlockProto) Reset 

func (x *DataNodeTransferBlockProto) Reset()

func (*DataNodeTransferBlockProto) String 

func (x *DataNodeTransferBlockProto) String() string

type DeleteFileRequestProto 

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

func (*DeleteFileRequestProto) Descriptor deprecated 

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

Deprecated: Use DeleteFileRequestProto.ProtoReflect.Descriptor instead.

func (*DeleteFileRequestProto) GetFilePath 

func (x *DeleteFileRequestProto) GetFilePath() string

func (*DeleteFileRequestProto) ProtoMessage 

func (*DeleteFileRequestProto) ProtoMessage()

func (*DeleteFileRequestProto) ProtoReflect 

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

func (*DeleteFileRequestProto) Reset 

func (x *DeleteFileRequestProto) Reset()

func (*DeleteFileRequestProto) String 

func (x *DeleteFileRequestProto) String() string

type DeleteFileResponseProto 

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

func (*DeleteFileResponseProto) Descriptor deprecated 

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

Deprecated: Use DeleteFileResponseProto.ProtoReflect.Descriptor instead.

func (*DeleteFileResponseProto) GetResult 

func (x *DeleteFileResponseProto) GetResult() string

func (*DeleteFileResponseProto) ProtoMessage 

func (*DeleteFileResponseProto) ProtoMessage()

func (*DeleteFileResponseProto) ProtoReflect 

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

func (*DeleteFileResponseProto) Reset 

func (x *DeleteFileResponseProto) Reset()

func (*DeleteFileResponseProto) String 

func (x *DeleteFileResponseProto) String() string

type ExtendedBlockInfoProto 

type ExtendedBlockInfoProto struct {
	BlockId uint32 `protobuf:"varint,1,opt,name=BlockId,proto3" json:"BlockId,omitempty"` // the local id in local machine
	// contains filtered or unexported fields
}

func (*ExtendedBlockInfoProto) Descriptor deprecated 

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

Deprecated: Use ExtendedBlockInfoProto.ProtoReflect.Descriptor instead.

func (*ExtendedBlockInfoProto) GetBlockId 

func (x *ExtendedBlockInfoProto) GetBlockId() uint32

func (*ExtendedBlockInfoProto) ProtoMessage 

func (*ExtendedBlockInfoProto) ProtoMessage()

func (*ExtendedBlockInfoProto) ProtoReflect 

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

func (*ExtendedBlockInfoProto) Reset 

func (x *ExtendedBlockInfoProto) Reset()

func (*ExtendedBlockInfoProto) String 

func (x *ExtendedBlockInfoProto) String() string

type GetFileBlocksLocationRequestProto 

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

func (*GetFileBlocksLocationRequestProto) Descriptor deprecated 

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

Deprecated: Use GetFileBlocksLocationRequestProto.ProtoReflect.Descriptor instead.

func (*GetFileBlocksLocationRequestProto) GetFilePath 

func (x *GetFileBlocksLocationRequestProto) GetFilePath() string

func (*GetFileBlocksLocationRequestProto) ProtoMessage 

func (*GetFileBlocksLocationRequestProto) ProtoMessage()

func (*GetFileBlocksLocationRequestProto) ProtoReflect 

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

func (*GetFileBlocksLocationRequestProto) Reset 

func (x *GetFileBlocksLocationRequestProto) Reset()

func (*GetFileBlocksLocationRequestProto) String 

func (x *GetFileBlocksLocationRequestProto) String() string

type GetFileBlocksLocationResponseProto 

type GetFileBlocksLocationResponseProto struct {
	Blocks []*BlockInfoProto `protobuf:"bytes,1,rep,name=Blocks,proto3" json:"Blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileBlocksLocationResponseProto) Descriptor deprecated 

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

Deprecated: Use GetFileBlocksLocationResponseProto.ProtoReflect.Descriptor instead.

func (*GetFileBlocksLocationResponseProto) GetBlocks 

func (x *GetFileBlocksLocationResponseProto) GetBlocks() []*BlockInfoProto

func (*GetFileBlocksLocationResponseProto) ProtoMessage 

func (*GetFileBlocksLocationResponseProto) ProtoMessage()

func (*GetFileBlocksLocationResponseProto) ProtoReflect 

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

func (*GetFileBlocksLocationResponseProto) Reset 

func (x *GetFileBlocksLocationResponseProto) Reset()

func (*GetFileBlocksLocationResponseProto) String 

func (x *GetFileBlocksLocationResponseProto) String() string

type HeartbeatRequestProto 

type HeartbeatRequestProto struct {
	DataNodeID *DataNodeIDProto          `protobuf:"bytes,1,opt,name=DataNodeID,proto3" json:"DataNodeID,omitempty"`
	BlocksInfo []*DataNodeBlockInfoProto `protobuf:"bytes,2,rep,name=BlocksInfo,proto3" json:"BlocksInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequestProto) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequestProto.ProtoReflect.Descriptor instead.

func (*HeartbeatRequestProto) GetBlocksInfo 

func (x *HeartbeatRequestProto) GetBlocksInfo() []*DataNodeBlockInfoProto

func (*HeartbeatRequestProto) GetDataNodeID 

func (x *HeartbeatRequestProto) GetDataNodeID() *DataNodeIDProto

func (*HeartbeatRequestProto) ProtoMessage 

func (*HeartbeatRequestProto) ProtoMessage()

func (*HeartbeatRequestProto) ProtoReflect 

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

func (*HeartbeatRequestProto) Reset 

func (x *HeartbeatRequestProto) Reset()

func (*HeartbeatRequestProto) String 

func (x *HeartbeatRequestProto) String() string

type HeartbeatResponseProto 

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

func (*HeartbeatResponseProto) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponseProto.ProtoReflect.Descriptor instead.

func (*HeartbeatResponseProto) GetResult 

func (x *HeartbeatResponseProto) GetResult() string

func (*HeartbeatResponseProto) ProtoMessage 

func (*HeartbeatResponseProto) ProtoMessage()

func (*HeartbeatResponseProto) ProtoReflect 

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

func (*HeartbeatResponseProto) Reset 

func (x *HeartbeatResponseProto) Reset()

func (*HeartbeatResponseProto) String 

func (x *HeartbeatResponseProto) String() string

type PacketHeaderProto 

type PacketHeaderProto struct {
	OffsetInBlock     uint64 `protobuf:"varint,1,opt,name=OffsetInBlock,proto3" json:"OffsetInBlock,omitempty"`
	SeqNo             uint32 `protobuf:"varint,2,opt,name=SeqNo,proto3" json:"SeqNo,omitempty"`
	LastPacketInBlock bool   `protobuf:"varint,3,opt,name=LastPacketInBlock,proto3" json:"LastPacketInBlock,omitempty"`
	DataLen           uint32 `protobuf:"varint,4,opt,name=DataLen,proto3" json:"DataLen,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketHeaderProto) Descriptor deprecated 

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

Deprecated: Use PacketHeaderProto.ProtoReflect.Descriptor instead.

func (*PacketHeaderProto) GetDataLen 

func (x *PacketHeaderProto) GetDataLen() uint32

func (*PacketHeaderProto) GetLastPacketInBlock 

func (x *PacketHeaderProto) GetLastPacketInBlock() bool

func (*PacketHeaderProto) GetOffsetInBlock 

func (x *PacketHeaderProto) GetOffsetInBlock() uint64

func (*PacketHeaderProto) GetSeqNo 

func (x *PacketHeaderProto) GetSeqNo() uint32

func (*PacketHeaderProto) ProtoMessage 

func (*PacketHeaderProto) ProtoMessage()

func (*PacketHeaderProto) ProtoReflect 

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

func (*PacketHeaderProto) Reset 

func (x *PacketHeaderProto) Reset()

func (*PacketHeaderProto) String 

func (x *PacketHeaderProto) String() string

type PacketProto 

type PacketProto struct {
	Header     *PacketHeaderProto `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	PacketData []*ChunkProto      `protobuf:"bytes,2,rep,name=PacketData,proto3" json:"PacketData,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketProto) Descriptor deprecated 

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

Deprecated: Use PacketProto.ProtoReflect.Descriptor instead.

func (*PacketProto) GetHeader 

func (x *PacketProto) GetHeader() *PacketHeaderProto

func (*PacketProto) GetPacketData 

func (x *PacketProto) GetPacketData() []*ChunkProto

func (*PacketProto) ProtoMessage 

func (*PacketProto) ProtoMessage()

func (*PacketProto) ProtoReflect 

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

func (*PacketProto) Reset 

func (x *PacketProto) Reset()

func (*PacketProto) String 

func (x *PacketProto) String() string

type PipelineAckProto 

type PipelineAckProto struct {
	SeqNo uint32   `protobuf:"varint,1,opt,name=SeqNo,proto3" json:"SeqNo,omitempty"`
	Reply []Status `protobuf:"varint,2,rep,packed,name=Reply,proto3,enum=proto.Status" json:"Reply,omitempty"` // append the former ACK.Reply
	// contains filtered or unexported fields
}

func (*PipelineAckProto) Descriptor deprecated 

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

Deprecated: Use PipelineAckProto.ProtoReflect.Descriptor instead.

func (*PipelineAckProto) GetReply 

func (x *PipelineAckProto) GetReply() []Status

func (*PipelineAckProto) GetSeqNo 

func (x *PipelineAckProto) GetSeqNo() uint32

func (*PipelineAckProto) ProtoMessage 

func (*PipelineAckProto) ProtoMessage()

func (*PipelineAckProto) ProtoReflect 

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

func (*PipelineAckProto) Reset 

func (x *PipelineAckProto) Reset()

func (*PipelineAckProto) String 

func (x *PipelineAckProto) String() string

type RegisterDataNodeRequestProto 

type RegisterDataNodeRequestProto struct {
	Registration *DataNodeRegistrationProto `protobuf:"bytes,1,opt,name=Registration,proto3" json:"Registration,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterDataNodeRequestProto) Descriptor deprecated 

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

Deprecated: Use RegisterDataNodeRequestProto.ProtoReflect.Descriptor instead.

func (*RegisterDataNodeRequestProto) GetRegistration 

func (x *RegisterDataNodeRequestProto) GetRegistration() *DataNodeRegistrationProto

func (*RegisterDataNodeRequestProto) ProtoMessage 

func (*RegisterDataNodeRequestProto) ProtoMessage()

func (*RegisterDataNodeRequestProto) ProtoReflect 

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

func (*RegisterDataNodeRequestProto) Reset 

func (x *RegisterDataNodeRequestProto) Reset()

func (*RegisterDataNodeRequestProto) String 

func (x *RegisterDataNodeRequestProto) String() string

type RegisterDataNodeResponseProto 

type RegisterDataNodeResponseProto struct {
	Registration *DataNodeRegistrationProto `protobuf:"bytes,1,opt,name=Registration,proto3" json:"Registration,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterDataNodeResponseProto) Descriptor deprecated 

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

Deprecated: Use RegisterDataNodeResponseProto.ProtoReflect.Descriptor instead.

func (*RegisterDataNodeResponseProto) GetRegistration 

func (x *RegisterDataNodeResponseProto) GetRegistration() *DataNodeRegistrationProto

func (*RegisterDataNodeResponseProto) ProtoMessage 

func (*RegisterDataNodeResponseProto) ProtoMessage()

func (*RegisterDataNodeResponseProto) ProtoReflect 

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

func (*RegisterDataNodeResponseProto) Reset 

func (x *RegisterDataNodeResponseProto) Reset()

func (*RegisterDataNodeResponseProto) String 

func (x *RegisterDataNodeResponseProto) String() string

type Status 

type Status int32
const (
	Status_SUCCESS        Status = 0
	Status_ERROR          Status = 1
	Status_ERROR_CHECKSUM Status = 2
	Status_ERROR_EXISTS   Status = 4
	Status_CHECKSUM_OK    Status = 6
	Status_IN_PROGRESS    Status = 12
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type StorageReportProto 

type StorageReportProto struct {
	BlocksTotalNum uint32 `protobuf:"varint,1,opt,name=BlocksTotalNum,proto3" json:"BlocksTotalNum,omitempty"`
	BlocksUsedNum  uint32 `protobuf:"varint,2,opt,name=BlocksUsedNum,proto3" json:"BlocksUsedNum,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageReportProto) Descriptor deprecated 

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

Deprecated: Use StorageReportProto.ProtoReflect.Descriptor instead.

func (*StorageReportProto) GetBlocksTotalNum 

func (x *StorageReportProto) GetBlocksTotalNum() uint32

func (*StorageReportProto) GetBlocksUsedNum 

func (x *StorageReportProto) GetBlocksUsedNum() uint32

func (*StorageReportProto) ProtoMessage 

func (*StorageReportProto) ProtoMessage()

func (*StorageReportProto) ProtoReflect 

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

func (*StorageReportProto) Reset 

func (x *StorageReportProto) Reset()

func (*StorageReportProto) String 

func (x *StorageReportProto) String() string

type UnimplementedClientNameNodeServer 

type UnimplementedClientNameNodeServer struct {
}

UnimplementedClientNameNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedClientNameNodeServer) CreateFile 

func (*UnimplementedClientNameNodeServer) CreateFile(context.Context, *CreateFileRequestProto) (*CreateFileResponseProto, error)

func (*UnimplementedClientNameNodeServer) DeleteFile 

func (*UnimplementedClientNameNodeServer) DeleteFile(context.Context, *DeleteFileRequestProto) (*DeleteFileResponseProto, error)

func (*UnimplementedClientNameNodeServer) GetFileBlocksLocation 

func (*UnimplementedClientNameNodeServer) GetFileBlocksLocation(context.Context, *GetFileBlocksLocationRequestProto) (*GetFileBlocksLocationResponseProto, error)

type UnimplementedDataNodeNameNodeServer 

type UnimplementedDataNodeNameNodeServer struct {
}

UnimplementedDataNodeNameNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataNodeNameNodeServer) RegisterDataNode 

func (*UnimplementedDataNodeNameNodeServer) RegisterDataNode(context.Context, *RegisterDataNodeRequestProto) (*RegisterDataNodeResponseProto, error)

func (*UnimplementedDataNodeNameNodeServer) SendHeartbeat 

func (*UnimplementedDataNodeNameNodeServer) SendHeartbeat(context.Context, *HeartbeatRequestProto) (*HeartbeatResponseProto, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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