hadoop_hdfs_qjournal

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: 0

Documentation

Overview

Package hadoop_hdfs_qjournal is a generated protocol buffer package.

It is generated from these files: 

QJournalProtocol.proto

It has these top-level messages: 

JournalIdProto
RequestInfoProto
SegmentStateProto
PersistedRecoveryPaxosData
JournalRequestProto
JournalResponseProto
HeartbeatRequestProto
HeartbeatResponseProto
StartLogSegmentRequestProto
StartLogSegmentResponseProto
FinalizeLogSegmentRequestProto
FinalizeLogSegmentResponseProto
PurgeLogsRequestProto
PurgeLogsResponseProto
IsFormattedRequestProto
IsFormattedResponseProto
DiscardSegmentsRequestProto
DiscardSegmentsResponseProto
GetJournalCTimeRequestProto
GetJournalCTimeResponseProto
DoPreUpgradeRequestProto
DoPreUpgradeResponseProto
DoUpgradeRequestProto
DoUpgradeResponseProto
DoFinalizeRequestProto
DoFinalizeResponseProto
CanRollBackRequestProto
CanRollBackResponseProto
DoRollbackRequestProto
DoRollbackResponseProto
GetJournalStateRequestProto
GetJournalStateResponseProto
FormatRequestProto
FormatResponseProto
NewEpochRequestProto
NewEpochResponseProto
GetEditLogManifestRequestProto
GetEditLogManifestResponseProto
PrepareRecoveryRequestProto
PrepareRecoveryResponseProto
AcceptRecoveryRequestProto
AcceptRecoveryResponseProto

Index

Constants

View Source 
const Default_GetEditLogManifestRequestProto_InProgressOk bool = false

Variables

This section is empty.

Functions

This section is empty.

Types

type AcceptRecoveryRequestProto 

type AcceptRecoveryRequestProto struct {
	ReqInfo *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	// * Details on the segment to recover
	StateToAccept *SegmentStateProto `protobuf:"bytes,2,req,name=stateToAccept" json:"stateToAccept,omitempty"`
	// * The URL from which the log may be copied
	FromURL          *string `protobuf:"bytes,3,req,name=fromURL" json:"fromURL,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* acceptRecovery()

func (*AcceptRecoveryRequestProto) GetFromURL 

func (m *AcceptRecoveryRequestProto) GetFromURL() string

func (*AcceptRecoveryRequestProto) GetReqInfo 

func (m *AcceptRecoveryRequestProto) GetReqInfo() *RequestInfoProto

func (*AcceptRecoveryRequestProto) GetStateToAccept 

func (m *AcceptRecoveryRequestProto) GetStateToAccept() *SegmentStateProto

func (*AcceptRecoveryRequestProto) ProtoMessage 

func (*AcceptRecoveryRequestProto) ProtoMessage()

func (*AcceptRecoveryRequestProto) Reset 

func (m *AcceptRecoveryRequestProto) Reset()

func (*AcceptRecoveryRequestProto) String 

func (m *AcceptRecoveryRequestProto) String() string

type AcceptRecoveryResponseProto 

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

func (*AcceptRecoveryResponseProto) ProtoMessage 

func (*AcceptRecoveryResponseProto) ProtoMessage()

func (*AcceptRecoveryResponseProto) Reset 

func (m *AcceptRecoveryResponseProto) Reset()

func (*AcceptRecoveryResponseProto) String 

func (m *AcceptRecoveryResponseProto) String() string

type CanRollBackRequestProto 

type CanRollBackRequestProto struct {
	Jid                 *JournalIdProto               `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	Storage             *hadoop_hdfs.StorageInfoProto `protobuf:"bytes,2,req,name=storage" json:"storage,omitempty"`
	PrevStorage         *hadoop_hdfs.StorageInfoProto `protobuf:"bytes,3,req,name=prevStorage" json:"prevStorage,omitempty"`
	TargetLayoutVersion *int32                        `protobuf:"varint,4,req,name=targetLayoutVersion" json:"targetLayoutVersion,omitempty"`
	XXX_unrecognized    []byte                        `json:"-"`
}

* canRollBack()

func (*CanRollBackRequestProto) GetJid 

func (m *CanRollBackRequestProto) GetJid() *JournalIdProto

func (*CanRollBackRequestProto) GetPrevStorage 

func (m *CanRollBackRequestProto) GetPrevStorage() *hadoop_hdfs.StorageInfoProto

