hadoop_common

package
Version: v1.1.3 Latest Latest
Warning

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

Go to latest
Published: Jun 22, 2018 License: MIT Imports: 3 Imported by: 138

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 added in v1.0.0

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 added in v1.1.1

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

func (*AddSpanReceiverRequestProto) GetClassName added in v1.0.0

func (m *AddSpanReceiverRequestProto) GetClassName() string

func (*AddSpanReceiverRequestProto) GetConfig added in v1.0.0

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

func (*AddSpanReceiverRequestProto) ProtoMessage added in v1.0.0

func (*AddSpanReceiverRequestProto) ProtoMessage()

func (*AddSpanReceiverRequestProto) Reset added in v1.0.0

func (m *AddSpanReceiverRequestProto) Reset()

func (*AddSpanReceiverRequestProto) String added in v1.0.0

func (m *AddSpanReceiverRequestProto) String() string

type AddSpanReceiverResponseProto added in v1.0.0

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

func (*AddSpanReceiverResponseProto) Descriptor added in v1.1.1

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

func (*AddSpanReceiverResponseProto) GetId added in v1.0.0

func (*AddSpanReceiverResponseProto) ProtoMessage added in v1.0.0

func (*AddSpanReceiverResponseProto) ProtoMessage()

func (*AddSpanReceiverResponseProto) Reset added in v1.0.0

func (m *AddSpanReceiverResponseProto) Reset()

func (*AddSpanReceiverResponseProto) String added in v1.0.0

type CancelDelegationTokenRequestProto

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

func (*CancelDelegationTokenRequestProto) Descriptor added in v1.1.1

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

func (*CancelDelegationTokenRequestProto) GetToken

func (*CancelDelegationTokenRequestProto) ProtoMessage

func (*CancelDelegationTokenRequestProto) ProtoMessage()

func (*CancelDelegationTokenRequestProto) Reset

func (*CancelDelegationTokenRequestProto) String

type CancelDelegationTokenResponseProto

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

func (*CancelDelegationTokenResponseProto) Descriptor added in v1.1.1

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

func (*CancelDelegationTokenResponseProto) ProtoMessage

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) Reset

func (*CancelDelegationTokenResponseProto) String

type CedeActiveRequestProto added in v1.0.0

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

func (*CedeActiveRequestProto) Descriptor added in v1.1.1

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

func (*CedeActiveRequestProto) GetMillisToCede added in v1.0.0

func (m *CedeActiveRequestProto) GetMillisToCede() uint32

func (*CedeActiveRequestProto) ProtoMessage added in v1.0.0

func (*CedeActiveRequestProto) ProtoMessage()

func (*CedeActiveRequestProto) Reset added in v1.0.0

func (m *CedeActiveRequestProto) Reset()

func (*CedeActiveRequestProto) String added in v1.0.0

func (m *CedeActiveRequestProto) String() string

type CedeActiveResponseProto added in v1.0.0

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

func (*CedeActiveResponseProto) Descriptor added in v1.1.1

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

func (*CedeActiveResponseProto) ProtoMessage added in v1.0.0

func (*CedeActiveResponseProto) ProtoMessage()

func (*CedeActiveResponseProto) Reset added in v1.0.0

func (m *CedeActiveResponseProto) Reset()

func (*CedeActiveResponseProto) String added in v1.0.0

func (m *CedeActiveResponseProto) String() string

type ConfigPair added in v1.0.0

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 added in v1.1.1

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

func (*ConfigPair) GetKey added in v1.0.0

func (m *ConfigPair) GetKey() string

func (*ConfigPair) GetValue added in v1.0.0

func (m *ConfigPair) GetValue() string

func (*ConfigPair) ProtoMessage added in v1.0.0

func (*ConfigPair) ProtoMessage()

func (*ConfigPair) Reset added in v1.0.0

func (m *ConfigPair) Reset()

func (*ConfigPair) String added in v1.0.0

func (m *ConfigPair) String() string

type GenericRefreshRequestProto added in v1.0.0

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 added in v1.1.1

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

func (*GenericRefreshRequestProto) GetArgs added in v1.0.0

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

