hadoop_common

package
v2.0.1-0...-3567f9a Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2020 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package hadoop_common is a generated protocol buffer package.

It is generated from these files: 

IpcConnectionContext.proto
ZKFCProtocol.proto
RefreshAuthorizationPolicyProtocol.proto
GenericRefreshProtocol.proto
RpcHeader.proto
TraceAdmin.proto
RefreshCallQueueProtocol.proto
Security.proto
ProtobufRpcEngine.proto
RefreshUserMappingsProtocol.proto
GetUserMappingsProtocol.proto
HAServiceProtocol.proto
ProtocolInfo.proto

It has these top-level messages: 

UserInformationProto
IpcConnectionContextProto
CedeActiveRequestProto
CedeActiveResponseProto
GracefulFailoverRequestProto
GracefulFailoverResponseProto
RefreshServiceAclRequestProto
RefreshServiceAclResponseProto
GenericRefreshRequestProto
GenericRefreshResponseProto
GenericRefreshResponseCollectionProto
RPCTraceInfoProto
RPCCallerContextProto
RpcRequestHeaderProto
RpcResponseHeaderProto
RpcSaslProto
ListSpanReceiversRequestProto
SpanReceiverListInfo
ListSpanReceiversResponseProto
ConfigPair
AddSpanReceiverRequestProto
AddSpanReceiverResponseProto
RemoveSpanReceiverRequestProto
RemoveSpanReceiverResponseProto
RefreshCallQueueRequestProto
RefreshCallQueueResponseProto
TokenProto
GetDelegationTokenRequestProto
GetDelegationTokenResponseProto
RenewDelegationTokenRequestProto
RenewDelegationTokenResponseProto
CancelDelegationTokenRequestProto
CancelDelegationTokenResponseProto
RequestHeaderProto
RefreshUserToGroupsMappingsRequestProto
RefreshUserToGroupsMappingsResponseProto
RefreshSuperUserGroupsConfigurationRequestProto
RefreshSuperUserGroupsConfigurationResponseProto
GetGroupsForUserRequestProto
GetGroupsForUserResponseProto
HAStateChangeRequestInfoProto
MonitorHealthRequestProto
MonitorHealthResponseProto
TransitionToActiveRequestProto
TransitionToActiveResponseProto
TransitionToStandbyRequestProto
TransitionToStandbyResponseProto
GetServiceStatusRequestProto
GetServiceStatusResponseProto
GetProtocolVersionsRequestProto
ProtocolVersionProto
GetProtocolVersionsResponseProto
GetProtocolSignatureRequestProto
GetProtocolSignatureResponseProto
ProtocolSignatureProto

Index

Constants

View Source 
const Default_RpcRequestHeaderProto_RetryCount int32 = -1
View Source 
const Default_RpcResponseHeaderProto_RetryCount int32 = -1

Variables

View Source 
var HARequestSource_name = map[int32]string{
	0: "REQUEST_BY_USER",
	1: "REQUEST_BY_USER_FORCED",
	2: "REQUEST_BY_ZKFC",
}
View Source 
var HARequestSource_value = map[string]int32{
	"REQUEST_BY_USER":        0,
	"REQUEST_BY_USER_FORCED": 1,
	"REQUEST_BY_ZKFC":        2,
}
View Source 
var HAServiceStateProto_name = map[int32]string{
	0: "INITIALIZING",
	1: "ACTIVE",
	2: "STANDBY",
}
View Source 
var HAServiceStateProto_value = map[string]int32{
	"INITIALIZING": 0,
	"ACTIVE":       1,
	"STANDBY":      2,
}
View Source 
var RpcKindProto_name = map[int32]string{
	0: "RPC_BUILTIN",
	1: "RPC_WRITABLE",
	2: "RPC_PROTOCOL_BUFFER",
}
View Source 
var RpcKindProto_value = map[string]int32{
	"RPC_BUILTIN":         0,
	"RPC_WRITABLE":        1,
	"RPC_PROTOCOL_BUFFER": 2,
}
View Source 
var RpcRequestHeaderProto_OperationProto_name = map[int32]string{
	0: "RPC_FINAL_PACKET",
	1: "RPC_CONTINUATION_PACKET",
	2: "RPC_CLOSE_CONNECTION",
}
View Source 
var RpcRequestHeaderProto_OperationProto_value = map[string]int32{
	"RPC_FINAL_PACKET":        0,
	"RPC_CONTINUATION_PACKET": 1,
	"RPC_CLOSE_CONNECTION":    2,
}
View Source 
var RpcResponseHeaderProto_RpcErrorCodeProto_name = map[int32]string{
	1:  "ERROR_APPLICATION",
	2:  "ERROR_NO_SUCH_METHOD",
	3:  "ERROR_NO_SUCH_PROTOCOL",
	4:  "ERROR_RPC_SERVER",
	5:  "ERROR_SERIALIZING_RESPONSE",
	6:  "ERROR_RPC_VERSION_MISMATCH",
	10: "FATAL_UNKNOWN",
	11: "FATAL_UNSUPPORTED_SERIALIZATION",
	12: "FATAL_INVALID_RPC_HEADER",
	13: "FATAL_DESERIALIZING_REQUEST",
	14: "FATAL_VERSION_MISMATCH",
	15: "FATAL_UNAUTHORIZED",
}
View Source 
var RpcResponseHeaderProto_RpcErrorCodeProto_value = map[string]int32{
	"ERROR_APPLICATION":               1,
	"ERROR_NO_SUCH_METHOD":            2,
	"ERROR_NO_SUCH_PROTOCOL":          3,
	"ERROR_RPC_SERVER":                4,
	"ERROR_SERIALIZING_RESPONSE":      5,
	"ERROR_RPC_VERSION_MISMATCH":      6,
	"FATAL_UNKNOWN":                   10,
	"FATAL_UNSUPPORTED_SERIALIZATION": 11,
	"FATAL_INVALID_RPC_HEADER":        12,
	"FATAL_DESERIALIZING_REQUEST":     13,
	"FATAL_VERSION_MISMATCH":          14,
	"FATAL_UNAUTHORIZED":              15,
}
View Source 
var RpcResponseHeaderProto_RpcStatusProto_name = map[int32]string{
	0: "SUCCESS",
	1: "ERROR",
	2: "FATAL",
}
View Source 
var RpcResponseHeaderProto_RpcStatusProto_value = map[string]int32{
	"SUCCESS": 0,
	"ERROR":   1,
	"FATAL":   2,
}
View Source 
var RpcSaslProto_SaslState_name = map[int32]string{
	0: "SUCCESS",
	1: "NEGOTIATE",
	2: "INITIATE",
	3: "CHALLENGE",
	4: "RESPONSE",
	5: "WRAP",
}
View Source 
var RpcSaslProto_SaslState_value = map[string]int32{
	"SUCCESS":   0,
	"NEGOTIATE": 1,
	"INITIATE":  2,
	"CHALLENGE": 3,
	"RESPONSE":  4,
	"WRAP":      5,
}

Functions

This section is empty.

Types

type AddSpanReceiverRequestProto 

