hadoop_common

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2017 License: MIT Imports: 2 Imported by: 0

Documentation

Overview

Package hadoop_common is a generated protocol buffer package.

It is generated from these files: 

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

It has these top-level messages: 

GenericRefreshRequestProto
GenericRefreshResponseProto
GenericRefreshResponseCollectionProto

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

func (m *AddSpanReceiverResponseProto) GetId() int64

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 

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) 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) ProtoMessage 

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) Reset 

func (m *CancelDelegationTokenResponseProto) Reset()

func (*CancelDelegationTokenResponseProto) String 

func (m *CancelDelegationTokenResponseProto) String() 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) 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) 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) 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) 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) GetResponses added in v1.0.0 

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

func (*GenericRefreshResponseCollectionProto) ProtoMessage added in v1.0.0 

func (*GenericRefreshResponseCollectionProto) ProtoMessage()

func (*GenericRefreshResponseCollectionProto) Reset added in v1.0.0 

func (m *GenericRefreshResponseCollectionProto) Reset()

func (*GenericRefreshResponseCollectionProto) String added in v1.0.0 

func (m *GenericRefreshResponseCollectionProto) String() string

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) 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) 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) 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 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) 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 

func (m *GetGroupsForUserRequestProto) String() string

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) 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 

func (m *GetGroupsForUserResponseProto) String() string

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) 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 (m *GetProtocolSignatureRequestProto) Reset()

func (*GetProtocolSignatureRequestProto) String added in v1.0.0 

func (m *GetProtocolSignatureRequestProto) String() string

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) 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 (m *GetProtocolSignatureResponseProto) Reset()

func (*GetProtocolSignatureResponseProto) String added in v1.0.0 

func (m *GetProtocolSignatureResponseProto) String() string

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) 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 (m *GetProtocolVersionsRequestProto) Reset()

func (*GetProtocolVersionsRequestProto) String added in v1.0.0 

func (m *GetProtocolVersionsRequestProto) String() string

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) 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 (m *GetProtocolVersionsResponseProto) Reset()

func (*GetProtocolVersionsResponseProto) String added in v1.0.0 

func (m *GetProtocolVersionsResponseProto) String() string

type GetServiceStatusRequestProto added in v1.0.0 

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

* void request

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 

func (m *GetServiceStatusRequestProto) String() string

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) 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 (m *GetServiceStatusResponseProto) GetState() HAServiceStateProto

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 

func (m *GetServiceStatusResponseProto) String() string

type GracefulFailoverRequestProto added in v1.0.0 

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

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 

func (m *GracefulFailoverRequestProto) String() string

type GracefulFailoverResponseProto added in v1.0.0 

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

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 

func (m *GracefulFailoverResponseProto) String() string

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) 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 (x HAServiceStateProto) Enum() *HAServiceStateProto

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

func (m *HAStateChangeRequestInfoProto) GetReqSource() HARequestSource

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 

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

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

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 

func (m *ListSpanReceiversRequestProto) String() string

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) 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 

func (m *ListSpanReceiversResponseProto) String() string

type MonitorHealthRequestProto added in v1.0.0 

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

* void request

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) 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) 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) 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) 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) 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) 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 

func (m *RefreshCallQueueRequestProto) String() string

type RefreshCallQueueResponseProto added in v1.0.0 

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

* void response.

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 

func (m *RefreshCallQueueResponseProto) String() string

type RefreshServiceAclRequestProto added in v1.0.0 

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

* 

Refresh service acl request.

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 

func (m *RefreshServiceAclRequestProto) String() string

type RefreshServiceAclResponseProto added in v1.0.0 

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

* void response

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 

func (m *RefreshServiceAclResponseProto) String() string

type RefreshSuperUserGroupsConfigurationRequestProto added in v1.0.0 

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

* Refresh superuser configuration request.

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage added in v1.0.0 

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationRequestProto) Reset added in v1.0.0 