func (*GenericRefreshRequestProto) GetIdentifier added in v1.0.0

func (m *GenericRefreshRequestProto) GetIdentifier() string

func (*GenericRefreshRequestProto) ProtoMessage added in v1.0.0

func (*GenericRefreshRequestProto) ProtoMessage()

func (*GenericRefreshRequestProto) Reset added in v1.0.0

func (m *GenericRefreshRequestProto) Reset()

func (*GenericRefreshRequestProto) String added in v1.0.0

func (m *GenericRefreshRequestProto) String() string

type GenericRefreshResponseCollectionProto added in v1.0.0

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 added in v1.1.1

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

func (*GenericRefreshResponseCollectionProto) GetResponses added in v1.0.0

func (*GenericRefreshResponseCollectionProto) ProtoMessage added in v1.0.0

func (*GenericRefreshResponseCollectionProto) ProtoMessage()

func (*GenericRefreshResponseCollectionProto) Reset added in v1.0.0

func (*GenericRefreshResponseCollectionProto) String added in v1.0.0

type GenericRefreshResponseProto added in v1.0.0

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 added in v1.1.1

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

func (*GenericRefreshResponseProto) GetExitStatus added in v1.0.0

func (m *GenericRefreshResponseProto) GetExitStatus() int32

func (*GenericRefreshResponseProto) GetSenderName added in v1.0.0

func (m *GenericRefreshResponseProto) GetSenderName() string

func (*GenericRefreshResponseProto) GetUserMessage added in v1.0.0

func (m *GenericRefreshResponseProto) GetUserMessage() string

func (*GenericRefreshResponseProto) ProtoMessage added in v1.0.0

func (*GenericRefreshResponseProto) ProtoMessage()

func (*GenericRefreshResponseProto) Reset added in v1.0.0

func (m *GenericRefreshResponseProto) Reset()

func (*GenericRefreshResponseProto) String added in v1.0.0

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 added in v1.1.1

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

type GetDelegationTokenResponseProto

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

func (*GetDelegationTokenResponseProto) Descriptor added in v1.1.1

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

func (*GetDelegationTokenResponseProto) GetToken

func (*GetDelegationTokenResponseProto) ProtoMessage

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) Reset

func (*GetDelegationTokenResponseProto) String

type GetGroupsForUserRequestProto added in v1.0.0

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 added in v1.1.1

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

func (*GetGroupsForUserRequestProto) GetUser added in v1.0.0

func (m *GetGroupsForUserRequestProto) GetUser() string

func (*GetGroupsForUserRequestProto) ProtoMessage added in v1.0.0

func (*GetGroupsForUserRequestProto) ProtoMessage()

func (*GetGroupsForUserRequestProto) Reset added in v1.0.0

func (m *GetGroupsForUserRequestProto) Reset()

func (*GetGroupsForUserRequestProto) String added in v1.0.0

type GetGroupsForUserResponseProto added in v1.0.0

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 added in v1.1.1

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

func (*GetGroupsForUserResponseProto) GetGroups added in v1.0.0

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

func (*GetGroupsForUserResponseProto) ProtoMessage added in v1.0.0

func (*GetGroupsForUserResponseProto) ProtoMessage()

func (*GetGroupsForUserResponseProto) Reset added in v1.0.0

func (m *GetGroupsForUserResponseProto) Reset()

func (*GetGroupsForUserResponseProto) String added in v1.0.0

type GetProtocolSignatureRequestProto added in v1.0.0

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 added in v1.1.1

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

func (*GetProtocolSignatureRequestProto) GetProtocol added in v1.0.0

func (m *GetProtocolSignatureRequestProto) GetProtocol() string

func (*GetProtocolSignatureRequestProto) GetRpcKind added in v1.0.0

func (m *GetProtocolSignatureRequestProto) GetRpcKind() string

func (*GetProtocolSignatureRequestProto) ProtoMessage added in v1.0.0

func (*GetProtocolSignatureRequestProto) ProtoMessage()

func (*GetProtocolSignatureRequestProto) Reset added in v1.0.0