type AddSpanReceiverRequestProto struct {
	ClassName        *string       `protobuf:"bytes,1,req,name=className" json:"className,omitempty"`
	Config           []*ConfigPair `protobuf:"bytes,2,rep,name=config" json:"config,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*AddSpanReceiverRequestProto) Descriptor 

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

func (*AddSpanReceiverRequestProto) GetClassName 

func (m *AddSpanReceiverRequestProto) GetClassName() string

func (*AddSpanReceiverRequestProto) GetConfig 

func (m *AddSpanReceiverRequestProto) GetConfig() []*ConfigPair

func (*AddSpanReceiverRequestProto) ProtoMessage 

func (*AddSpanReceiverRequestProto) ProtoMessage()

func (*AddSpanReceiverRequestProto) Reset 

func (m *AddSpanReceiverRequestProto) Reset()

func (*AddSpanReceiverRequestProto) String 

func (m *AddSpanReceiverRequestProto) String() string

type AddSpanReceiverResponseProto 

type AddSpanReceiverResponseProto struct {
	Id               *int64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AddSpanReceiverResponseProto) Descriptor 

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

func (*AddSpanReceiverResponseProto) GetId 

func (m *AddSpanReceiverResponseProto) GetId() int64

func (*AddSpanReceiverResponseProto) ProtoMessage 

func (*AddSpanReceiverResponseProto) ProtoMessage()

func (*AddSpanReceiverResponseProto) Reset 

func (m *AddSpanReceiverResponseProto) Reset()

func (*AddSpanReceiverResponseProto) String 

func (m *AddSpanReceiverResponseProto) String() string

type CancelDelegationTokenRequestProto 

type CancelDelegationTokenRequestProto struct {
	Token            *TokenProto `protobuf:"bytes,1,req,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*CancelDelegationTokenRequestProto) Descriptor 

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

func (*CancelDelegationTokenRequestProto) GetToken 

func (m *CancelDelegationTokenRequestProto) GetToken() *TokenProto

func (*CancelDelegationTokenRequestProto) ProtoMessage 

func (*CancelDelegationTokenRequestProto) ProtoMessage()

func (*CancelDelegationTokenRequestProto) Reset 

func (m *CancelDelegationTokenRequestProto) Reset()

func (*CancelDelegationTokenRequestProto) String 

func (m *CancelDelegationTokenRequestProto) String() string

type CancelDelegationTokenResponseProto 

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

func (*CancelDelegationTokenResponseProto) Descriptor 

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

func (*CancelDelegationTokenResponseProto) ProtoMessage 

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) Reset 

func (m *CancelDelegationTokenResponseProto) Reset()

func (*CancelDelegationTokenResponseProto) String 

func (m *CancelDelegationTokenResponseProto) String() string

type CedeActiveRequestProto 