func (m *RefreshSuperUserGroupsConfigurationRequestProto) Reset()

func (*RefreshSuperUserGroupsConfigurationRequestProto) String added in v1.0.0 

func (m *RefreshSuperUserGroupsConfigurationRequestProto) String() string

type RefreshSuperUserGroupsConfigurationResponseProto added in v1.0.0 

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

* void response

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage added in v1.0.0 

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationResponseProto) Reset added in v1.0.0 

func (m *RefreshSuperUserGroupsConfigurationResponseProto) Reset()

func (*RefreshSuperUserGroupsConfigurationResponseProto) String added in v1.0.0 

func (m *RefreshSuperUserGroupsConfigurationResponseProto) String() string

type RefreshUserToGroupsMappingsRequestProto added in v1.0.0 

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

* 

Refresh user to group mappings request.

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage added in v1.0.0 

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsRequestProto) Reset added in v1.0.0 

func (m *RefreshUserToGroupsMappingsRequestProto) Reset()

func (*RefreshUserToGroupsMappingsRequestProto) String added in v1.0.0 

func (m *RefreshUserToGroupsMappingsRequestProto) String() string

type RefreshUserToGroupsMappingsResponseProto added in v1.0.0 

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

* void response

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage added in v1.0.0 

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsResponseProto) Reset added in v1.0.0 

func (m *RefreshUserToGroupsMappingsResponseProto) Reset()

func (*RefreshUserToGroupsMappingsResponseProto) String added in v1.0.0 

func (m *RefreshUserToGroupsMappingsResponseProto) String() string

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

func (m *RemoveSpanReceiverRequestProto) GetId() int64

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 

func (m *RemoveSpanReceiverRequestProto) String() string

type RemoveSpanReceiverResponseProto added in v1.0.0 

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

func (*RemoveSpanReceiverResponseProto) ProtoMessage added in v1.0.0 

func (*RemoveSpanReceiverResponseProto) ProtoMessage()

func (*RemoveSpanReceiverResponseProto) Reset added in v1.0.0 

func (m *RemoveSpanReceiverResponseProto) Reset()

func (*RemoveSpanReceiverResponseProto) String added in v1.0.0 

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) 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) 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) 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) 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) 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 (m *RpcRequestHeaderProto) GetRpcOp() RpcRequestHeaderProto_OperationProto

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 (x RpcRequestHeaderProto_OperationProto) Enum() *RpcRequestHeaderProto_OperationProto

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

func (m *TransitionToActiveRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

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 

func (m *TransitionToActiveRequestProto) String() string

type TransitionToActiveResponseProto added in v1.0.0 

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

* void response

func (*TransitionToActiveResponseProto) ProtoMessage added in v1.0.0 

func (*TransitionToActiveResponseProto) ProtoMessage()

func (*TransitionToActiveResponseProto) Reset added in v1.0.0 

func (m *TransitionToActiveResponseProto) Reset()

func (*TransitionToActiveResponseProto) String added in v1.0.0 

func (m *TransitionToActiveResponseProto) String() string

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

func (m *TransitionToStandbyRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToStandbyRequestProto) ProtoMessage added in v1.0.0 

func (*TransitionToStandbyRequestProto) ProtoMessage()

func (*TransitionToStandbyRequestProto) Reset added in v1.0.0 

func (m *TransitionToStandbyRequestProto) Reset()

func (*TransitionToStandbyRequestProto) String added in v1.0.0 

func (m *TransitionToStandbyRequestProto) String() string

type TransitionToStandbyResponseProto added in v1.0.0 

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

* void response

func (*TransitionToStandbyResponseProto) ProtoMessage added in v1.0.0 

func (*TransitionToStandbyResponseProto) ProtoMessage()

func (*TransitionToStandbyResponseProto) Reset added in v1.0.0 

func (m *TransitionToStandbyResponseProto) Reset()

func (*TransitionToStandbyResponseProto) String added in v1.0.0 

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) 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.