func (*GetProtocolSignatureRequestProto) String added in v1.0.0

type GetProtocolSignatureResponseProto added in v1.0.0

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 added in v1.1.1

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

func (*GetProtocolSignatureResponseProto) GetProtocolSignature added in v1.0.0

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

func (*GetProtocolSignatureResponseProto) ProtoMessage added in v1.0.0

func (*GetProtocolSignatureResponseProto) ProtoMessage()

func (*GetProtocolSignatureResponseProto) Reset added in v1.0.0

func (*GetProtocolSignatureResponseProto) String added in v1.0.0

type GetProtocolVersionsRequestProto added in v1.0.0

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 added in v1.1.1

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

func (*GetProtocolVersionsRequestProto) GetProtocol added in v1.0.0

func (m *GetProtocolVersionsRequestProto) GetProtocol() string

func (*GetProtocolVersionsRequestProto) ProtoMessage added in v1.0.0

func (*GetProtocolVersionsRequestProto) ProtoMessage()

func (*GetProtocolVersionsRequestProto) Reset added in v1.0.0

func (*GetProtocolVersionsRequestProto) String added in v1.0.0

type GetProtocolVersionsResponseProto added in v1.0.0

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 added in v1.1.1

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

func (*GetProtocolVersionsResponseProto) GetProtocolVersions added in v1.0.0

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

func (*GetProtocolVersionsResponseProto) ProtoMessage added in v1.0.0

func (*GetProtocolVersionsResponseProto) ProtoMessage()

func (*GetProtocolVersionsResponseProto) Reset added in v1.0.0

func (*GetProtocolVersionsResponseProto) String added in v1.0.0

type GetServiceStatusRequestProto added in v1.0.0

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

* void request

func (*GetServiceStatusRequestProto) Descriptor added in v1.1.1

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

func (*GetServiceStatusRequestProto) ProtoMessage added in v1.0.0

func (*GetServiceStatusRequestProto) ProtoMessage()

func (*GetServiceStatusRequestProto) Reset added in v1.0.0

func (m *GetServiceStatusRequestProto) Reset()

func (*GetServiceStatusRequestProto) String added in v1.0.0

type GetServiceStatusResponseProto added in v1.0.0

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 added in v1.1.1

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

func (*GetServiceStatusResponseProto) GetNotReadyReason added in v1.0.0

func (m *GetServiceStatusResponseProto) GetNotReadyReason() string

func (*GetServiceStatusResponseProto) GetReadyToBecomeActive added in v1.0.0

func (m *GetServiceStatusResponseProto) GetReadyToBecomeActive() bool

func (*GetServiceStatusResponseProto) GetState added in v1.0.0

func (*GetServiceStatusResponseProto) ProtoMessage added in v1.0.0

func (*GetServiceStatusResponseProto) ProtoMessage()

func (*GetServiceStatusResponseProto) Reset added in v1.0.0

func (m *GetServiceStatusResponseProto) Reset()

func (*GetServiceStatusResponseProto) String added in v1.0.0

type GracefulFailoverRequestProto added in v1.0.0

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

func (*GracefulFailoverRequestProto) Descriptor added in v1.1.1

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

func (*GracefulFailoverRequestProto) ProtoMessage added in v1.0.0

func (*GracefulFailoverRequestProto) ProtoMessage()

func (*GracefulFailoverRequestProto) Reset added in v1.0.0

func (m *GracefulFailoverRequestProto) Reset()

func (*GracefulFailoverRequestProto) String added in v1.0.0

type GracefulFailoverResponseProto added in v1.0.0

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

func (*GracefulFailoverResponseProto) Descriptor added in v1.1.1

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

func (*GracefulFailoverResponseProto) ProtoMessage added in v1.0.0

func (*GracefulFailoverResponseProto) ProtoMessage()

func (*GracefulFailoverResponseProto) Reset added in v1.0.0

func (m *GracefulFailoverResponseProto) Reset()

func (*GracefulFailoverResponseProto) String added in v1.0.0

type HARequestSource added in v1.0.0

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 added in v1.0.0

func (x HARequestSource) Enum() *HARequestSource