type CedeActiveRequestProto struct {
	MillisToCede     *uint32 `protobuf:"varint,1,req,name=millisToCede" json:"millisToCede,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CedeActiveRequestProto) Descriptor 

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

func (*CedeActiveRequestProto) GetMillisToCede 

func (m *CedeActiveRequestProto) GetMillisToCede() uint32

func (*CedeActiveRequestProto) ProtoMessage 

func (*CedeActiveRequestProto) ProtoMessage()

func (*CedeActiveRequestProto) Reset 

func (m *CedeActiveRequestProto) Reset()

func (*CedeActiveRequestProto) String 

func (m *CedeActiveRequestProto) String() string

type CedeActiveResponseProto 

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

func (*CedeActiveResponseProto) Descriptor 

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

func (*CedeActiveResponseProto) ProtoMessage 

func (*CedeActiveResponseProto) ProtoMessage()

func (*CedeActiveResponseProto) Reset 

func (m *CedeActiveResponseProto) Reset()

func (*CedeActiveResponseProto) String 

func (m *CedeActiveResponseProto) String() string

type ConfigPair 

type ConfigPair struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ConfigPair) Descriptor 

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

func (*ConfigPair) GetKey 

func (m *ConfigPair) GetKey() string

func (*ConfigPair) GetValue 

func (m *ConfigPair) GetValue() string

func (*ConfigPair) ProtoMessage 

func (*ConfigPair) ProtoMessage()

func (*ConfigPair) Reset 

func (m *ConfigPair) Reset()

func (*ConfigPair) String 

func (m *ConfigPair) String() string

type GenericRefreshRequestProto 

type GenericRefreshRequestProto struct {
	Identifier       *string  `protobuf:"bytes,1,opt,name=identifier" json:"identifier,omitempty"`
	Args             []string `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* 

Refresh request.

func (*GenericRefreshRequestProto) Descriptor 

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

func (*GenericRefreshRequestProto) GetArgs 

func (m *GenericRefreshRequestProto) GetArgs() []string

func (*GenericRefreshRequestProto) GetIdentifier 

func (m *GenericRefreshRequestProto) GetIdentifier() string

func (*GenericRefreshRequestProto) ProtoMessage 

func (*GenericRefreshRequestProto) ProtoMessage()

func (*GenericRefreshRequestProto) Reset 

func (m *GenericRefreshRequestProto) Reset()

func (*GenericRefreshRequestProto) String 

func (m *GenericRefreshRequestProto) String() string

type GenericRefreshResponseCollectionProto 

type GenericRefreshResponseCollectionProto struct {
	Responses        []*GenericRefreshResponseProto `protobuf:"bytes,1,rep,name=responses" json:"responses,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

* Collection of responses from zero or more handlers.

func (*GenericRefreshResponseCollectionProto) Descriptor 

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

func (*GenericRefreshResponseCollectionProto) GetResponses 

func (m *GenericRefreshResponseCollectionProto) GetResponses() []*GenericRefreshResponseProto

func (*GenericRefreshResponseCollectionProto) ProtoMessage 

func (*GenericRefreshResponseCollectionProto) ProtoMessage()

func (*GenericRefreshResponseCollectionProto) Reset 

func (m *GenericRefreshResponseCollectionProto) Reset()

func (*GenericRefreshResponseCollectionProto) String 

func (m *GenericRefreshResponseCollectionProto) String() string

type GenericRefreshResponseProto 

type GenericRefreshResponseProto struct {
	ExitStatus       *int32  `protobuf:"varint,1,opt,name=exitStatus" json:"exitStatus,omitempty"`
	UserMessage      *string `protobuf:"bytes,2,opt,name=userMessage" json:"userMessage,omitempty"`
	SenderName       *string `protobuf:"bytes,3,opt,name=senderName" json:"senderName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A single response from a refresh handler.

func (*GenericRefreshResponseProto) Descriptor 

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

func (*GenericRefreshResponseProto) GetExitStatus 

func (m *GenericRefreshResponseProto) GetExitStatus() int32

func (*GenericRefreshResponseProto) GetSenderName 

func (m *GenericRefreshResponseProto) GetSenderName() string

func (*GenericRefreshResponseProto) GetUserMessage 

func (m *GenericRefreshResponseProto) GetUserMessage() string

func (*GenericRefreshResponseProto) ProtoMessage 

func (*GenericRefreshResponseProto) ProtoMessage()

func (*GenericRefreshResponseProto) Reset 

func (m *GenericRefreshResponseProto) Reset()

func (*GenericRefreshResponseProto) String 

func (m *GenericRefreshResponseProto) String() string

type GetDelegationTokenRequestProto 

type GetDelegationTokenRequestProto struct {
	Renewer          *string `protobuf:"bytes,1,req,name=renewer" json:"renewer,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetDelegationTokenRequestProto) Descriptor 

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

func (*GetDelegationTokenRequestProto) GetRenewer 

func (m *GetDelegationTokenRequestProto) GetRenewer() string

func (*GetDelegationTokenRequestProto) ProtoMessage 

func (*GetDelegationTokenRequestProto) ProtoMessage()

func (*GetDelegationTokenRequestProto) Reset 

func (m *GetDelegationTokenRequestProto) Reset()

func (*GetDelegationTokenRequestProto) String 

func (m *GetDelegationTokenRequestProto) String() string

type GetDelegationTokenResponseProto 

type GetDelegationTokenResponseProto struct {
	Token            *TokenProto `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*GetDelegationTokenResponseProto) Descriptor 

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

func (*GetDelegationTokenResponseProto) GetToken 

func (m *GetDelegationTokenResponseProto) GetToken() *TokenProto

func (*GetDelegationTokenResponseProto) ProtoMessage 

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) Reset 

func (m *GetDelegationTokenResponseProto) Reset()

func (*GetDelegationTokenResponseProto) String 

func (m *GetDelegationTokenResponseProto) String() string

type GetGroupsForUserRequestProto 

type GetGroupsForUserRequestProto struct {
	User             *string `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* 

Get groups for user request.

func (*GetGroupsForUserRequestProto) Descriptor 

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

func (*GetGroupsForUserRequestProto) GetUser 

func (m *GetGroupsForUserRequestProto) GetUser() string

func (*GetGroupsForUserRequestProto) ProtoMessage 

func (*GetGroupsForUserRequestProto) ProtoMessage()

func (*GetGroupsForUserRequestProto) Reset 

func (m *GetGroupsForUserRequestProto) Reset()

func (*GetGroupsForUserRequestProto) String 

func (m *GetGroupsForUserRequestProto) String() string

type GetGroupsForUserResponseProto 

type GetGroupsForUserResponseProto struct {
	Groups           []string `protobuf:"bytes,1,rep,name=groups" json:"groups,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Response for get groups.

func (*GetGroupsForUserResponseProto) Descriptor 

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

func (*GetGroupsForUserResponseProto) GetGroups 

func (m *GetGroupsForUserResponseProto) GetGroups() []string

func (*GetGroupsForUserResponseProto) ProtoMessage 

func (*GetGroupsForUserResponseProto) ProtoMessage()

func (*GetGroupsForUserResponseProto) Reset 

func (m *GetGroupsForUserResponseProto) Reset()

func (*GetGroupsForUserResponseProto) String 

func (m *GetGroupsForUserResponseProto) String() string

type GetProtocolSignatureRequestProto 

type GetProtocolSignatureRequestProto struct {
	Protocol         *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"`
	RpcKind          *string `protobuf:"bytes,2,req,name=rpcKind" json:"rpcKind,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Get protocol signature request.

func (*GetProtocolSignatureRequestProto) Descriptor 

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

func (*GetProtocolSignatureRequestProto) GetProtocol 

func (m *GetProtocolSignatureRequestProto) GetProtocol() string

func (*GetProtocolSignatureRequestProto) GetRpcKind 

func (m *GetProtocolSignatureRequestProto) GetRpcKind() string

func (*GetProtocolSignatureRequestProto) ProtoMessage 

func (*GetProtocolSignatureRequestProto) ProtoMessage()

func (*GetProtocolSignatureRequestProto) Reset 

func (m *GetProtocolSignatureRequestProto) Reset()

func (*GetProtocolSignatureRequestProto) String 

func (m *GetProtocolSignatureRequestProto) String() string

type GetProtocolSignatureResponseProto 

type GetProtocolSignatureResponseProto struct {
	ProtocolSignature []*ProtocolSignatureProto `protobuf:"bytes,1,rep,name=protocolSignature" json:"protocolSignature,omitempty"`
	XXX_unrecognized  []byte                    `json:"-"`
}

* Get protocol signature response.

func (*GetProtocolSignatureResponseProto) Descriptor 

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

func (*GetProtocolSignatureResponseProto) GetProtocolSignature 

func (m *GetProtocolSignatureResponseProto) GetProtocolSignature() []*ProtocolSignatureProto

func (*GetProtocolSignatureResponseProto) ProtoMessage 

func (*GetProtocolSignatureResponseProto) ProtoMessage()

func (*GetProtocolSignatureResponseProto) Reset 

func (m *GetProtocolSignatureResponseProto) Reset()

func (*GetProtocolSignatureResponseProto) String 

func (m *GetProtocolSignatureResponseProto) String() string

type GetProtocolVersionsRequestProto 

type GetProtocolVersionsRequestProto struct {
	Protocol         *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Request to get protocol versions for all supported rpc kinds.

func (*GetProtocolVersionsRequestProto) Descriptor 

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

func (*GetProtocolVersionsRequestProto) GetProtocol 

func (m *GetProtocolVersionsRequestProto) GetProtocol() string

func (*GetProtocolVersionsRequestProto) ProtoMessage 

func (*GetProtocolVersionsRequestProto) ProtoMessage()

func (*GetProtocolVersionsRequestProto) Reset 

func (m *GetProtocolVersionsRequestProto) Reset()

func (*GetProtocolVersionsRequestProto) String 

func (m *GetProtocolVersionsRequestProto) String() string

type GetProtocolVersionsResponseProto 

type GetProtocolVersionsResponseProto struct {
	ProtocolVersions []*ProtocolVersionProto `protobuf:"bytes,1,rep,name=protocolVersions" json:"protocolVersions,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

* Get protocol version response.

func (*GetProtocolVersionsResponseProto) Descriptor 

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

func (*GetProtocolVersionsResponseProto) GetProtocolVersions 

func (m *GetProtocolVersionsResponseProto) GetProtocolVersions() []*ProtocolVersionProto

func (*GetProtocolVersionsResponseProto) ProtoMessage 

func (*GetProtocolVersionsResponseProto) ProtoMessage()

func (*GetProtocolVersionsResponseProto) Reset 

func (m *GetProtocolVersionsResponseProto) Reset()

func (*GetProtocolVersionsResponseProto) String 

func (m *GetProtocolVersionsResponseProto) String() string

type GetServiceStatusRequestProto 

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

* void request

func (*GetServiceStatusRequestProto) Descriptor 

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

func (*GetServiceStatusRequestProto) ProtoMessage 

func (*GetServiceStatusRequestProto) ProtoMessage()

func (*GetServiceStatusRequestProto) Reset 

func (m *GetServiceStatusRequestProto) Reset()

func (*GetServiceStatusRequestProto) String 

func (m *GetServiceStatusRequestProto) String() string

type GetServiceStatusResponseProto 

type GetServiceStatusResponseProto struct {
	State *HAServiceStateProto `protobuf:"varint,1,req,name=state,enum=hadoop.common.HAServiceStateProto" json:"state,omitempty"`
	// If state is STANDBY, indicate whether it is
	// ready to become active.
	ReadyToBecomeActive *bool `protobuf:"varint,2,opt,name=readyToBecomeActive" json:"readyToBecomeActive,omitempty"`
	// If not ready to become active, a textual explanation of why not
	NotReadyReason   *string `protobuf:"bytes,3,opt,name=notReadyReason" json:"notReadyReason,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Returns the state of the service

func (*GetServiceStatusResponseProto) Descriptor 

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

func (*GetServiceStatusResponseProto) GetNotReadyReason 

func (m *GetServiceStatusResponseProto) GetNotReadyReason() string

func (*GetServiceStatusResponseProto) GetReadyToBecomeActive 

func (m *GetServiceStatusResponseProto) GetReadyToBecomeActive() bool

func (*GetServiceStatusResponseProto) GetState 

func (m *GetServiceStatusResponseProto) GetState() HAServiceStateProto

func (*GetServiceStatusResponseProto) ProtoMessage 

func (*GetServiceStatusResponseProto) ProtoMessage()

func (*GetServiceStatusResponseProto) Reset 

func (m *GetServiceStatusResponseProto) Reset()

func (*GetServiceStatusResponseProto) String 

func (m *GetServiceStatusResponseProto) String() string

type GracefulFailoverRequestProto 

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

func (*GracefulFailoverRequestProto) Descriptor 

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

func (*GracefulFailoverRequestProto) ProtoMessage 

func (*GracefulFailoverRequestProto) ProtoMessage()

func (*GracefulFailoverRequestProto) Reset 

func (m *GracefulFailoverRequestProto) Reset()

func (*GracefulFailoverRequestProto) String 

func (m *GracefulFailoverRequestProto) String() string

type GracefulFailoverResponseProto 

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

func (*GracefulFailoverResponseProto) Descriptor 

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

func (*GracefulFailoverResponseProto) ProtoMessage 

func (*GracefulFailoverResponseProto) ProtoMessage()

func (*GracefulFailoverResponseProto) Reset 

func (m *GracefulFailoverResponseProto) Reset()

func (*GracefulFailoverResponseProto) String 

func (m *GracefulFailoverResponseProto) String() string

type HARequestSource 

type HARequestSource int32
const (
	HARequestSource_REQUEST_BY_USER        HARequestSource = 0
	HARequestSource_REQUEST_BY_USER_FORCED HARequestSource = 1
	HARequestSource_REQUEST_BY_ZKFC        HARequestSource = 2
)

func (HARequestSource) Enum 

func (x HARequestSource) Enum() *HARequestSource

func (HARequestSource) EnumDescriptor 

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

func (HARequestSource) String 

func (x HARequestSource) String() string

func (*HARequestSource) UnmarshalJSON 

func (x *HARequestSource) UnmarshalJSON(data []byte) error

type HAServiceStateProto 

type HAServiceStateProto int32
const (
	HAServiceStateProto_INITIALIZING HAServiceStateProto = 0
	HAServiceStateProto_ACTIVE       HAServiceStateProto = 1
	HAServiceStateProto_STANDBY      HAServiceStateProto = 2
)

func (HAServiceStateProto) Enum 

func (x HAServiceStateProto) Enum() *HAServiceStateProto

func (HAServiceStateProto) EnumDescriptor 

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

func (HAServiceStateProto) String 

func (x HAServiceStateProto) String() string

func (*HAServiceStateProto) UnmarshalJSON 

func (x *HAServiceStateProto) UnmarshalJSON(data []byte) error

type HAStateChangeRequestInfoProto 

type HAStateChangeRequestInfoProto struct {
	ReqSource        *HARequestSource `protobuf:"varint,1,req,name=reqSource,enum=hadoop.common.HARequestSource" json:"reqSource,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*HAStateChangeRequestInfoProto) Descriptor 

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

func (*HAStateChangeRequestInfoProto) GetReqSource 

func (m *HAStateChangeRequestInfoProto) GetReqSource() HARequestSource

func (*HAStateChangeRequestInfoProto) ProtoMessage 

func (*HAStateChangeRequestInfoProto) ProtoMessage()

func (*HAStateChangeRequestInfoProto) Reset 

func (m *HAStateChangeRequestInfoProto) Reset()

func (*HAStateChangeRequestInfoProto) String 

func (m *HAStateChangeRequestInfoProto) String() string

type IpcConnectionContextProto 

type IpcConnectionContextProto struct {
	// UserInfo beyond what is determined as part of security handshake
	// at connection time (kerberos, tokens etc).
	UserInfo *UserInformationProto `protobuf:"bytes,2,opt,name=userInfo" json:"userInfo,omitempty"`
	// Protocol name for next rpc layer.
	// The client created a proxy with this protocol name
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* The connection context is sent as part of the connection establishment. It establishes the context for ALL Rpc calls within the connection.

func (*IpcConnectionContextProto) Descriptor 

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

func (*IpcConnectionContextProto) GetProtocol 

func (m *IpcConnectionContextProto) GetProtocol() string

func (*IpcConnectionContextProto) GetUserInfo 

func (m *IpcConnectionContextProto) GetUserInfo() *UserInformationProto

func (*IpcConnectionContextProto) ProtoMessage 

func (*IpcConnectionContextProto) ProtoMessage()

func (*IpcConnectionContextProto) Reset 

func (m *IpcConnectionContextProto) Reset()

func (*IpcConnectionContextProto) String 

func (m *IpcConnectionContextProto) String() string

type ListSpanReceiversRequestProto 

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

func (*ListSpanReceiversRequestProto) Descriptor 

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

func (*ListSpanReceiversRequestProto) ProtoMessage 

func (*ListSpanReceiversRequestProto) ProtoMessage()

func (*ListSpanReceiversRequestProto) Reset 

func (m *ListSpanReceiversRequestProto) Reset()

func (*ListSpanReceiversRequestProto) String 

func (m *ListSpanReceiversRequestProto) String() string

type ListSpanReceiversResponseProto 

type ListSpanReceiversResponseProto struct {
	Descriptions     []*SpanReceiverListInfo `protobuf:"bytes,1,rep,name=descriptions" json:"descriptions,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*ListSpanReceiversResponseProto) Descriptor 

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

func (*ListSpanReceiversResponseProto) GetDescriptions 

func (m *ListSpanReceiversResponseProto) GetDescriptions() []*SpanReceiverListInfo

func (*ListSpanReceiversResponseProto) ProtoMessage 

func (*ListSpanReceiversResponseProto) ProtoMessage()

func (*ListSpanReceiversResponseProto) Reset 

func (m *ListSpanReceiversResponseProto) Reset()

func (*ListSpanReceiversResponseProto) String 

func (m *ListSpanReceiversResponseProto) String() string

type MonitorHealthRequestProto 

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

* void request

func (*MonitorHealthRequestProto) Descriptor 

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

func (*MonitorHealthRequestProto) ProtoMessage 

func (*MonitorHealthRequestProto) ProtoMessage()

func (*MonitorHealthRequestProto) Reset 

func (m *MonitorHealthRequestProto) Reset()

func (*MonitorHealthRequestProto) String 

func (m *MonitorHealthRequestProto) String() string

type MonitorHealthResponseProto 

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

* void response

func (*MonitorHealthResponseProto) Descriptor 

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

func (*MonitorHealthResponseProto) ProtoMessage 

func (*MonitorHealthResponseProto) ProtoMessage()

func (*MonitorHealthResponseProto) Reset 

func (m *MonitorHealthResponseProto) Reset()

func (*MonitorHealthResponseProto) String 

func (m *MonitorHealthResponseProto) String() string

type ProtocolSignatureProto 

type ProtocolSignatureProto struct {
	Version          *uint64  `protobuf:"varint,1,req,name=version" json:"version,omitempty"`
	Methods          []uint32 `protobuf:"varint,2,rep,name=methods" json:"methods,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ProtocolSignatureProto) Descriptor 

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

func (*ProtocolSignatureProto) GetMethods 

func (m *ProtocolSignatureProto) GetMethods() []uint32

func (*ProtocolSignatureProto) GetVersion 

func (m *ProtocolSignatureProto) GetVersion() uint64

func (*ProtocolSignatureProto) ProtoMessage 

func (*ProtocolSignatureProto) ProtoMessage()

func (*ProtocolSignatureProto) Reset 

func (m *ProtocolSignatureProto) Reset()

func (*ProtocolSignatureProto) String 

func (m *ProtocolSignatureProto) String() string

type ProtocolVersionProto 

type ProtocolVersionProto struct {
	RpcKind          *string  `protobuf:"bytes,1,req,name=rpcKind" json:"rpcKind,omitempty"`
	Versions         []uint64 `protobuf:"varint,2,rep,name=versions" json:"versions,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Protocol version with corresponding rpc kind.

func (*ProtocolVersionProto) Descriptor 

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

func (*ProtocolVersionProto) GetRpcKind 

func (m *ProtocolVersionProto) GetRpcKind() string

func (*ProtocolVersionProto) GetVersions 

func (m *ProtocolVersionProto) GetVersions() []uint64

func (*ProtocolVersionProto) ProtoMessage 

func (*ProtocolVersionProto) ProtoMessage()

func (*ProtocolVersionProto) Reset 

func (m *ProtocolVersionProto) Reset()

func (*ProtocolVersionProto) String 

func (m *ProtocolVersionProto) String() string

type RPCCallerContextProto 

type RPCCallerContextProto struct {
	Context          *string `protobuf:"bytes,1,req,name=context" json:"context,omitempty"`
	Signature        []byte  `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Used to pass through the call context entry after an RPC is made.

func (*RPCCallerContextProto) Descriptor 

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

func (*RPCCallerContextProto) GetContext 

func (m *RPCCallerContextProto) GetContext() string

func (*RPCCallerContextProto) GetSignature 

func (m *RPCCallerContextProto) GetSignature() []byte

func (*RPCCallerContextProto) ProtoMessage 

func (*RPCCallerContextProto) ProtoMessage()

func (*RPCCallerContextProto) Reset 

func (m *RPCCallerContextProto) Reset()

func (*RPCCallerContextProto) String 

func (m *RPCCallerContextProto) String() string

type RPCTraceInfoProto 

type RPCTraceInfoProto struct {
	TraceId          *int64 `protobuf:"varint,1,opt,name=traceId" json:"traceId,omitempty"`
	ParentId         *int64 `protobuf:"varint,2,opt,name=parentId" json:"parentId,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Used to pass through the information necessary to continue a trace after an RPC is made. All we need is the traceid (so we know the overarching trace this message is a part of), and the id of the current span when this message was sent, so we know what span caused the new span we will create when this message is received.

func (*RPCTraceInfoProto) Descriptor 

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

func (*RPCTraceInfoProto) GetParentId 

func (m *RPCTraceInfoProto) GetParentId() int64

func (*RPCTraceInfoProto) GetTraceId 

func (m *RPCTraceInfoProto) GetTraceId() int64

func (*RPCTraceInfoProto) ProtoMessage 

func (*RPCTraceInfoProto) ProtoMessage()

func (*RPCTraceInfoProto) Reset 

func (m *RPCTraceInfoProto) Reset()

func (*RPCTraceInfoProto) String 

func (m *RPCTraceInfoProto) String() string

type RefreshCallQueueRequestProto 

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

* 

Refresh callqueue request.

func (*RefreshCallQueueRequestProto) Descriptor 

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

func (*RefreshCallQueueRequestProto) ProtoMessage 

func (*RefreshCallQueueRequestProto) ProtoMessage()

func (*RefreshCallQueueRequestProto) Reset 

func (m *RefreshCallQueueRequestProto) Reset()

func (*RefreshCallQueueRequestProto) String 

func (m *RefreshCallQueueRequestProto) String() string

type RefreshCallQueueResponseProto 

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

* void response.

func (*RefreshCallQueueResponseProto) Descriptor 

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

func (*RefreshCallQueueResponseProto) ProtoMessage 

func (*RefreshCallQueueResponseProto) ProtoMessage()

func (*RefreshCallQueueResponseProto) Reset 

func (m *RefreshCallQueueResponseProto) Reset()

func (*RefreshCallQueueResponseProto) String 

func (m *RefreshCallQueueResponseProto) String() string

type RefreshServiceAclRequestProto 

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

* 

Refresh service acl request.

func (*RefreshServiceAclRequestProto) Descriptor 

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

func (*RefreshServiceAclRequestProto) ProtoMessage 

func (*RefreshServiceAclRequestProto) ProtoMessage()

func (*RefreshServiceAclRequestProto) Reset 

func (m *RefreshServiceAclRequestProto) Reset()

func (*RefreshServiceAclRequestProto) String 

func (m *RefreshServiceAclRequestProto) String() string

type RefreshServiceAclResponseProto 

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

* void response

func (*RefreshServiceAclResponseProto) Descriptor 

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

func (*RefreshServiceAclResponseProto) ProtoMessage 

func (*RefreshServiceAclResponseProto) ProtoMessage()

func (*RefreshServiceAclResponseProto) Reset 

func (m *RefreshServiceAclResponseProto) Reset()

func (*RefreshServiceAclResponseProto) String 

func (m *RefreshServiceAclResponseProto) String() string

type RefreshSuperUserGroupsConfigurationRequestProto 

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

* Refresh superuser configuration request.

func (*RefreshSuperUserGroupsConfigurationRequestProto) Descriptor 

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

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage 

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationRequestProto) Reset 

func (m *RefreshSuperUserGroupsConfigurationRequestProto) Reset()

func (*RefreshSuperUserGroupsConfigurationRequestProto) String 

func (m *RefreshSuperUserGroupsConfigurationRequestProto) String() string

type RefreshSuperUserGroupsConfigurationResponseProto 

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

* void response

func (*RefreshSuperUserGroupsConfigurationResponseProto) Descriptor 

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

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage 

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationResponseProto) Reset 

func (m *RefreshSuperUserGroupsConfigurationResponseProto) Reset()

func (*RefreshSuperUserGroupsConfigurationResponseProto) String 

func (m *RefreshSuperUserGroupsConfigurationResponseProto) String() string

type RefreshUserToGroupsMappingsRequestProto 

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

* 

Refresh user to group mappings request.

func (*RefreshUserToGroupsMappingsRequestProto) Descriptor 

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

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage 

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsRequestProto) Reset 

func (m *RefreshUserToGroupsMappingsRequestProto) Reset()

func (*RefreshUserToGroupsMappingsRequestProto) String 

func (m *RefreshUserToGroupsMappingsRequestProto) String() string

type RefreshUserToGroupsMappingsResponseProto 

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

* void response

func (*RefreshUserToGroupsMappingsResponseProto) Descriptor 

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

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage 

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsResponseProto) Reset 

func (m *RefreshUserToGroupsMappingsResponseProto) Reset()

func (*RefreshUserToGroupsMappingsResponseProto) String 

func (m *RefreshUserToGroupsMappingsResponseProto) String() string

type RemoveSpanReceiverRequestProto 

type RemoveSpanReceiverRequestProto struct {
	Id               *int64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RemoveSpanReceiverRequestProto) Descriptor 

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

func (*RemoveSpanReceiverRequestProto) GetId 

func (m *RemoveSpanReceiverRequestProto) GetId() int64

func (*RemoveSpanReceiverRequestProto) ProtoMessage 

func (*RemoveSpanReceiverRequestProto) ProtoMessage()

func (*RemoveSpanReceiverRequestProto) Reset 

func (m *RemoveSpanReceiverRequestProto) Reset()

func (*RemoveSpanReceiverRequestProto) String 

func (m *RemoveSpanReceiverRequestProto) String() string

type RemoveSpanReceiverResponseProto 

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

func (*RemoveSpanReceiverResponseProto) Descriptor 

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

func (*RemoveSpanReceiverResponseProto) ProtoMessage 

func (*RemoveSpanReceiverResponseProto) ProtoMessage()

func (*RemoveSpanReceiverResponseProto) Reset 

func (m *RemoveSpanReceiverResponseProto) Reset()

func (*RemoveSpanReceiverResponseProto) String 

func (m *RemoveSpanReceiverResponseProto) String() string

type RenewDelegationTokenRequestProto 

type RenewDelegationTokenRequestProto struct {
	Token            *TokenProto `protobuf:"bytes,1,req,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*RenewDelegationTokenRequestProto) Descriptor 

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

func (*RenewDelegationTokenRequestProto) GetToken 

func (m *RenewDelegationTokenRequestProto) GetToken() *TokenProto

func (*RenewDelegationTokenRequestProto) ProtoMessage 

func (*RenewDelegationTokenRequestProto) ProtoMessage()

func (*RenewDelegationTokenRequestProto) Reset 

func (m *RenewDelegationTokenRequestProto) Reset()

func (*RenewDelegationTokenRequestProto) String 

func (m *RenewDelegationTokenRequestProto) String() string

type RenewDelegationTokenResponseProto 

type RenewDelegationTokenResponseProto struct {
	NewExpiryTime    *uint64 `protobuf:"varint,1,req,name=newExpiryTime" json:"newExpiryTime,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RenewDelegationTokenResponseProto) Descriptor 

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

func (*RenewDelegationTokenResponseProto) GetNewExpiryTime 

func (m *RenewDelegationTokenResponseProto) GetNewExpiryTime() uint64

func (*RenewDelegationTokenResponseProto) ProtoMessage 

func (*RenewDelegationTokenResponseProto) ProtoMessage()

func (*RenewDelegationTokenResponseProto) Reset 

func (m *RenewDelegationTokenResponseProto) Reset()

func (*RenewDelegationTokenResponseProto) String 

func (m *RenewDelegationTokenResponseProto) String() string

type RequestHeaderProto 

type RequestHeaderProto struct {
	// * Name of the RPC method
	MethodName *string `protobuf:"bytes,1,req,name=methodName" json:"methodName,omitempty"`
	// *
	// RPCs for a particular interface (ie protocol) are done using a
	// IPC connection that is setup using rpcProxy.
	// The rpcProxy's has a declared protocol name that is
	// sent form client to server at connection time.
	//
	// Each Rpc call also sends a protocol name
	// (called declaringClassprotocolName). This name is usually the same
	// as the connection protocol name except in some cases.
	// For example metaProtocols such ProtocolInfoProto which get metainfo
	// about the protocol reuse the connection but need to indicate that
	// the actual protocol is different (i.e. the protocol is
	// ProtocolInfoProto) since they reuse the connection; in this case
	// the declaringClassProtocolName field is set to the ProtocolInfoProto
	DeclaringClassProtocolName *string `protobuf:"bytes,2,req,name=declaringClassProtocolName" json:"declaringClassProtocolName,omitempty"`
	// * protocol version of class declaring the called method
	ClientProtocolVersion *uint64 `protobuf:"varint,3,req,name=clientProtocolVersion" json:"clientProtocolVersion,omitempty"`
	XXX_unrecognized      []byte  `json:"-"`
}

* This message is the header for the Protobuf Rpc Engine when sending a RPC request from RPC client to the RPC server. The actual request (serialized as protobuf) follows this request.

No special header is needed for the Rpc Response for Protobuf Rpc Engine. The normal RPC response header (see RpcHeader.proto) are sufficient.

func (*RequestHeaderProto) Descriptor 

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

func (*RequestHeaderProto) GetClientProtocolVersion 

func (m *RequestHeaderProto) GetClientProtocolVersion() uint64

func (*RequestHeaderProto) GetDeclaringClassProtocolName 

func (m *RequestHeaderProto) GetDeclaringClassProtocolName() string

func (*RequestHeaderProto) GetMethodName 

func (m *RequestHeaderProto) GetMethodName() string

func (*RequestHeaderProto) ProtoMessage 

func (*RequestHeaderProto) ProtoMessage()

func (*RequestHeaderProto) Reset 

func (m *RequestHeaderProto) Reset()

func (*RequestHeaderProto) String 

func (m *RequestHeaderProto) String() string

type RpcKindProto 

type RpcKindProto int32

* RpcKind determine the rpcEngine and the serialization of the rpc request 

const (
	RpcKindProto_RPC_BUILTIN         RpcKindProto = 0
	RpcKindProto_RPC_WRITABLE        RpcKindProto = 1
	RpcKindProto_RPC_PROTOCOL_BUFFER RpcKindProto = 2
)

func (RpcKindProto) Enum 

func (x RpcKindProto) Enum() *RpcKindProto

func (RpcKindProto) EnumDescriptor 

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

func (RpcKindProto) String 

func (x RpcKindProto) String() string

func (*RpcKindProto) UnmarshalJSON 

func (x *RpcKindProto) UnmarshalJSON(data []byte) error

type RpcRequestHeaderProto 

type RpcRequestHeaderProto struct {
	RpcKind  *RpcKindProto                         `protobuf:"varint,1,opt,name=rpcKind,enum=hadoop.common.RpcKindProto" json:"rpcKind,omitempty"`
	RpcOp    *RpcRequestHeaderProto_OperationProto `protobuf:"varint,2,opt,name=rpcOp,enum=hadoop.common.RpcRequestHeaderProto_OperationProto" json:"rpcOp,omitempty"`
	CallId   *int32                                `protobuf:"zigzag32,3,req,name=callId" json:"callId,omitempty"`
	ClientId []byte                                `protobuf:"bytes,4,req,name=clientId" json:"clientId,omitempty"`
	// clientId + callId uniquely identifies a request
	// retry count, 1 means this is the first retry
	RetryCount       *int32                 `protobuf:"zigzag32,5,opt,name=retryCount,def=-1" json:"retryCount,omitempty"`
	TraceInfo        *RPCTraceInfoProto     `protobuf:"bytes,6,opt,name=traceInfo" json:"traceInfo,omitempty"`
	CallerContext    *RPCCallerContextProto `protobuf:"bytes,7,opt,name=callerContext" json:"callerContext,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*RpcRequestHeaderProto) Descriptor 

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

func (*RpcRequestHeaderProto) GetCallId 

func (m *RpcRequestHeaderProto) GetCallId() int32

func (*RpcRequestHeaderProto) GetCallerContext 

func (m *RpcRequestHeaderProto) GetCallerContext() *RPCCallerContextProto

func (*RpcRequestHeaderProto) GetClientId 

func (m *RpcRequestHeaderProto) GetClientId() []byte

func (*RpcRequestHeaderProto) GetRetryCount 

func (m *RpcRequestHeaderProto) GetRetryCount() int32

func (*RpcRequestHeaderProto) GetRpcKind 

func (m *RpcRequestHeaderProto) GetRpcKind() RpcKindProto

func (*RpcRequestHeaderProto) GetRpcOp 

func (m *RpcRequestHeaderProto) GetRpcOp() RpcRequestHeaderProto_OperationProto

func (*RpcRequestHeaderProto) GetTraceInfo 

func (m *RpcRequestHeaderProto) GetTraceInfo() *RPCTraceInfoProto

func (*RpcRequestHeaderProto) ProtoMessage 

func (*RpcRequestHeaderProto) ProtoMessage()

func (*RpcRequestHeaderProto) Reset 

func (m *RpcRequestHeaderProto) Reset()

func (*RpcRequestHeaderProto) String 

func (m *RpcRequestHeaderProto) String() string

type RpcRequestHeaderProto_OperationProto 

type RpcRequestHeaderProto_OperationProto int32
const (
	RpcRequestHeaderProto_RPC_FINAL_PACKET        RpcRequestHeaderProto_OperationProto = 0
	RpcRequestHeaderProto_RPC_CONTINUATION_PACKET RpcRequestHeaderProto_OperationProto = 1
	RpcRequestHeaderProto_RPC_CLOSE_CONNECTION    RpcRequestHeaderProto_OperationProto = 2
)

func (RpcRequestHeaderProto_OperationProto) Enum 

func (x RpcRequestHeaderProto_OperationProto) Enum() *RpcRequestHeaderProto_OperationProto

func (RpcRequestHeaderProto_OperationProto) EnumDescriptor 

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

func (RpcRequestHeaderProto_OperationProto) String 

func (x RpcRequestHeaderProto_OperationProto) String() string

func (*RpcRequestHeaderProto_OperationProto) UnmarshalJSON 

func (x *RpcRequestHeaderProto_OperationProto) UnmarshalJSON(data []byte) error

type RpcResponseHeaderProto 

type RpcResponseHeaderProto struct {
	CallId              *uint32                                   `protobuf:"varint,1,req,name=callId" json:"callId,omitempty"`
	Status              *RpcResponseHeaderProto_RpcStatusProto    `protobuf:"varint,2,req,name=status,enum=hadoop.common.RpcResponseHeaderProto_RpcStatusProto" json:"status,omitempty"`
	ServerIpcVersionNum *uint32                                   `protobuf:"varint,3,opt,name=serverIpcVersionNum" json:"serverIpcVersionNum,omitempty"`
	ExceptionClassName  *string                                   `protobuf:"bytes,4,opt,name=exceptionClassName" json:"exceptionClassName,omitempty"`
	ErrorMsg            *string                                   `protobuf:"bytes,5,opt,name=errorMsg" json:"errorMsg,omitempty"`
	ErrorDetail         *RpcResponseHeaderProto_RpcErrorCodeProto `` /* 129-byte string literal not displayed */
	ClientId            []byte                                    `protobuf:"bytes,7,opt,name=clientId" json:"clientId,omitempty"`
	RetryCount          *int32                                    `protobuf:"zigzag32,8,opt,name=retryCount,def=-1" json:"retryCount,omitempty"`
	XXX_unrecognized    []byte                                    `json:"-"`
}

* Rpc Response Header +------------------------------------------------------------------+ | Rpc total response length in bytes (4 bytes int) | | (sum of next two parts) | +------------------------------------------------------------------+ | RpcResponseHeaderProto - serialized delimited ie has len | +------------------------------------------------------------------+ | if request is successful: | | - RpcResponse - The actual rpc response bytes follow | | the response header | | This response is serialized based on RpcKindProto | | if request fails : | | The rpc response header contains the necessary info | +------------------------------------------------------------------+

Note that rpc response header is also used when connection setup fails. Ie the response looks like a rpc response with a fake callId.

func (*RpcResponseHeaderProto) Descriptor 

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

func (*RpcResponseHeaderProto) GetCallId 

func (m *RpcResponseHeaderProto) GetCallId() uint32

func (*RpcResponseHeaderProto) GetClientId 

func (m *RpcResponseHeaderProto) GetClientId() []byte

func (*RpcResponseHeaderProto) GetErrorDetail 

func (m *RpcResponseHeaderProto) GetErrorDetail() RpcResponseHeaderProto_RpcErrorCodeProto

func (*RpcResponseHeaderProto) GetErrorMsg 

func (m *RpcResponseHeaderProto) GetErrorMsg() string

func (*RpcResponseHeaderProto) GetExceptionClassName 

func (m *RpcResponseHeaderProto) GetExceptionClassName() string

func (*RpcResponseHeaderProto) GetRetryCount 

func (m *RpcResponseHeaderProto) GetRetryCount() int32

func (*RpcResponseHeaderProto) GetServerIpcVersionNum 

func (m *RpcResponseHeaderProto) GetServerIpcVersionNum() uint32

func (*RpcResponseHeaderProto) GetStatus 

func (m *RpcResponseHeaderProto) GetStatus() RpcResponseHeaderProto_RpcStatusProto

func (*RpcResponseHeaderProto) ProtoMessage 

func (*RpcResponseHeaderProto) ProtoMessage()

func (*RpcResponseHeaderProto) Reset 

func (m *RpcResponseHeaderProto) Reset()

func (*RpcResponseHeaderProto) String 

func (m *RpcResponseHeaderProto) String() string

type RpcResponseHeaderProto_RpcErrorCodeProto 

type RpcResponseHeaderProto_RpcErrorCodeProto int32
const (
	// Non-fatal Rpc error - connection left open for future rpc calls
	RpcResponseHeaderProto_ERROR_APPLICATION          RpcResponseHeaderProto_RpcErrorCodeProto = 1
	RpcResponseHeaderProto_ERROR_NO_SUCH_METHOD       RpcResponseHeaderProto_RpcErrorCodeProto = 2
	RpcResponseHeaderProto_ERROR_NO_SUCH_PROTOCOL     RpcResponseHeaderProto_RpcErrorCodeProto = 3
	RpcResponseHeaderProto_ERROR_RPC_SERVER           RpcResponseHeaderProto_RpcErrorCodeProto = 4
	RpcResponseHeaderProto_ERROR_SERIALIZING_RESPONSE RpcResponseHeaderProto_RpcErrorCodeProto = 5
	RpcResponseHeaderProto_ERROR_RPC_VERSION_MISMATCH RpcResponseHeaderProto_RpcErrorCodeProto = 6
	// Fatal Server side Rpc error - connection closed
	RpcResponseHeaderProto_FATAL_UNKNOWN                   RpcResponseHeaderProto_RpcErrorCodeProto = 10
	RpcResponseHeaderProto_FATAL_UNSUPPORTED_SERIALIZATION RpcResponseHeaderProto_RpcErrorCodeProto = 11
	RpcResponseHeaderProto_FATAL_INVALID_RPC_HEADER        RpcResponseHeaderProto_RpcErrorCodeProto = 12
	RpcResponseHeaderProto_FATAL_DESERIALIZING_REQUEST     RpcResponseHeaderProto_RpcErrorCodeProto = 13
	RpcResponseHeaderProto_FATAL_VERSION_MISMATCH          RpcResponseHeaderProto_RpcErrorCodeProto = 14
	RpcResponseHeaderProto_FATAL_UNAUTHORIZED              RpcResponseHeaderProto_RpcErrorCodeProto = 15
)

func (RpcResponseHeaderProto_RpcErrorCodeProto) Enum 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) Enum() *RpcResponseHeaderProto_RpcErrorCodeProto

func (RpcResponseHeaderProto_RpcErrorCodeProto) EnumDescriptor 

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

func (RpcResponseHeaderProto_RpcErrorCodeProto) String 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) String() string

func (*RpcResponseHeaderProto_RpcErrorCodeProto) UnmarshalJSON 

func (x *RpcResponseHeaderProto_RpcErrorCodeProto) UnmarshalJSON(data []byte) error

type RpcResponseHeaderProto_RpcStatusProto 

type RpcResponseHeaderProto_RpcStatusProto int32
const (
	RpcResponseHeaderProto_SUCCESS RpcResponseHeaderProto_RpcStatusProto = 0
	RpcResponseHeaderProto_ERROR   RpcResponseHeaderProto_RpcStatusProto = 1
	RpcResponseHeaderProto_FATAL   RpcResponseHeaderProto_RpcStatusProto = 2
)

func (RpcResponseHeaderProto_RpcStatusProto) Enum 

func (x RpcResponseHeaderProto_RpcStatusProto) Enum() *RpcResponseHeaderProto_RpcStatusProto

func (RpcResponseHeaderProto_RpcStatusProto) EnumDescriptor 

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

func (RpcResponseHeaderProto_RpcStatusProto) String 

func (x RpcResponseHeaderProto_RpcStatusProto) String() string

func (*RpcResponseHeaderProto_RpcStatusProto) UnmarshalJSON 

func (x *RpcResponseHeaderProto_RpcStatusProto) UnmarshalJSON(data []byte) error

type RpcSaslProto 

type RpcSaslProto struct {
	Version          *uint32                  `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	State            *RpcSaslProto_SaslState  `protobuf:"varint,2,req,name=state,enum=hadoop.common.RpcSaslProto_SaslState" json:"state,omitempty"`
	Token            []byte                   `protobuf:"bytes,3,opt,name=token" json:"token,omitempty"`
	Auths            []*RpcSaslProto_SaslAuth `protobuf:"bytes,4,rep,name=auths" json:"auths,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*RpcSaslProto) Descriptor 

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

func (*RpcSaslProto) GetAuths 

func (m *RpcSaslProto) GetAuths() []*RpcSaslProto_SaslAuth

func (*RpcSaslProto) GetState 

func (m *RpcSaslProto) GetState() RpcSaslProto_SaslState

func (*RpcSaslProto) GetToken 

func (m *RpcSaslProto) GetToken() []byte

func (*RpcSaslProto) GetVersion 

func (m *RpcSaslProto) GetVersion() uint32

func (*RpcSaslProto) ProtoMessage 

func (*RpcSaslProto) ProtoMessage()

func (*RpcSaslProto) Reset 

func (m *RpcSaslProto) Reset()

func (*RpcSaslProto) String 

func (m *RpcSaslProto) String() string

type RpcSaslProto_SaslAuth 

type RpcSaslProto_SaslAuth struct {
	Method           *string `protobuf:"bytes,1,req,name=method" json:"method,omitempty"`
	Mechanism        *string `protobuf:"bytes,2,req,name=mechanism" json:"mechanism,omitempty"`
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	ServerId         *string `protobuf:"bytes,4,opt,name=serverId" json:"serverId,omitempty"`
	Challenge        []byte  `protobuf:"bytes,5,opt,name=challenge" json:"challenge,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RpcSaslProto_SaslAuth) Descriptor 

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

func (*RpcSaslProto_SaslAuth) GetChallenge 

func (m *RpcSaslProto_SaslAuth) GetChallenge() []byte

func (*RpcSaslProto_SaslAuth) GetMechanism 

func (m *RpcSaslProto_SaslAuth) GetMechanism() string

func (*RpcSaslProto_SaslAuth) GetMethod 

func (m *RpcSaslProto_SaslAuth) GetMethod() string

func (*RpcSaslProto_SaslAuth) GetProtocol 

func (m *RpcSaslProto_SaslAuth) GetProtocol() string

func (*RpcSaslProto_SaslAuth) GetServerId 

func (m *RpcSaslProto_SaslAuth) GetServerId() string

func (*RpcSaslProto_SaslAuth) ProtoMessage 

func (*RpcSaslProto_SaslAuth) ProtoMessage()

func (*RpcSaslProto_SaslAuth) Reset 

func (m *RpcSaslProto_SaslAuth) Reset()

func (*RpcSaslProto_SaslAuth) String 

func (m *RpcSaslProto_SaslAuth) String() string

type RpcSaslProto_SaslState 

type RpcSaslProto_SaslState int32
const (
	RpcSaslProto_SUCCESS   RpcSaslProto_SaslState = 0
	RpcSaslProto_NEGOTIATE RpcSaslProto_SaslState = 1
	RpcSaslProto_INITIATE  RpcSaslProto_SaslState = 2
	RpcSaslProto_CHALLENGE RpcSaslProto_SaslState = 3
	RpcSaslProto_RESPONSE  RpcSaslProto_SaslState = 4
	RpcSaslProto_WRAP      RpcSaslProto_SaslState = 5
)

func (RpcSaslProto_SaslState) Enum 

func (x RpcSaslProto_SaslState) Enum() *RpcSaslProto_SaslState

func (RpcSaslProto_SaslState) EnumDescriptor 

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

func (RpcSaslProto_SaslState) String 

func (x RpcSaslProto_SaslState) String() string

func (*RpcSaslProto_SaslState) UnmarshalJSON 

func (x *RpcSaslProto_SaslState) UnmarshalJSON(data []byte) error

type SpanReceiverListInfo 

type SpanReceiverListInfo struct {
	Id               *int64  `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	ClassName        *string `protobuf:"bytes,2,req,name=className" json:"className,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SpanReceiverListInfo) Descriptor 

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

func (*SpanReceiverListInfo) GetClassName 

func (m *SpanReceiverListInfo) GetClassName() string

func (*SpanReceiverListInfo) GetId 

func (m *SpanReceiverListInfo) GetId() int64

func (*SpanReceiverListInfo) ProtoMessage 

func (*SpanReceiverListInfo) ProtoMessage()

func (*SpanReceiverListInfo) Reset 

func (m *SpanReceiverListInfo) Reset()

func (*SpanReceiverListInfo) String 

func (m *SpanReceiverListInfo) String() string

type TokenProto 

type TokenProto struct {
	Identifier       []byte  `protobuf:"bytes,1,req,name=identifier" json:"identifier,omitempty"`
	Password         []byte  `protobuf:"bytes,2,req,name=password" json:"password,omitempty"`
	Kind             *string `protobuf:"bytes,3,req,name=kind" json:"kind,omitempty"`
	Service          *string `protobuf:"bytes,4,req,name=service" json:"service,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Security token identifier

func (*TokenProto) Descriptor 

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

func (*TokenProto) GetIdentifier 

func (m *TokenProto) GetIdentifier() []byte

func (*TokenProto) GetKind 

func (m *TokenProto) GetKind() string

func (*TokenProto) GetPassword 

func (m *TokenProto) GetPassword() []byte

func (*TokenProto) GetService 

func (m *TokenProto) GetService() string

func (*TokenProto) ProtoMessage 

func (*TokenProto) ProtoMessage()

func (*TokenProto) Reset 

func (m *TokenProto) Reset()

func (*TokenProto) String 

func (m *TokenProto) String() string

type TransitionToActiveRequestProto 

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

* void request

func (*TransitionToActiveRequestProto) Descriptor 

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

func (*TransitionToActiveRequestProto) GetReqInfo 

func (m *TransitionToActiveRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToActiveRequestProto) ProtoMessage 

func (*TransitionToActiveRequestProto) ProtoMessage()

func (*TransitionToActiveRequestProto) Reset 

func (m *TransitionToActiveRequestProto) Reset()

func (*TransitionToActiveRequestProto) String 

func (m *TransitionToActiveRequestProto) String() string

type TransitionToActiveResponseProto 

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

* void response

func (*TransitionToActiveResponseProto) Descriptor 

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

func (*TransitionToActiveResponseProto) ProtoMessage 

func (*TransitionToActiveResponseProto) ProtoMessage()

func (*TransitionToActiveResponseProto) Reset 

func (m *TransitionToActiveResponseProto) Reset()

func (*TransitionToActiveResponseProto) String 

func (m *TransitionToActiveResponseProto) String() string

type TransitionToStandbyRequestProto 

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

* void request

func (*TransitionToStandbyRequestProto) Descriptor 

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

func (*TransitionToStandbyRequestProto) GetReqInfo 

func (m *TransitionToStandbyRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToStandbyRequestProto) ProtoMessage 

func (*TransitionToStandbyRequestProto) ProtoMessage()

func (*TransitionToStandbyRequestProto) Reset 

func (m *TransitionToStandbyRequestProto) Reset()

func (*TransitionToStandbyRequestProto) String 

func (m *TransitionToStandbyRequestProto) String() string

type TransitionToStandbyResponseProto 

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

* void response

func (*TransitionToStandbyResponseProto) Descriptor 

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

func (*TransitionToStandbyResponseProto) ProtoMessage 

func (*TransitionToStandbyResponseProto) ProtoMessage()

func (*TransitionToStandbyResponseProto) Reset 

func (m *TransitionToStandbyResponseProto) Reset()

func (*TransitionToStandbyResponseProto) String 

func (m *TransitionToStandbyResponseProto) String() string

type UserInformationProto 

type UserInformationProto struct {
	EffectiveUser    *string `protobuf:"bytes,1,opt,name=effectiveUser" json:"effectiveUser,omitempty"`
	RealUser         *string `protobuf:"bytes,2,opt,name=realUser" json:"realUser,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Spec for UserInformationProto is specified in ProtoUtil#makeIpcConnectionContext

func (*UserInformationProto) Descriptor 

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

func (*UserInformationProto) GetEffectiveUser 

func (m *UserInformationProto) GetEffectiveUser() string

func (*UserInformationProto) GetRealUser 

func (m *UserInformationProto) GetRealUser() string

func (*UserInformationProto) ProtoMessage 

func (*UserInformationProto) ProtoMessage()

func (*UserInformationProto) Reset 

func (m *UserInformationProto) Reset()

func (*UserInformationProto) String 

func (m *UserInformationProto) 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.