hadoop_hdfs_namenode

package
v0.0.0-...-58217a2 Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2014 License: Apache-2.0 Imports: 3 Imported by: 1

Documentation

Overview

Package hadoop_hdfs_namenode is a generated protocol buffer package.

It is generated from these files:

NamenodeProtocol.proto

It has these top-level messages:

GetBlocksRequestProto
GetBlocksResponseProto
GetBlockKeysRequestProto
GetBlockKeysResponseProto
GetTransactionIdRequestProto
GetTransactionIdResponseProto
RollEditLogRequestProto
RollEditLogResponseProto
GetMostRecentCheckpointTxIdRequestProto
GetMostRecentCheckpointTxIdResponseProto
ErrorReportRequestProto
ErrorReportResponseProto
RegisterRequestProto
RegisterResponseProto
StartCheckpointRequestProto
StartCheckpointResponseProto
EndCheckpointRequestProto
EndCheckpointResponseProto
GetEditLogManifestRequestProto
GetEditLogManifestResponseProto

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EndCheckpointRequestProto

type EndCheckpointRequestProto struct {
	Registration     *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	Signature        *hadoop_hdfs.CheckpointSignatureProto  `protobuf:"bytes,2,req,name=signature" json:"signature,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

* End or finalize the previously started checkpoint registration - Namenode that is ending the checkpoint signature - unique token to identify checkpoint transaction,

that was received when checkpoint was started.

func (*EndCheckpointRequestProto) GetRegistration

func (*EndCheckpointRequestProto) GetSignature

func (*EndCheckpointRequestProto) ProtoMessage

func (*EndCheckpointRequestProto) ProtoMessage()

func (*EndCheckpointRequestProto) Reset

func (m *EndCheckpointRequestProto) Reset()

func (*EndCheckpointRequestProto) String

func (m *EndCheckpointRequestProto) String() string

type EndCheckpointResponseProto

type EndCheckpointResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void response

func (*EndCheckpointResponseProto) ProtoMessage

func (*EndCheckpointResponseProto) ProtoMessage()

func (*EndCheckpointResponseProto) Reset

func (m *EndCheckpointResponseProto) Reset()

func (*EndCheckpointResponseProto) String

func (m *EndCheckpointResponseProto) String() string

type ErrorReportRequestProto

type ErrorReportRequestProto struct {
	Registration     *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	ErrorCode        *uint32                                `protobuf:"varint,2,req,name=errorCode" json:"errorCode,omitempty"`
	Msg              *string                                `protobuf:"bytes,3,req,name=msg" json:"msg,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

* registration - Namenode reporting the error errorCode - error code indicating the error msg - Free text description of the error

func (*ErrorReportRequestProto) GetErrorCode

func (m *ErrorReportRequestProto) GetErrorCode() uint32

func (*ErrorReportRequestProto) GetMsg

func (m *ErrorReportRequestProto) GetMsg() string

func (*ErrorReportRequestProto) GetRegistration

func (*ErrorReportRequestProto) ProtoMessage

func (*ErrorReportRequestProto) ProtoMessage()

func (*ErrorReportRequestProto) Reset

func (m *ErrorReportRequestProto) Reset()

func (*ErrorReportRequestProto) String

func (m *ErrorReportRequestProto) String() string

type ErrorReportResponseProto

type ErrorReportResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void response

func (*ErrorReportResponseProto) ProtoMessage

func (*ErrorReportResponseProto) ProtoMessage()

func (*ErrorReportResponseProto) Reset

func (m *ErrorReportResponseProto) Reset()

func (*ErrorReportResponseProto) String

func (m *ErrorReportResponseProto) String() string

type GetBlockKeysRequestProto

type GetBlockKeysRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void request

func (*GetBlockKeysRequestProto) ProtoMessage

func (*GetBlockKeysRequestProto) ProtoMessage()

func (*GetBlockKeysRequestProto) Reset

func (m *GetBlockKeysRequestProto) Reset()

func (*GetBlockKeysRequestProto) String

func (m *GetBlockKeysRequestProto) String() string

type GetBlockKeysResponseProto

type GetBlockKeysResponseProto struct {
	Keys             *hadoop_hdfs.ExportedBlockKeysProto `protobuf:"bytes,1,opt,name=keys" json:"keys,omitempty"`
	XXX_unrecognized []byte                              `json:"-"`
}

* keys - Information about block keys at the active namenode

func (*GetBlockKeysResponseProto) GetKeys

func (*GetBlockKeysResponseProto) ProtoMessage

func (*GetBlockKeysResponseProto) ProtoMessage()

func (*GetBlockKeysResponseProto) Reset

func (m *GetBlockKeysResponseProto) Reset()

func (*GetBlockKeysResponseProto) String

func (m *GetBlockKeysResponseProto) String() string

type GetBlocksRequestProto

type GetBlocksRequestProto struct {
	Datanode         *hadoop_hdfs.DatanodeIDProto `protobuf:"bytes,1,req,name=datanode" json:"datanode,omitempty"`
	Size             *uint64                      `protobuf:"varint,2,req,name=size" json:"size,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

* Get list of blocks for a given datanode with the total length of adding up to given size datanode - Datanode ID to get list of block from size - size to which the block lengths must add up to

func (*GetBlocksRequestProto) GetDatanode

func (*GetBlocksRequestProto) GetSize

func (m *GetBlocksRequestProto) GetSize() uint64

func (*GetBlocksRequestProto) ProtoMessage

func (*GetBlocksRequestProto) ProtoMessage()

func (*GetBlocksRequestProto) Reset

func (m *GetBlocksRequestProto) Reset()

func (*GetBlocksRequestProto) String

func (m *GetBlocksRequestProto) String() string

type GetBlocksResponseProto

type GetBlocksResponseProto struct {
	Blocks           *hadoop_hdfs.BlocksWithLocationsProto `protobuf:"bytes,1,req,name=blocks" json:"blocks,omitempty"`
	XXX_unrecognized []byte                                `json:"-"`
}

* blocks - List of returned blocks

func (*GetBlocksResponseProto) GetBlocks

func (*GetBlocksResponseProto) ProtoMessage

func (*GetBlocksResponseProto) ProtoMessage()

func (*GetBlocksResponseProto) Reset

func (m *GetBlocksResponseProto) Reset()

func (*GetBlocksResponseProto) String

func (m *GetBlocksResponseProto) String() string

type GetEditLogManifestRequestProto

type GetEditLogManifestRequestProto struct {
	SinceTxId        *uint64 `protobuf:"varint,1,req,name=sinceTxId" json:"sinceTxId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* sinceTxId - return the editlog information for transactions >= sinceTxId

func (*GetEditLogManifestRequestProto) GetSinceTxId

func (m *GetEditLogManifestRequestProto) GetSinceTxId() uint64

func (*GetEditLogManifestRequestProto) ProtoMessage

func (*GetEditLogManifestRequestProto) ProtoMessage()

func (*GetEditLogManifestRequestProto) Reset

func (m *GetEditLogManifestRequestProto) Reset()

func (*GetEditLogManifestRequestProto) String

type GetEditLogManifestResponseProto

type GetEditLogManifestResponseProto struct {
	Manifest         *hadoop_hdfs.RemoteEditLogManifestProto `protobuf:"bytes,1,req,name=manifest" json:"manifest,omitempty"`
	XXX_unrecognized []byte                                  `json:"-"`
}

* manifest - Enumeration of editlogs from namenode for

logs >= sinceTxId in the request

func (*GetEditLogManifestResponseProto) GetManifest

func (*GetEditLogManifestResponseProto) ProtoMessage

func (*GetEditLogManifestResponseProto) ProtoMessage()

func (*GetEditLogManifestResponseProto) Reset

func (*GetEditLogManifestResponseProto) String

type GetMostRecentCheckpointTxIdRequestProto

type GetMostRecentCheckpointTxIdRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void request

func (*GetMostRecentCheckpointTxIdRequestProto) ProtoMessage

func (*GetMostRecentCheckpointTxIdRequestProto) Reset

func (*GetMostRecentCheckpointTxIdRequestProto) String

type GetMostRecentCheckpointTxIdResponseProto

type GetMostRecentCheckpointTxIdResponseProto struct {
	TxId             *uint64 `protobuf:"varint,1,req,name=txId" json:"txId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetMostRecentCheckpointTxIdResponseProto) GetTxId

func (*GetMostRecentCheckpointTxIdResponseProto) ProtoMessage

func (*GetMostRecentCheckpointTxIdResponseProto) Reset

func (*GetMostRecentCheckpointTxIdResponseProto) String

type GetTransactionIdRequestProto

type GetTransactionIdRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void request

func (*GetTransactionIdRequestProto) ProtoMessage

func (*GetTransactionIdRequestProto) ProtoMessage()

func (*GetTransactionIdRequestProto) Reset

func (m *GetTransactionIdRequestProto) Reset()

func (*GetTransactionIdRequestProto) String

type GetTransactionIdResponseProto

type GetTransactionIdResponseProto struct {
	TxId             *uint64 `protobuf:"varint,1,req,name=txId" json:"txId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* txId - Transaction ID of the most recently persisted edit log record

func (*GetTransactionIdResponseProto) GetTxId

func (*GetTransactionIdResponseProto) ProtoMessage

func (*GetTransactionIdResponseProto) ProtoMessage()

func (*GetTransactionIdResponseProto) Reset

func (m *GetTransactionIdResponseProto) Reset()

func (*GetTransactionIdResponseProto) String

type RegisterRequestProto

type RegisterRequestProto struct {
	Registration     *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

* registration - Information of the namenode registering with primary namenode

func (*RegisterRequestProto) GetRegistration

func (*RegisterRequestProto) ProtoMessage

func (*RegisterRequestProto) ProtoMessage()

func (*RegisterRequestProto) Reset

func (m *RegisterRequestProto) Reset()

func (*RegisterRequestProto) String

func (m *RegisterRequestProto) String() string

type RegisterResponseProto

type RegisterResponseProto struct {
	Registration     *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

* registration - Updated registration information of the newly registered

datanode.

func (*RegisterResponseProto) GetRegistration

func (*RegisterResponseProto) ProtoMessage

func (*RegisterResponseProto) ProtoMessage()

func (*RegisterResponseProto) Reset

func (m *RegisterResponseProto) Reset()

func (*RegisterResponseProto) String

func (m *RegisterResponseProto) String() string

type RollEditLogRequestProto

type RollEditLogRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void request

func (*RollEditLogRequestProto) ProtoMessage

func (*RollEditLogRequestProto) ProtoMessage()

func (*RollEditLogRequestProto) Reset

func (m *RollEditLogRequestProto) Reset()

func (*RollEditLogRequestProto) String

func (m *RollEditLogRequestProto) String() string

type RollEditLogResponseProto

type RollEditLogResponseProto struct {
	Signature        *hadoop_hdfs.CheckpointSignatureProto `protobuf:"bytes,1,req,name=signature" json:"signature,omitempty"`
	XXX_unrecognized []byte                                `json:"-"`
}

* signature - A unique token to identify checkpoint transaction

func (*RollEditLogResponseProto) GetSignature

func (*RollEditLogResponseProto) ProtoMessage

func (*RollEditLogResponseProto) ProtoMessage()

func (*RollEditLogResponseProto) Reset

func (m *RollEditLogResponseProto) Reset()

func (*RollEditLogResponseProto) String

func (m *RollEditLogResponseProto) String() string

type StartCheckpointRequestProto

type StartCheckpointRequestProto struct {
	Registration     *hadoop_hdfs.NamenodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

* Start checkpoint request registration - Namenode that is starting the checkpoint

func (*StartCheckpointRequestProto) GetRegistration

func (*StartCheckpointRequestProto) ProtoMessage

func (*StartCheckpointRequestProto) ProtoMessage()

func (*StartCheckpointRequestProto) Reset

func (m *StartCheckpointRequestProto) Reset()

func (*StartCheckpointRequestProto) String

func (m *StartCheckpointRequestProto) String() string

type StartCheckpointResponseProto

type StartCheckpointResponseProto struct {
	Command          *hadoop_hdfs.NamenodeCommandProto `protobuf:"bytes,1,req,name=command" json:"command,omitempty"`
	XXX_unrecognized []byte                            `json:"-"`
}

* command - Command returned by the active namenode to be

be handled by the caller.

func (*StartCheckpointResponseProto) GetCommand

func (*StartCheckpointResponseProto) ProtoMessage

func (*StartCheckpointResponseProto) ProtoMessage()

func (*StartCheckpointResponseProto) Reset

func (m *StartCheckpointResponseProto) Reset()

func (*StartCheckpointResponseProto) String

Jump to

Keyboard shortcuts

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