func (HARequestSource) EnumDescriptor added in v1.1.1

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

func (HARequestSource) String added in v1.0.0

func (x HARequestSource) String() string

func (*HARequestSource) UnmarshalJSON added in v1.0.0

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

type HAServiceStateProto added in v1.0.0

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

func (HAServiceStateProto) Enum added in v1.0.0

func (HAServiceStateProto) EnumDescriptor added in v1.1.1

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

func (HAServiceStateProto) String added in v1.0.0

func (x HAServiceStateProto) String() string

func (*HAServiceStateProto) UnmarshalJSON added in v1.0.0

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

type HAStateChangeRequestInfoProto added in v1.0.0

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 added in v1.1.1

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

func (*HAStateChangeRequestInfoProto) GetReqSource added in v1.0.0

func (*HAStateChangeRequestInfoProto) ProtoMessage added in v1.0.0

func (*HAStateChangeRequestInfoProto) ProtoMessage()

func (*HAStateChangeRequestInfoProto) Reset added in v1.0.0

func (m *HAStateChangeRequestInfoProto) Reset()

func (*HAStateChangeRequestInfoProto) String added in v1.0.0

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 added in v1.1.1

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

func (*IpcConnectionContextProto) GetProtocol

func (m *IpcConnectionContextProto) GetProtocol() string

func (*IpcConnectionContextProto) GetUserInfo

func (*IpcConnectionContextProto) ProtoMessage

func (*IpcConnectionContextProto) ProtoMessage()

func (*IpcConnectionContextProto) Reset

func (m *IpcConnectionContextProto) Reset()

func (*IpcConnectionContextProto) String

func (m *IpcConnectionContextProto) String() string

type ListSpanReceiversRequestProto added in v1.0.0

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

func (*ListSpanReceiversRequestProto) Descriptor added in v1.1.1

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

func (*ListSpanReceiversRequestProto) ProtoMessage added in v1.0.0

func (*ListSpanReceiversRequestProto) ProtoMessage()

func (*ListSpanReceiversRequestProto) Reset added in v1.0.0

func (m *ListSpanReceiversRequestProto) Reset()

func (*ListSpanReceiversRequestProto) String added in v1.0.0

type ListSpanReceiversResponseProto added in v1.0.0

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

func (*ListSpanReceiversResponseProto) Descriptor added in v1.1.1

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

func (*ListSpanReceiversResponseProto) GetDescriptions added in v1.0.0

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

func (*ListSpanReceiversResponseProto) ProtoMessage added in v1.0.0

func (*ListSpanReceiversResponseProto) ProtoMessage()

func (*ListSpanReceiversResponseProto) Reset added in v1.0.0

func (m *ListSpanReceiversResponseProto) Reset()

func (*ListSpanReceiversResponseProto) String added in v1.0.0

type MonitorHealthRequestProto added in v1.0.0

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

* void request

func (*MonitorHealthRequestProto) Descriptor added in v1.1.1

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

func (*MonitorHealthRequestProto) ProtoMessage added in v1.0.0

func (*MonitorHealthRequestProto) ProtoMessage()

func (*MonitorHealthRequestProto) Reset added in v1.0.0

func (m *MonitorHealthRequestProto) Reset()

func (*MonitorHealthRequestProto) String added in v1.0.0

func (m *MonitorHealthRequestProto) String() string

type MonitorHealthResponseProto added in v1.0.0

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

* void response

func (*MonitorHealthResponseProto) Descriptor added in v1.1.1

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

func (*MonitorHealthResponseProto) ProtoMessage added in v1.0.0

func (*MonitorHealthResponseProto) ProtoMessage()

func (*MonitorHealthResponseProto) Reset added in v1.0.0

func (m *MonitorHealthResponseProto) Reset()

func (*MonitorHealthResponseProto) String added in v1.0.0

func (m *MonitorHealthResponseProto) String() string

type ProtocolSignatureProto added in v1.0.0

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 added in v1.1.1

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

func (*ProtocolSignatureProto) GetMethods added in v1.0.0

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

func (*ProtocolSignatureProto) GetVersion added in v1.0.0