func (*CanRollBackRequestProto) GetStorage 

func (m *CanRollBackRequestProto) GetStorage() *hadoop_hdfs.StorageInfoProto

func (*CanRollBackRequestProto) GetTargetLayoutVersion 

func (m *CanRollBackRequestProto) GetTargetLayoutVersion() int32

func (*CanRollBackRequestProto) ProtoMessage 

func (*CanRollBackRequestProto) ProtoMessage()

func (*CanRollBackRequestProto) Reset 

func (m *CanRollBackRequestProto) Reset()

func (*CanRollBackRequestProto) String 

func (m *CanRollBackRequestProto) String() string

type CanRollBackResponseProto 

type CanRollBackResponseProto struct {
	CanRollBack      *bool  `protobuf:"varint,1,req,name=canRollBack" json:"canRollBack,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CanRollBackResponseProto) GetCanRollBack 

func (m *CanRollBackResponseProto) GetCanRollBack() bool

func (*CanRollBackResponseProto) ProtoMessage 

func (*CanRollBackResponseProto) ProtoMessage()

func (*CanRollBackResponseProto) Reset 

func (m *CanRollBackResponseProto) Reset()

func (*CanRollBackResponseProto) String 

func (m *CanRollBackResponseProto) String() string

type DiscardSegmentsRequestProto 

type DiscardSegmentsRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	StartTxId        *uint64         `protobuf:"varint,2,req,name=startTxId" json:"startTxId,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* discardSegments()

func (*DiscardSegmentsRequestProto) GetJid 

func (m *DiscardSegmentsRequestProto) GetJid() *JournalIdProto

func (*DiscardSegmentsRequestProto) GetStartTxId 

func (m *DiscardSegmentsRequestProto) GetStartTxId() uint64

func (*DiscardSegmentsRequestProto) ProtoMessage 

func (*DiscardSegmentsRequestProto) ProtoMessage()

func (*DiscardSegmentsRequestProto) Reset 

func (m *DiscardSegmentsRequestProto) Reset()

func (*DiscardSegmentsRequestProto) String 

func (m *DiscardSegmentsRequestProto) String() string

type DiscardSegmentsResponseProto 

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

func (*DiscardSegmentsResponseProto) ProtoMessage 

func (*DiscardSegmentsResponseProto) ProtoMessage()

func (*DiscardSegmentsResponseProto) Reset 

func (m *DiscardSegmentsResponseProto) Reset()

func (*DiscardSegmentsResponseProto) String 

func (m *DiscardSegmentsResponseProto) String() string

type DoFinalizeRequestProto 

type DoFinalizeRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* doFinalize()

func (*DoFinalizeRequestProto) GetJid 

func (m *DoFinalizeRequestProto) GetJid() *JournalIdProto

func (*DoFinalizeRequestProto) ProtoMessage 

func (*DoFinalizeRequestProto) ProtoMessage()

func (*DoFinalizeRequestProto) Reset 

func (m *DoFinalizeRequestProto) Reset()

func (*DoFinalizeRequestProto) String 

func (m *DoFinalizeRequestProto) String() string

type DoFinalizeResponseProto 

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

func (*DoFinalizeResponseProto) ProtoMessage 

func (*DoFinalizeResponseProto) ProtoMessage()

func (*DoFinalizeResponseProto) Reset 

func (m *DoFinalizeResponseProto) Reset()

func (*DoFinalizeResponseProto) String 

func (m *DoFinalizeResponseProto) String() string

type DoPreUpgradeRequestProto 

type DoPreUpgradeRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* doPreUpgrade()

func (*DoPreUpgradeRequestProto) GetJid 

func (m *DoPreUpgradeRequestProto) GetJid() *JournalIdProto

func (*DoPreUpgradeRequestProto) ProtoMessage 

func (*DoPreUpgradeRequestProto) ProtoMessage()

func (*DoPreUpgradeRequestProto) Reset 

func (m *DoPreUpgradeRequestProto) Reset()

func (*DoPreUpgradeRequestProto) String 

func (m *DoPreUpgradeRequestProto) String() string

type DoPreUpgradeResponseProto 

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

func (*DoPreUpgradeResponseProto) ProtoMessage 

func (*DoPreUpgradeResponseProto) ProtoMessage()

func (*DoPreUpgradeResponseProto) Reset 

func (m *DoPreUpgradeResponseProto) Reset()

func (*DoPreUpgradeResponseProto) String 

func (m *DoPreUpgradeResponseProto) String() string

type DoRollbackRequestProto 

type DoRollbackRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* doRollback()

func (*DoRollbackRequestProto) GetJid 

func (m *DoRollbackRequestProto) GetJid() *JournalIdProto

func (*DoRollbackRequestProto) ProtoMessage 

func (*DoRollbackRequestProto) ProtoMessage()

func (*DoRollbackRequestProto) Reset 

func (m *DoRollbackRequestProto) Reset()

func (*DoRollbackRequestProto) String 

func (m *DoRollbackRequestProto) String() string

type DoRollbackResponseProto 

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

func (*DoRollbackResponseProto) ProtoMessage 

func (*DoRollbackResponseProto) ProtoMessage()

func (*DoRollbackResponseProto) Reset 

func (m *DoRollbackResponseProto) Reset()

func (*DoRollbackResponseProto) String 

func (m *DoRollbackResponseProto) String() string

type DoUpgradeRequestProto 

type DoUpgradeRequestProto struct {
	Jid              *JournalIdProto               `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	SInfo            *hadoop_hdfs.StorageInfoProto `protobuf:"bytes,2,req,name=sInfo" json:"sInfo,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

* doUpgrade()

func (*DoUpgradeRequestProto) GetJid 

func (m *DoUpgradeRequestProto) GetJid() *JournalIdProto

func (*DoUpgradeRequestProto) GetSInfo 

func (m *DoUpgradeRequestProto) GetSInfo() *hadoop_hdfs.StorageInfoProto

func (*DoUpgradeRequestProto) ProtoMessage 

func (*DoUpgradeRequestProto) ProtoMessage()

func (*DoUpgradeRequestProto) Reset 

func (m *DoUpgradeRequestProto) Reset()

func (*DoUpgradeRequestProto) String 

func (m *DoUpgradeRequestProto) String() string

type DoUpgradeResponseProto 

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

func (*DoUpgradeResponseProto) ProtoMessage 

func (*DoUpgradeResponseProto) ProtoMessage()

func (*DoUpgradeResponseProto) Reset 

func (m *DoUpgradeResponseProto) Reset()

func (*DoUpgradeResponseProto) String 

func (m *DoUpgradeResponseProto) String() string

type FinalizeLogSegmentRequestProto 

type FinalizeLogSegmentRequestProto struct {
	ReqInfo          *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	StartTxId        *uint64           `protobuf:"varint,2,req,name=startTxId" json:"startTxId,omitempty"`
	EndTxId          *uint64           `protobuf:"varint,3,req,name=endTxId" json:"endTxId,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* finalizeLogSegment()

func (*FinalizeLogSegmentRequestProto) GetEndTxId 

func (m *FinalizeLogSegmentRequestProto) GetEndTxId() uint64

func (*FinalizeLogSegmentRequestProto) GetReqInfo 

func (m *FinalizeLogSegmentRequestProto) GetReqInfo() *RequestInfoProto

func (*FinalizeLogSegmentRequestProto) GetStartTxId 

func (m *FinalizeLogSegmentRequestProto) GetStartTxId() uint64

func (*FinalizeLogSegmentRequestProto) ProtoMessage 

func (*FinalizeLogSegmentRequestProto) ProtoMessage()

func (*FinalizeLogSegmentRequestProto) Reset 

func (m *FinalizeLogSegmentRequestProto) Reset()

func (*FinalizeLogSegmentRequestProto) String 

func (m *FinalizeLogSegmentRequestProto) String() string

type FinalizeLogSegmentResponseProto 

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

func (*FinalizeLogSegmentResponseProto) ProtoMessage 

func (*FinalizeLogSegmentResponseProto) ProtoMessage()

func (*FinalizeLogSegmentResponseProto) Reset 

func (m *FinalizeLogSegmentResponseProto) Reset()

func (*FinalizeLogSegmentResponseProto) String 

func (m *FinalizeLogSegmentResponseProto) String() string

type FormatRequestProto 

type FormatRequestProto struct {
	Jid              *JournalIdProto                 `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	NsInfo           *hadoop_hdfs.NamespaceInfoProto `protobuf:"bytes,2,req,name=nsInfo" json:"nsInfo,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

* format()

func (*FormatRequestProto) GetJid 

func (m *FormatRequestProto) GetJid() *JournalIdProto

func (*FormatRequestProto) GetNsInfo 

func (m *FormatRequestProto) GetNsInfo() *hadoop_hdfs.NamespaceInfoProto

func (*FormatRequestProto) ProtoMessage 

func (*FormatRequestProto) ProtoMessage()

func (*FormatRequestProto) Reset 

func (m *FormatRequestProto) Reset()

func (*FormatRequestProto) String 

func (m *FormatRequestProto) String() string

type FormatResponseProto 

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

func (*FormatResponseProto) ProtoMessage 

func (*FormatResponseProto) ProtoMessage()

func (*FormatResponseProto) Reset 

func (m *FormatResponseProto) Reset()

func (*FormatResponseProto) String 

func (m *FormatResponseProto) String() string

type GetEditLogManifestRequestProto 

type GetEditLogManifestRequestProto struct {
	Jid       *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	SinceTxId *uint64         `protobuf:"varint,2,req,name=sinceTxId" json:"sinceTxId,omitempty"`
	// Whether or not the client will be reading from the returned streams.
	// optional bool forReading = 3 [default = true]; <obsolete, do not reuse>
	InProgressOk     *bool  `protobuf:"varint,4,opt,name=inProgressOk,def=0" json:"inProgressOk,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* getEditLogManifest()

func (*GetEditLogManifestRequestProto) GetInProgressOk 

func (m *GetEditLogManifestRequestProto) GetInProgressOk() bool

func (*GetEditLogManifestRequestProto) GetJid 

func (m *GetEditLogManifestRequestProto) GetJid() *JournalIdProto

func (*GetEditLogManifestRequestProto) GetSinceTxId 

func (m *GetEditLogManifestRequestProto) GetSinceTxId() uint64

func (*GetEditLogManifestRequestProto) ProtoMessage 

func (*GetEditLogManifestRequestProto) ProtoMessage()

func (*GetEditLogManifestRequestProto) Reset 

func (m *GetEditLogManifestRequestProto) Reset()

func (*GetEditLogManifestRequestProto) String 

func (m *GetEditLogManifestRequestProto) String() string

type GetEditLogManifestResponseProto 

type GetEditLogManifestResponseProto struct {
	Manifest *hadoop_hdfs.RemoteEditLogManifestProto `protobuf:"bytes,1,req,name=manifest" json:"manifest,omitempty"`
	// Deprecated by fromURL
	HttpPort         *uint32 `protobuf:"varint,2,req,name=httpPort" json:"httpPort,omitempty"`
	FromURL          *string `protobuf:"bytes,3,opt,name=fromURL" json:"fromURL,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetEditLogManifestResponseProto) GetFromURL 

func (m *GetEditLogManifestResponseProto) GetFromURL() string

func (*GetEditLogManifestResponseProto) GetHttpPort 

func (m *GetEditLogManifestResponseProto) GetHttpPort() uint32

func (*GetEditLogManifestResponseProto) GetManifest 

func (m *GetEditLogManifestResponseProto) GetManifest() *hadoop_hdfs.RemoteEditLogManifestProto

func (*GetEditLogManifestResponseProto) ProtoMessage 

func (*GetEditLogManifestResponseProto) ProtoMessage()

func (*GetEditLogManifestResponseProto) Reset 

func (m *GetEditLogManifestResponseProto) Reset()

func (*GetEditLogManifestResponseProto) String 

func (m *GetEditLogManifestResponseProto) String() string

type GetJournalCTimeRequestProto 

type GetJournalCTimeRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* getJournalCTime()

func (*GetJournalCTimeRequestProto) GetJid 

func (m *GetJournalCTimeRequestProto) GetJid() *JournalIdProto

func (*GetJournalCTimeRequestProto) ProtoMessage 

func (*GetJournalCTimeRequestProto) ProtoMessage()

func (*GetJournalCTimeRequestProto) Reset 

func (m *GetJournalCTimeRequestProto) Reset()

func (*GetJournalCTimeRequestProto) String 

func (m *GetJournalCTimeRequestProto) String() string

type GetJournalCTimeResponseProto 

type GetJournalCTimeResponseProto struct {
	ResultCTime      *int64 `protobuf:"varint,1,req,name=resultCTime" json:"resultCTime,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetJournalCTimeResponseProto) GetResultCTime 

func (m *GetJournalCTimeResponseProto) GetResultCTime() int64

func (*GetJournalCTimeResponseProto) ProtoMessage 

func (*GetJournalCTimeResponseProto) ProtoMessage()

func (*GetJournalCTimeResponseProto) Reset 

func (m *GetJournalCTimeResponseProto) Reset()

func (*GetJournalCTimeResponseProto) String 

func (m *GetJournalCTimeResponseProto) String() string

type GetJournalStateRequestProto 

type GetJournalStateRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* getJournalState()

func (*GetJournalStateRequestProto) GetJid 

func (m *GetJournalStateRequestProto) GetJid() *JournalIdProto

func (*GetJournalStateRequestProto) ProtoMessage 

func (*GetJournalStateRequestProto) ProtoMessage()

func (*GetJournalStateRequestProto) Reset 

func (m *GetJournalStateRequestProto) Reset()

func (*GetJournalStateRequestProto) String 

func (m *GetJournalStateRequestProto) String() string

type GetJournalStateResponseProto 

type GetJournalStateResponseProto struct {
	LastPromisedEpoch *uint64 `protobuf:"varint,1,req,name=lastPromisedEpoch" json:"lastPromisedEpoch,omitempty"`
	// Deprecated by fromURL
	HttpPort         *uint32 `protobuf:"varint,2,req,name=httpPort" json:"httpPort,omitempty"`
	FromURL          *string `protobuf:"bytes,3,opt,name=fromURL" json:"fromURL,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetJournalStateResponseProto) GetFromURL 

func (m *GetJournalStateResponseProto) GetFromURL() string

func (*GetJournalStateResponseProto) GetHttpPort 

func (m *GetJournalStateResponseProto) GetHttpPort() uint32

func (*GetJournalStateResponseProto) GetLastPromisedEpoch 

func (m *GetJournalStateResponseProto) GetLastPromisedEpoch() uint64

func (*GetJournalStateResponseProto) ProtoMessage 

func (*GetJournalStateResponseProto) ProtoMessage()

func (*GetJournalStateResponseProto) Reset 

func (m *GetJournalStateResponseProto) Reset()

func (*GetJournalStateResponseProto) String 

func (m *GetJournalStateResponseProto) String() string

type HeartbeatRequestProto 

type HeartbeatRequestProto struct {
	ReqInfo          *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*HeartbeatRequestProto) GetReqInfo 

func (m *HeartbeatRequestProto) GetReqInfo() *RequestInfoProto

func (*HeartbeatRequestProto) ProtoMessage 

func (*HeartbeatRequestProto) ProtoMessage()

func (*HeartbeatRequestProto) Reset 

func (m *HeartbeatRequestProto) Reset()

func (*HeartbeatRequestProto) String 

func (m *HeartbeatRequestProto) String() string

type HeartbeatResponseProto 

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

func (*HeartbeatResponseProto) ProtoMessage 

func (*HeartbeatResponseProto) ProtoMessage()

func (*HeartbeatResponseProto) Reset 

func (m *HeartbeatResponseProto) Reset()

func (*HeartbeatResponseProto) String 

func (m *HeartbeatResponseProto) String() string

type IsFormattedRequestProto 

type IsFormattedRequestProto struct {
	Jid              *JournalIdProto `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* isFormatted()

func (*IsFormattedRequestProto) GetJid 

func (m *IsFormattedRequestProto) GetJid() *JournalIdProto

func (*IsFormattedRequestProto) ProtoMessage 

func (*IsFormattedRequestProto) ProtoMessage()

func (*IsFormattedRequestProto) Reset 

func (m *IsFormattedRequestProto) Reset()

func (*IsFormattedRequestProto) String 

func (m *IsFormattedRequestProto) String() string

type IsFormattedResponseProto 

type IsFormattedResponseProto struct {
	IsFormatted      *bool  `protobuf:"varint,1,req,name=isFormatted" json:"isFormatted,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IsFormattedResponseProto) GetIsFormatted 

func (m *IsFormattedResponseProto) GetIsFormatted() bool

func (*IsFormattedResponseProto) ProtoMessage 

func (*IsFormattedResponseProto) ProtoMessage()

func (*IsFormattedResponseProto) Reset 

func (m *IsFormattedResponseProto) Reset()

func (*IsFormattedResponseProto) String 

func (m *IsFormattedResponseProto) String() string

type JournalIdProto 

type JournalIdProto struct {
	Identifier       *string `protobuf:"bytes,1,req,name=identifier" json:"identifier,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*JournalIdProto) GetIdentifier 

func (m *JournalIdProto) GetIdentifier() string

func (*JournalIdProto) ProtoMessage 

func (*JournalIdProto) ProtoMessage()

func (*JournalIdProto) Reset 

func (m *JournalIdProto) Reset()

func (*JournalIdProto) String 

func (m *JournalIdProto) String() string

type JournalRequestProto 

type JournalRequestProto struct {
	ReqInfo          *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	FirstTxnId       *uint64           `protobuf:"varint,2,req,name=firstTxnId" json:"firstTxnId,omitempty"`
	NumTxns          *uint32           `protobuf:"varint,3,req,name=numTxns" json:"numTxns,omitempty"`
	Records          []byte            `protobuf:"bytes,4,req,name=records" json:"records,omitempty"`
	SegmentTxnId     *uint64           `protobuf:"varint,5,req,name=segmentTxnId" json:"segmentTxnId,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*JournalRequestProto) GetFirstTxnId 

func (m *JournalRequestProto) GetFirstTxnId() uint64

func (*JournalRequestProto) GetNumTxns 

func (m *JournalRequestProto) GetNumTxns() uint32

func (*JournalRequestProto) GetRecords 

func (m *JournalRequestProto) GetRecords() []byte

func (*JournalRequestProto) GetReqInfo 

func (m *JournalRequestProto) GetReqInfo() *RequestInfoProto

func (*JournalRequestProto) GetSegmentTxnId 

func (m *JournalRequestProto) GetSegmentTxnId() uint64

func (*JournalRequestProto) ProtoMessage 

func (*JournalRequestProto) ProtoMessage()

func (*JournalRequestProto) Reset 

func (m *JournalRequestProto) Reset()

func (*JournalRequestProto) String 

func (m *JournalRequestProto) String() string

type JournalResponseProto 

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

func (*JournalResponseProto) ProtoMessage 

func (*JournalResponseProto) ProtoMessage()

func (*JournalResponseProto) Reset 

func (m *JournalResponseProto) Reset()

func (*JournalResponseProto) String 

func (m *JournalResponseProto) String() string

type NewEpochRequestProto 

type NewEpochRequestProto struct {
	Jid              *JournalIdProto                 `protobuf:"bytes,1,req,name=jid" json:"jid,omitempty"`
	NsInfo           *hadoop_hdfs.NamespaceInfoProto `protobuf:"bytes,2,req,name=nsInfo" json:"nsInfo,omitempty"`
	Epoch            *uint64                         `protobuf:"varint,3,req,name=epoch" json:"epoch,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

* newEpoch()

func (*NewEpochRequestProto) GetEpoch 

func (m *NewEpochRequestProto) GetEpoch() uint64

func (*NewEpochRequestProto) GetJid 

func (m *NewEpochRequestProto) GetJid() *JournalIdProto

func (*NewEpochRequestProto) GetNsInfo 

func (m *NewEpochRequestProto) GetNsInfo() *hadoop_hdfs.NamespaceInfoProto

func (*NewEpochRequestProto) ProtoMessage 

func (*NewEpochRequestProto) ProtoMessage()

func (*NewEpochRequestProto) Reset 

func (m *NewEpochRequestProto) Reset()

func (*NewEpochRequestProto) String 

func (m *NewEpochRequestProto) String() string

type NewEpochResponseProto 

type NewEpochResponseProto struct {
	LastSegmentTxId  *uint64 `protobuf:"varint,1,opt,name=lastSegmentTxId" json:"lastSegmentTxId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NewEpochResponseProto) GetLastSegmentTxId 

func (m *NewEpochResponseProto) GetLastSegmentTxId() uint64

func (*NewEpochResponseProto) ProtoMessage 

func (*NewEpochResponseProto) ProtoMessage()

func (*NewEpochResponseProto) Reset 

func (m *NewEpochResponseProto) Reset()

func (*NewEpochResponseProto) String 

func (m *NewEpochResponseProto) String() string

type PersistedRecoveryPaxosData 

type PersistedRecoveryPaxosData struct {
	SegmentState     *SegmentStateProto `protobuf:"bytes,1,req,name=segmentState" json:"segmentState,omitempty"`
	AcceptedInEpoch  *uint64            `protobuf:"varint,2,req,name=acceptedInEpoch" json:"acceptedInEpoch,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* The storage format used on local disk for previously accepted decisions.

func (*PersistedRecoveryPaxosData) GetAcceptedInEpoch 

func (m *PersistedRecoveryPaxosData) GetAcceptedInEpoch() uint64

func (*PersistedRecoveryPaxosData) GetSegmentState 

func (m *PersistedRecoveryPaxosData) GetSegmentState() *SegmentStateProto

func (*PersistedRecoveryPaxosData) ProtoMessage 

func (*PersistedRecoveryPaxosData) ProtoMessage()

func (*PersistedRecoveryPaxosData) Reset 

func (m *PersistedRecoveryPaxosData) Reset()

func (*PersistedRecoveryPaxosData) String 

func (m *PersistedRecoveryPaxosData) String() string

type PrepareRecoveryRequestProto 

type PrepareRecoveryRequestProto struct {
	ReqInfo          *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	SegmentTxId      *uint64           `protobuf:"varint,2,req,name=segmentTxId" json:"segmentTxId,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* prepareRecovery()

func (*PrepareRecoveryRequestProto) GetReqInfo 

func (m *PrepareRecoveryRequestProto) GetReqInfo() *RequestInfoProto

func (*PrepareRecoveryRequestProto) GetSegmentTxId 

func (m *PrepareRecoveryRequestProto) GetSegmentTxId() uint64

func (*PrepareRecoveryRequestProto) ProtoMessage 

func (*PrepareRecoveryRequestProto) ProtoMessage()

func (*PrepareRecoveryRequestProto) Reset 

func (m *PrepareRecoveryRequestProto) Reset()

func (*PrepareRecoveryRequestProto) String 

func (m *PrepareRecoveryRequestProto) String() string

type PrepareRecoveryResponseProto 

type PrepareRecoveryResponseProto struct {
	SegmentState    *SegmentStateProto `protobuf:"bytes,1,opt,name=segmentState" json:"segmentState,omitempty"`
	AcceptedInEpoch *uint64            `protobuf:"varint,2,opt,name=acceptedInEpoch" json:"acceptedInEpoch,omitempty"`
	LastWriterEpoch *uint64            `protobuf:"varint,3,req,name=lastWriterEpoch" json:"lastWriterEpoch,omitempty"`
	// The highest committed txid that this logger has ever seen.
	// This may be higher than the data it actually has, in the case
	// that it was lagging before the old writer crashed.
	LastCommittedTxId *uint64 `protobuf:"varint,4,opt,name=lastCommittedTxId" json:"lastCommittedTxId,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

func (*PrepareRecoveryResponseProto) GetAcceptedInEpoch 

func (m *PrepareRecoveryResponseProto) GetAcceptedInEpoch() uint64

func (*PrepareRecoveryResponseProto) GetLastCommittedTxId 

func (m *PrepareRecoveryResponseProto) GetLastCommittedTxId() uint64

func (*PrepareRecoveryResponseProto) GetLastWriterEpoch 

func (m *PrepareRecoveryResponseProto) GetLastWriterEpoch() uint64

func (*PrepareRecoveryResponseProto) GetSegmentState 

func (m *PrepareRecoveryResponseProto) GetSegmentState() *SegmentStateProto

func (*PrepareRecoveryResponseProto) ProtoMessage 

func (*PrepareRecoveryResponseProto) ProtoMessage()

func (*PrepareRecoveryResponseProto) Reset 

func (m *PrepareRecoveryResponseProto) Reset()

func (*PrepareRecoveryResponseProto) String 

func (m *PrepareRecoveryResponseProto) String() string

type PurgeLogsRequestProto 

type PurgeLogsRequestProto struct {
	ReqInfo          *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	MinTxIdToKeep    *uint64           `protobuf:"varint,2,req,name=minTxIdToKeep" json:"minTxIdToKeep,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* purgeLogs()

func (*PurgeLogsRequestProto) GetMinTxIdToKeep 

func (m *PurgeLogsRequestProto) GetMinTxIdToKeep() uint64

func (*PurgeLogsRequestProto) GetReqInfo 

func (m *PurgeLogsRequestProto) GetReqInfo() *RequestInfoProto

func (*PurgeLogsRequestProto) ProtoMessage 

func (*PurgeLogsRequestProto) ProtoMessage()

func (*PurgeLogsRequestProto) Reset 

func (m *PurgeLogsRequestProto) Reset()

func (*PurgeLogsRequestProto) String 

func (m *PurgeLogsRequestProto) String() string

type PurgeLogsResponseProto 

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

func (*PurgeLogsResponseProto) ProtoMessage 

func (*PurgeLogsResponseProto) ProtoMessage()

func (*PurgeLogsResponseProto) Reset 

func (m *PurgeLogsResponseProto) Reset()

func (*PurgeLogsResponseProto) String 

func (m *PurgeLogsResponseProto) String() string

type RequestInfoProto 

type RequestInfoProto struct {
	JournalId       *JournalIdProto `protobuf:"bytes,1,req,name=journalId" json:"journalId,omitempty"`
	Epoch           *uint64         `protobuf:"varint,2,req,name=epoch" json:"epoch,omitempty"`
	IpcSerialNumber *uint64         `protobuf:"varint,3,req,name=ipcSerialNumber" json:"ipcSerialNumber,omitempty"`
	// Whenever a writer makes a request, it informs
	// the node of the latest committed txid. This may
	// be higher than the transaction data included in the
	// request itself, eg in the case that the node has
	// fallen behind.
	CommittedTxId    *uint64 `protobuf:"varint,4,opt,name=committedTxId" json:"committedTxId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RequestInfoProto) GetCommittedTxId 

func (m *RequestInfoProto) GetCommittedTxId() uint64

func (*RequestInfoProto) GetEpoch 

func (m *RequestInfoProto) GetEpoch() uint64

func (*RequestInfoProto) GetIpcSerialNumber 

func (m *RequestInfoProto) GetIpcSerialNumber() uint64

func (*RequestInfoProto) GetJournalId 

func (m *RequestInfoProto) GetJournalId() *JournalIdProto

func (*RequestInfoProto) ProtoMessage 

func (*RequestInfoProto) ProtoMessage()

func (*RequestInfoProto) Reset 

func (m *RequestInfoProto) Reset()

func (*RequestInfoProto) String 

func (m *RequestInfoProto) String() string

type SegmentStateProto 

type SegmentStateProto struct {
	StartTxId        *uint64 `protobuf:"varint,1,req,name=startTxId" json:"startTxId,omitempty"`
	EndTxId          *uint64 `protobuf:"varint,2,req,name=endTxId" json:"endTxId,omitempty"`
	IsInProgress     *bool   `protobuf:"varint,3,req,name=isInProgress" json:"isInProgress,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SegmentStateProto) GetEndTxId 

func (m *SegmentStateProto) GetEndTxId() uint64

func (*SegmentStateProto) GetIsInProgress 

func (m *SegmentStateProto) GetIsInProgress() bool

func (*SegmentStateProto) GetStartTxId 

func (m *SegmentStateProto) GetStartTxId() uint64

func (*SegmentStateProto) ProtoMessage 

func (*SegmentStateProto) ProtoMessage()

func (*SegmentStateProto) Reset 

func (m *SegmentStateProto) Reset()

func (*SegmentStateProto) String 

func (m *SegmentStateProto) String() string

type StartLogSegmentRequestProto 

type StartLogSegmentRequestProto struct {
	ReqInfo          *RequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	Txid             *uint64           `protobuf:"varint,2,req,name=txid" json:"txid,omitempty"`
	LayoutVersion    *int32            `protobuf:"zigzag32,3,opt,name=layoutVersion" json:"layoutVersion,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* startLogSegment()

func (*StartLogSegmentRequestProto) GetLayoutVersion 

func (m *StartLogSegmentRequestProto) GetLayoutVersion() int32

func (*StartLogSegmentRequestProto) GetReqInfo 

func (m *StartLogSegmentRequestProto) GetReqInfo() *RequestInfoProto

func (*StartLogSegmentRequestProto) GetTxid 

func (m *StartLogSegmentRequestProto) GetTxid() uint64

func (*StartLogSegmentRequestProto) ProtoMessage 

func (*StartLogSegmentRequestProto) ProtoMessage()

func (*StartLogSegmentRequestProto) Reset 

func (m *StartLogSegmentRequestProto) Reset()

func (*StartLogSegmentRequestProto) String 

func (m *StartLogSegmentRequestProto) String() string

type StartLogSegmentResponseProto 

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

func (*StartLogSegmentResponseProto) ProtoMessage 

func (*StartLogSegmentResponseProto) ProtoMessage()

func (*StartLogSegmentResponseProto) Reset 

func (m *StartLogSegmentResponseProto) Reset()

func (*StartLogSegmentResponseProto) String 

func (m *StartLogSegmentResponseProto) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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