func (m *ProtocolSignatureProto) GetVersion() uint64

func (*ProtocolSignatureProto) ProtoMessage added in v1.0.0

func (*ProtocolSignatureProto) ProtoMessage()

func (*ProtocolSignatureProto) Reset added in v1.0.0

func (m *ProtocolSignatureProto) Reset()

func (*ProtocolSignatureProto) String added in v1.0.0

func (m *ProtocolSignatureProto) String() string

type ProtocolVersionProto added in v1.0.0

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 added in v1.1.1

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

func (*ProtocolVersionProto) GetRpcKind added in v1.0.0

func (m *ProtocolVersionProto) GetRpcKind() string

func (*ProtocolVersionProto) GetVersions added in v1.0.0

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

func (*ProtocolVersionProto) ProtoMessage added in v1.0.0

func (*ProtocolVersionProto) ProtoMessage()

func (*ProtocolVersionProto) Reset added in v1.0.0

func (m *ProtocolVersionProto) Reset()

func (*ProtocolVersionProto) String added in v1.0.0

func (m *ProtocolVersionProto) String() string

type RPCCallerContextProto added in v1.0.0

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 added in v1.1.1

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

func (*RPCCallerContextProto) GetContext added in v1.0.0

func (m *RPCCallerContextProto) GetContext() string

func (*RPCCallerContextProto) GetSignature added in v1.0.0

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

func (*RPCCallerContextProto) ProtoMessage added in v1.0.0

func (*RPCCallerContextProto) ProtoMessage()

func (*RPCCallerContextProto) Reset added in v1.0.0

func (m *RPCCallerContextProto) Reset()

func (*RPCCallerContextProto) String added in v1.0.0

func (m *RPCCallerContextProto) String() string

type RPCTraceInfoProto added in v1.0.0

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 added in v1.1.1

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

func (*RPCTraceInfoProto) GetParentId added in v1.0.0

func (m *RPCTraceInfoProto) GetParentId() int64

func (*RPCTraceInfoProto) GetTraceId added in v1.0.0

func (m *RPCTraceInfoProto) GetTraceId() int64

func (*RPCTraceInfoProto) ProtoMessage added in v1.0.0

func (*RPCTraceInfoProto) ProtoMessage()

func (*RPCTraceInfoProto) Reset added in v1.0.0

func (m *RPCTraceInfoProto) Reset()

func (*RPCTraceInfoProto) String added in v1.0.0

func (m *RPCTraceInfoProto) String() string

type RefreshCallQueueRequestProto added in v1.0.0

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

*

Refresh callqueue request.

func (*RefreshCallQueueRequestProto) Descriptor added in v1.1.1

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

func (*RefreshCallQueueRequestProto) ProtoMessage added in v1.0.0

func (*RefreshCallQueueRequestProto) ProtoMessage()

func (*RefreshCallQueueRequestProto) Reset added in v1.0.0

func (m *RefreshCallQueueRequestProto) Reset()

func (*RefreshCallQueueRequestProto) String added in v1.0.0

type RefreshCallQueueResponseProto added in v1.0.0

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

* void response.

func (*RefreshCallQueueResponseProto) Descriptor added in v1.1.1

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

func (*RefreshCallQueueResponseProto) ProtoMessage added in v1.0.0

func (*RefreshCallQueueResponseProto) ProtoMessage()

func (*RefreshCallQueueResponseProto) Reset added in v1.0.0

func (m *RefreshCallQueueResponseProto) Reset()

func (*RefreshCallQueueResponseProto) String added in v1.0.0

type RefreshServiceAclRequestProto added in v1.0.0

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

*

Refresh service acl request.

func (*RefreshServiceAclRequestProto) Descriptor added in v1.1.1

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

func (*RefreshServiceAclRequestProto) ProtoMessage added in v1.0.0

func (*RefreshServiceAclRequestProto) ProtoMessage()

func (*RefreshServiceAclRequestProto) Reset added in v1.0.0

func (m *RefreshServiceAclRequestProto) Reset()

func (*RefreshServiceAclRequestProto) String added in v1.0.0

type RefreshServiceAclResponseProto added in v1.0.0

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

* void response

func (*RefreshServiceAclResponseProto) Descriptor added in v1.1.1

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

func (*RefreshServiceAclResponseProto) ProtoMessage added in v1.0.0

func (*RefreshServiceAclResponseProto) ProtoMessage()

func (*RefreshServiceAclResponseProto) Reset added in v1.0.0

func (m *RefreshServiceAclResponseProto) Reset()

func (*RefreshServiceAclResponseProto) String added in v1.0.0

type RefreshSuperUserGroupsConfigurationRequestProto added in v1.0.0

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

* Refresh superuser configuration request.

func (*RefreshSuperUserGroupsConfigurationRequestProto) Descriptor added in v1.1.1

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage added in v1.0.0

func (*RefreshSuperUserGroupsConfigurationRequestProto) Reset added in v1.0.0

func (*RefreshSuperUserGroupsConfigurationRequestProto) String added in v1.0.0

type RefreshSuperUserGroupsConfigurationResponseProto added in v1.0.0

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

* void response

func (*RefreshSuperUserGroupsConfigurationResponseProto) Descriptor added in v1.1.1

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage added in v1.0.0

func (*RefreshSuperUserGroupsConfigurationResponseProto) Reset added in v1.0.0

func (*RefreshSuperUserGroupsConfigurationResponseProto) String added in v1.0.0

type RefreshUserToGroupsMappingsRequestProto added in v1.0.0

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

*

Refresh user to group mappings request.

func (*RefreshUserToGroupsMappingsRequestProto) Descriptor added in v1.1.1

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

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage added in v1.0.0

func (*RefreshUserToGroupsMappingsRequestProto) Reset added in v1.0.0

func (*RefreshUserToGroupsMappingsRequestProto) String added in v1.0.0

type RefreshUserToGroupsMappingsResponseProto added in v1.0.0

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

* void response

func (*RefreshUserToGroupsMappingsResponseProto) Descriptor added in v1.1.1

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

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage added in v1.0.0

func (*RefreshUserToGroupsMappingsResponseProto) Reset added in v1.0.0

func (*RefreshUserToGroupsMappingsResponseProto) String added in v1.0.0

type RemoveSpanReceiverRequestProto added in v1.0.0

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

func (*RemoveSpanReceiverRequestProto) Descriptor added in v1.1.1

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

func (*RemoveSpanReceiverRequestProto) GetId added in v1.0.0

func (*RemoveSpanReceiverRequestProto) ProtoMessage added in v1.0.0

func (*RemoveSpanReceiverRequestProto) ProtoMessage()

func (*RemoveSpanReceiverRequestProto) Reset added in v1.0.0

func (m *RemoveSpanReceiverRequestProto) Reset()

func (*RemoveSpanReceiverRequestProto) String added in v1.0.0

type RemoveSpanReceiverResponseProto added in v1.0.0

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

func (*RemoveSpanReceiverResponseProto) Descriptor added in v1.1.1

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

func (*RemoveSpanReceiverResponseProto) ProtoMessage added in v1.0.0

func (*RemoveSpanReceiverResponseProto) ProtoMessage()

func (*RemoveSpanReceiverResponseProto) Reset added in v1.0.0

func (*RemoveSpanReceiverResponseProto) String added in v1.0.0

type RenewDelegationTokenRequestProto

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

func (*RenewDelegationTokenRequestProto) Descriptor added in v1.1.1

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

func (*RenewDelegationTokenRequestProto) GetToken

func (*RenewDelegationTokenRequestProto) ProtoMessage

func (*RenewDelegationTokenRequestProto) ProtoMessage()

func (*RenewDelegationTokenRequestProto) Reset

func (*RenewDelegationTokenRequestProto) String

type RenewDelegationTokenResponseProto

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

func (*RenewDelegationTokenResponseProto) Descriptor added in v1.1.1

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

func (*RenewDelegationTokenResponseProto) GetNewExpiryTime

func (m *RenewDelegationTokenResponseProto) GetNewExpiryTime() uint64

func (*RenewDelegationTokenResponseProto) ProtoMessage

func (*RenewDelegationTokenResponseProto) ProtoMessage()

func (*RenewDelegationTokenResponseProto) Reset

func (*RenewDelegationTokenResponseProto) 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 added in v1.1.1

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 added in v1.1.1

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 added in v1.1.1

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

func (*RpcRequestHeaderProto) GetCallId

func (m *RpcRequestHeaderProto) GetCallId() int32

func (*RpcRequestHeaderProto) GetCallerContext added in v1.0.0

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 (*RpcRequestHeaderProto) GetTraceInfo added in v1.0.0

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 (RpcRequestHeaderProto_OperationProto) EnumDescriptor added in v1.1.1

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

func (RpcRequestHeaderProto_OperationProto) 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 added in v1.1.1

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 (*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 (*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 (RpcResponseHeaderProto_RpcErrorCodeProto) EnumDescriptor added in v1.1.1

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

func (RpcResponseHeaderProto_RpcErrorCodeProto) 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 (RpcResponseHeaderProto_RpcStatusProto) EnumDescriptor added in v1.1.1

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

func (RpcResponseHeaderProto_RpcStatusProto) 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 added in v1.1.1

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 added in v1.1.1

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 (RpcSaslProto_SaslState) EnumDescriptor added in v1.1.1

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 added in v1.0.0

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 added in v1.1.1

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

func (*SpanReceiverListInfo) GetClassName added in v1.0.0

func (m *SpanReceiverListInfo) GetClassName() string

func (*SpanReceiverListInfo) GetId added in v1.0.0

func (m *SpanReceiverListInfo) GetId() int64

func (*SpanReceiverListInfo) ProtoMessage added in v1.0.0

func (*SpanReceiverListInfo) ProtoMessage()

func (*SpanReceiverListInfo) Reset added in v1.0.0

func (m *SpanReceiverListInfo) Reset()

func (*SpanReceiverListInfo) String added in v1.0.0

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 added in v1.1.1

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 added in v1.0.0

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

* void request

func (*TransitionToActiveRequestProto) Descriptor added in v1.1.1

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

func (*TransitionToActiveRequestProto) GetReqInfo added in v1.0.0

func (*TransitionToActiveRequestProto) ProtoMessage added in v1.0.0

func (*TransitionToActiveRequestProto) ProtoMessage()

func (*TransitionToActiveRequestProto) Reset added in v1.0.0

func (m *TransitionToActiveRequestProto) Reset()

func (*TransitionToActiveRequestProto) String added in v1.0.0

type TransitionToActiveResponseProto added in v1.0.0

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

* void response

func (*TransitionToActiveResponseProto) Descriptor added in v1.1.1

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

func (*TransitionToActiveResponseProto) ProtoMessage added in v1.0.0

func (*TransitionToActiveResponseProto) ProtoMessage()

func (*TransitionToActiveResponseProto) Reset added in v1.0.0

func (*TransitionToActiveResponseProto) String added in v1.0.0

type TransitionToStandbyRequestProto added in v1.0.0

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

* void request

func (*TransitionToStandbyRequestProto) Descriptor added in v1.1.1

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

func (*TransitionToStandbyRequestProto) GetReqInfo added in v1.0.0

func (*TransitionToStandbyRequestProto) ProtoMessage added in v1.0.0

func (*TransitionToStandbyRequestProto) ProtoMessage()

func (*TransitionToStandbyRequestProto) Reset added in v1.0.0

func (*TransitionToStandbyRequestProto) String added in v1.0.0

type TransitionToStandbyResponseProto added in v1.0.0

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

* void response

func (*TransitionToStandbyResponseProto) Descriptor added in v1.1.1

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

func (*TransitionToStandbyResponseProto) ProtoMessage added in v1.0.0

func (*TransitionToStandbyResponseProto) ProtoMessage()

func (*TransitionToStandbyResponseProto) Reset added in v1.0.0

func (*TransitionToStandbyResponseProto) String added in v1.0.0

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 added in v1.1.1

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

Jump to

Keyboard shortcuts

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