hadoop_common

package
v2.3.0 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2022 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_RpcRequestHeaderProto_RetryCount = int32(-1)
)

Default values for RpcRequestHeaderProto fields.

View Source 
const (
	Default_RpcResponseHeaderProto_RetryCount = int32(-1)
)

Default values for RpcResponseHeaderProto fields.

Variables

View Source 
var (
	HAServiceStateProto_name = map[int32]string{
		0: "INITIALIZING",
		1: "ACTIVE",
		2: "STANDBY",
		3: "OBSERVER",
	}
	HAServiceStateProto_value = map[string]int32{
		"INITIALIZING": 0,
		"ACTIVE":       1,
		"STANDBY":      2,
		"OBSERVER":     3,
	}
)

Enum value maps for HAServiceStateProto.

View Source 
var (
	HARequestSource_name = map[int32]string{
		0: "REQUEST_BY_USER",
		1: "REQUEST_BY_USER_FORCED",
		2: "REQUEST_BY_ZKFC",
	}
	HARequestSource_value = map[string]int32{
		"REQUEST_BY_USER":        0,
		"REQUEST_BY_USER_FORCED": 1,
		"REQUEST_BY_ZKFC":        2,
	}
)

Enum value maps for HARequestSource.

View Source 
var (
	RpcKindProto_name = map[int32]string{
		0: "RPC_BUILTIN",
		1: "RPC_WRITABLE",
		2: "RPC_PROTOCOL_BUFFER",
	}
	RpcKindProto_value = map[string]int32{
		"RPC_BUILTIN":         0,
		"RPC_WRITABLE":        1,
		"RPC_PROTOCOL_BUFFER": 2,
	}
)

Enum value maps for RpcKindProto.

View Source 
var (
	RpcRequestHeaderProto_OperationProto_name = map[int32]string{
		0: "RPC_FINAL_PACKET",
		1: "RPC_CONTINUATION_PACKET",
		2: "RPC_CLOSE_CONNECTION",
	}
	RpcRequestHeaderProto_OperationProto_value = map[string]int32{
		"RPC_FINAL_PACKET":        0,
		"RPC_CONTINUATION_PACKET": 1,
		"RPC_CLOSE_CONNECTION":    2,
	}
)

Enum value maps for RpcRequestHeaderProto_OperationProto.

View Source 
var (
	RpcResponseHeaderProto_RpcStatusProto_name = map[int32]string{
		0: "SUCCESS",
		1: "ERROR",
		2: "FATAL",
	}
	RpcResponseHeaderProto_RpcStatusProto_value = map[string]int32{
		"SUCCESS": 0,
		"ERROR":   1,
		"FATAL":   2,
	}
)

Enum value maps for RpcResponseHeaderProto_RpcStatusProto.

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",
	}
	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,
	}
)

Enum value maps for RpcResponseHeaderProto_RpcErrorCodeProto.

View Source 
var (
	RpcSaslProto_SaslState_name = map[int32]string{
		0: "SUCCESS",
		1: "NEGOTIATE",
		2: "INITIATE",
		3: "CHALLENGE",
		4: "RESPONSE",
		5: "WRAP",
	}
	RpcSaslProto_SaslState_value = map[string]int32{
		"SUCCESS":   0,
		"NEGOTIATE": 1,
		"INITIATE":  2,
		"CHALLENGE": 3,
		"RESPONSE":  4,
		"WRAP":      5,
	}
)

Enum value maps for RpcSaslProto_SaslState.

View Source 
var File_GenericRefreshProtocol_proto protoreflect.FileDescriptor
View Source 
var File_GetUserMappingsProtocol_proto protoreflect.FileDescriptor
View Source 
var File_HAServiceProtocol_proto protoreflect.FileDescriptor
View Source 
var File_IpcConnectionContext_proto protoreflect.FileDescriptor
View Source 
var File_ProtobufRpcEngine_proto protoreflect.FileDescriptor
View Source 
var File_ProtocolInfo_proto protoreflect.FileDescriptor
View Source 
var File_RefreshAuthorizationPolicyProtocol_proto protoreflect.FileDescriptor
View Source 
var File_RefreshCallQueueProtocol_proto protoreflect.FileDescriptor
View Source 
var File_RefreshUserMappingsProtocol_proto protoreflect.FileDescriptor
View Source 
var File_RpcHeader_proto protoreflect.FileDescriptor
View Source 
var File_Security_proto protoreflect.FileDescriptor
View Source 
var File_TraceAdmin_proto protoreflect.FileDescriptor
View Source 
var File_ZKFCProtocol_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddSpanReceiverRequestProto 

type AddSpanReceiverRequestProto struct {
	ClassName *string       `protobuf:"bytes,1,req,name=className" json:"className,omitempty"`
	Config    []*ConfigPair `protobuf:"bytes,2,rep,name=config" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*AddSpanReceiverRequestProto) Descriptor deprecated 

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

Deprecated: Use AddSpanReceiverRequestProto.ProtoReflect.Descriptor instead.

func (*AddSpanReceiverRequestProto) GetClassName 

func (x *AddSpanReceiverRequestProto) GetClassName() string

func (*AddSpanReceiverRequestProto) GetConfig 

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

func (*AddSpanReceiverRequestProto) ProtoMessage 

func (*AddSpanReceiverRequestProto) ProtoMessage()

func (*AddSpanReceiverRequestProto) ProtoReflect added in v2.2.1 

func (x *AddSpanReceiverRequestProto) ProtoReflect() protoreflect.Message

func (*AddSpanReceiverRequestProto) Reset 

func (x *AddSpanReceiverRequestProto) Reset()

func (*AddSpanReceiverRequestProto) String 

func (x *AddSpanReceiverRequestProto) String() string

type AddSpanReceiverResponseProto 

type AddSpanReceiverResponseProto struct {
	Id *int64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddSpanReceiverResponseProto) Descriptor deprecated 

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

Deprecated: Use AddSpanReceiverResponseProto.ProtoReflect.Descriptor instead.

func (*AddSpanReceiverResponseProto) GetId 

func (x *AddSpanReceiverResponseProto) GetId() int64

func (*AddSpanReceiverResponseProto) ProtoMessage 

func (*AddSpanReceiverResponseProto) ProtoMessage()

func (*AddSpanReceiverResponseProto) ProtoReflect added in v2.2.1 

func (x *AddSpanReceiverResponseProto) ProtoReflect() protoreflect.Message

func (*AddSpanReceiverResponseProto) Reset 

func (x *AddSpanReceiverResponseProto) Reset()

func (*AddSpanReceiverResponseProto) String 

func (x *AddSpanReceiverResponseProto) String() string

type CancelDelegationTokenRequestProto 

type CancelDelegationTokenRequestProto struct {
	Token *TokenProto `protobuf:"bytes,1,req,name=token" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelDelegationTokenRequestProto) Descriptor deprecated 

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

Deprecated: Use CancelDelegationTokenRequestProto.ProtoReflect.Descriptor instead.

func (*CancelDelegationTokenRequestProto) GetToken 

func (x *CancelDelegationTokenRequestProto) GetToken() *TokenProto

func (*CancelDelegationTokenRequestProto) ProtoMessage 

func (*CancelDelegationTokenRequestProto) ProtoMessage()

func (*CancelDelegationTokenRequestProto) ProtoReflect added in v2.2.1 

func (x *CancelDelegationTokenRequestProto) ProtoReflect() protoreflect.Message

func (*CancelDelegationTokenRequestProto) Reset 

func (x *CancelDelegationTokenRequestProto) Reset()

func (*CancelDelegationTokenRequestProto) String 

func (x *CancelDelegationTokenRequestProto) String() string

type CancelDelegationTokenResponseProto 

type CancelDelegationTokenResponseProto struct {
	// contains filtered or unexported fields
}

func (*CancelDelegationTokenResponseProto) Descriptor deprecated 

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

Deprecated: Use CancelDelegationTokenResponseProto.ProtoReflect.Descriptor instead.

func (*CancelDelegationTokenResponseProto) ProtoMessage 

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) ProtoReflect added in v2.2.1 

func (x *CancelDelegationTokenResponseProto) ProtoReflect() protoreflect.Message

func (*CancelDelegationTokenResponseProto) Reset 

func (x *CancelDelegationTokenResponseProto) Reset()

func (*CancelDelegationTokenResponseProto) String 

func (x *CancelDelegationTokenResponseProto) String() string

type CedeActiveRequestProto 

type CedeActiveRequestProto struct {
	MillisToCede *uint32 `protobuf:"varint,1,req,name=millisToCede" json:"millisToCede,omitempty"`
	// contains filtered or unexported fields
}

func (*CedeActiveRequestProto) Descriptor deprecated 

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

Deprecated: Use CedeActiveRequestProto.ProtoReflect.Descriptor instead.

func (*CedeActiveRequestProto) GetMillisToCede 

func (x *CedeActiveRequestProto) GetMillisToCede() uint32

func (*CedeActiveRequestProto) ProtoMessage 

func (*CedeActiveRequestProto) ProtoMessage()

func (*CedeActiveRequestProto) ProtoReflect added in v2.2.1 

func (x *CedeActiveRequestProto) ProtoReflect() protoreflect.Message

func (*CedeActiveRequestProto) Reset 

func (x *CedeActiveRequestProto) Reset()

func (*CedeActiveRequestProto) String 

func (x *CedeActiveRequestProto) String() string

type CedeActiveResponseProto 

type CedeActiveResponseProto struct {
	// contains filtered or unexported fields
}

func (*CedeActiveResponseProto) Descriptor deprecated 

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

Deprecated: Use CedeActiveResponseProto.ProtoReflect.Descriptor instead.

func (*CedeActiveResponseProto) ProtoMessage 

func (*CedeActiveResponseProto) ProtoMessage()

func (*CedeActiveResponseProto) ProtoReflect added in v2.2.1 

func (x *CedeActiveResponseProto) ProtoReflect() protoreflect.Message

func (*CedeActiveResponseProto) Reset 

func (x *CedeActiveResponseProto) Reset()

func (*CedeActiveResponseProto) String 

func (x *CedeActiveResponseProto) String() string

type ConfigPair 

type ConfigPair struct {
	Key   *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigPair) Descriptor deprecated 

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

Deprecated: Use ConfigPair.ProtoReflect.Descriptor instead.

func (*ConfigPair) GetKey 

func (x *ConfigPair) GetKey() string

func (*ConfigPair) GetValue 

func (x *ConfigPair) GetValue() string

func (*ConfigPair) ProtoMessage 

func (*ConfigPair) ProtoMessage()

func (*ConfigPair) ProtoReflect added in v2.2.1 

func (x *ConfigPair) ProtoReflect() protoreflect.Message

func (*ConfigPair) Reset 

func (x *ConfigPair) Reset()

func (*ConfigPair) String 

func (x *ConfigPair) String() string

type CredentialsKVProto added in v2.2.1 

type CredentialsKVProto struct {
	Alias  *string     `protobuf:"bytes,1,req,name=alias" json:"alias,omitempty"`
	Token  *TokenProto `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	Secret []byte      `protobuf:"bytes,3,opt,name=secret" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialsKVProto) Descriptor deprecated added in v2.2.1 

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

Deprecated: Use CredentialsKVProto.ProtoReflect.Descriptor instead.

func (*CredentialsKVProto) GetAlias added in v2.2.1 

func (x *CredentialsKVProto) GetAlias() string

func (*CredentialsKVProto) GetSecret added in v2.2.1 

func (x *CredentialsKVProto) GetSecret() []byte

func (*CredentialsKVProto) GetToken added in v2.2.1 

func (x *CredentialsKVProto) GetToken() *TokenProto

func (*CredentialsKVProto) ProtoMessage added in v2.2.1 

func (*CredentialsKVProto) ProtoMessage()

func (*CredentialsKVProto) ProtoReflect added in v2.2.1 

func (x *CredentialsKVProto) ProtoReflect() protoreflect.Message

func (*CredentialsKVProto) Reset added in v2.2.1 

func (x *CredentialsKVProto) Reset()

func (*CredentialsKVProto) String added in v2.2.1 

func (x *CredentialsKVProto) String() string

type CredentialsProto added in v2.2.1 

type CredentialsProto struct {
	Tokens  []*CredentialsKVProto `protobuf:"bytes,1,rep,name=tokens" json:"tokens,omitempty"`
	Secrets []*CredentialsKVProto `protobuf:"bytes,2,rep,name=secrets" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialsProto) Descriptor deprecated added in v2.2.1 

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

Deprecated: Use CredentialsProto.ProtoReflect.Descriptor instead.

func (*CredentialsProto) GetSecrets added in v2.2.1 

func (x *CredentialsProto) GetSecrets() []*CredentialsKVProto

func (*CredentialsProto) GetTokens added in v2.2.1 

func (x *CredentialsProto) GetTokens() []*CredentialsKVProto

func (*CredentialsProto) ProtoMessage added in v2.2.1 

func (*CredentialsProto) ProtoMessage()

func (*CredentialsProto) ProtoReflect added in v2.2.1 

func (x *CredentialsProto) ProtoReflect() protoreflect.Message

func (*CredentialsProto) Reset added in v2.2.1 

func (x *CredentialsProto) Reset()

func (*CredentialsProto) String added in v2.2.1 

func (x *CredentialsProto) String() string

type GenericRefreshRequestProto 

type GenericRefreshRequestProto struct {
	Identifier *string  `protobuf:"bytes,1,opt,name=identifier" json:"identifier,omitempty"`
	Args       []string `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
	// contains filtered or unexported fields
}

* 

Refresh request.

func (*GenericRefreshRequestProto) Descriptor deprecated 

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

Deprecated: Use GenericRefreshRequestProto.ProtoReflect.Descriptor instead.

func (*GenericRefreshRequestProto) GetArgs 

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

func (*GenericRefreshRequestProto) GetIdentifier 

func (x *GenericRefreshRequestProto) GetIdentifier() string

func (*GenericRefreshRequestProto) ProtoMessage 

func (*GenericRefreshRequestProto) ProtoMessage()

func (*GenericRefreshRequestProto) ProtoReflect added in v2.2.1 

func (x *GenericRefreshRequestProto) ProtoReflect() protoreflect.Message

func (*GenericRefreshRequestProto) Reset 

func (x *GenericRefreshRequestProto) Reset()

func (*GenericRefreshRequestProto) String 

func (x *GenericRefreshRequestProto) String() string

type GenericRefreshResponseCollectionProto 

type GenericRefreshResponseCollectionProto struct {
	Responses []*GenericRefreshResponseProto `protobuf:"bytes,1,rep,name=responses" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

* Collection of responses from zero or more handlers.

func (*GenericRefreshResponseCollectionProto) Descriptor deprecated 

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

Deprecated: Use GenericRefreshResponseCollectionProto.ProtoReflect.Descriptor instead.

func (*GenericRefreshResponseCollectionProto) GetResponses 

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

func (*GenericRefreshResponseCollectionProto) ProtoMessage 

func (*GenericRefreshResponseCollectionProto) ProtoMessage()

func (*GenericRefreshResponseCollectionProto) ProtoReflect added in v2.2.1 

func (x *GenericRefreshResponseCollectionProto) ProtoReflect() protoreflect.Message

func (*GenericRefreshResponseCollectionProto) Reset 

func (x *GenericRefreshResponseCollectionProto) Reset()

func (*GenericRefreshResponseCollectionProto) String 

func (x *GenericRefreshResponseCollectionProto) String() string

type GenericRefreshResponseProto 

type GenericRefreshResponseProto struct {
	ExitStatus  *int32  `protobuf:"varint,1,opt,name=exitStatus" json:"exitStatus,omitempty"`  // unix exit status to return
	UserMessage *string `protobuf:"bytes,2,opt,name=userMessage" json:"userMessage,omitempty"` // to be displayed to the user
	SenderName  *string `protobuf:"bytes,3,opt,name=senderName" json:"senderName,omitempty"`   // which handler sent this message
	// contains filtered or unexported fields
}

* A single response from a refresh handler.

func (*GenericRefreshResponseProto) Descriptor deprecated 

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

Deprecated: Use GenericRefreshResponseProto.ProtoReflect.Descriptor instead.

func (*GenericRefreshResponseProto) GetExitStatus 

func (x *GenericRefreshResponseProto) GetExitStatus() int32

func (*GenericRefreshResponseProto) GetSenderName 

func (x *GenericRefreshResponseProto) GetSenderName() string

func (*GenericRefreshResponseProto) GetUserMessage 

func (x *GenericRefreshResponseProto) GetUserMessage() string

func (*GenericRefreshResponseProto) ProtoMessage 

func (*GenericRefreshResponseProto) ProtoMessage()

func (*GenericRefreshResponseProto) ProtoReflect added in v2.2.1 

func (x *GenericRefreshResponseProto) ProtoReflect() protoreflect.Message

func (*GenericRefreshResponseProto) Reset 

func (x *GenericRefreshResponseProto) Reset()

func (*GenericRefreshResponseProto) String 

func (x *GenericRefreshResponseProto) String() string

type GetDelegationTokenRequestProto 

type GetDelegationTokenRequestProto struct {
	Renewer *string `protobuf:"bytes,1,req,name=renewer" json:"renewer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDelegationTokenRequestProto) Descriptor deprecated 

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

Deprecated: Use GetDelegationTokenRequestProto.ProtoReflect.Descriptor instead.

func (*GetDelegationTokenRequestProto) GetRenewer 

func (x *GetDelegationTokenRequestProto) GetRenewer() string

func (*GetDelegationTokenRequestProto) ProtoMessage 

func (*GetDelegationTokenRequestProto) ProtoMessage()

func (*GetDelegationTokenRequestProto) ProtoReflect added in v2.2.1 

func (x *GetDelegationTokenRequestProto) ProtoReflect() protoreflect.Message

func (*GetDelegationTokenRequestProto) Reset 

func (x *GetDelegationTokenRequestProto) Reset()

func (*GetDelegationTokenRequestProto) String 

func (x *GetDelegationTokenRequestProto) String() string

type GetDelegationTokenResponseProto 

type GetDelegationTokenResponseProto struct {
	Token *TokenProto `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDelegationTokenResponseProto) Descriptor deprecated 

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

Deprecated: Use GetDelegationTokenResponseProto.ProtoReflect.Descriptor instead.

func (*GetDelegationTokenResponseProto) GetToken 

func (x *GetDelegationTokenResponseProto) GetToken() *TokenProto

func (*GetDelegationTokenResponseProto) ProtoMessage 

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) ProtoReflect added in v2.2.1 

func (x *GetDelegationTokenResponseProto) ProtoReflect() protoreflect.Message

func (*GetDelegationTokenResponseProto) Reset 

func (x *GetDelegationTokenResponseProto) Reset()

func (*GetDelegationTokenResponseProto) String 

func (x *GetDelegationTokenResponseProto) String() string

type GetGroupsForUserRequestProto 

type GetGroupsForUserRequestProto struct {
	User *string `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	// contains filtered or unexported fields
}

* 

Get groups for user request.

func (*GetGroupsForUserRequestProto) Descriptor deprecated 

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

Deprecated: Use GetGroupsForUserRequestProto.ProtoReflect.Descriptor instead.

func (*GetGroupsForUserRequestProto) GetUser 

func (x *GetGroupsForUserRequestProto) GetUser() string

func (*GetGroupsForUserRequestProto) ProtoMessage 

func (*GetGroupsForUserRequestProto) ProtoMessage()

func (*GetGroupsForUserRequestProto) ProtoReflect added in v2.2.1 

func (x *GetGroupsForUserRequestProto) ProtoReflect() protoreflect.Message

func (*GetGroupsForUserRequestProto) Reset 

func (x *GetGroupsForUserRequestProto) Reset()

func (*GetGroupsForUserRequestProto) String 

func (x *GetGroupsForUserRequestProto) String() string

type GetGroupsForUserResponseProto 

type GetGroupsForUserResponseProto struct {
	Groups []string `protobuf:"bytes,1,rep,name=groups" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

* Response for get groups.

func (*GetGroupsForUserResponseProto) Descriptor deprecated 

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

Deprecated: Use GetGroupsForUserResponseProto.ProtoReflect.Descriptor instead.

func (*GetGroupsForUserResponseProto) GetGroups 

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

func (*GetGroupsForUserResponseProto) ProtoMessage 

func (*GetGroupsForUserResponseProto) ProtoMessage()

func (*GetGroupsForUserResponseProto) ProtoReflect added in v2.2.1 

func (x *GetGroupsForUserResponseProto) ProtoReflect() protoreflect.Message

func (*GetGroupsForUserResponseProto) Reset 

func (x *GetGroupsForUserResponseProto) Reset()

func (*GetGroupsForUserResponseProto) String 

func (x *GetGroupsForUserResponseProto) String() string

type GetProtocolSignatureRequestProto 

type GetProtocolSignatureRequestProto struct {
	Protocol *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"` // Protocol name
	RpcKind  *string `protobuf:"bytes,2,req,name=rpcKind" json:"rpcKind,omitempty"`   // RPC kind
	// contains filtered or unexported fields
}

* Get protocol signature request.

func (*GetProtocolSignatureRequestProto) Descriptor deprecated 

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

Deprecated: Use GetProtocolSignatureRequestProto.ProtoReflect.Descriptor instead.

func (*GetProtocolSignatureRequestProto) GetProtocol 

func (x *GetProtocolSignatureRequestProto) GetProtocol() string

func (*GetProtocolSignatureRequestProto) GetRpcKind 

func (x *GetProtocolSignatureRequestProto) GetRpcKind() string

func (*GetProtocolSignatureRequestProto) ProtoMessage 

func (*GetProtocolSignatureRequestProto) ProtoMessage()

func (*GetProtocolSignatureRequestProto) ProtoReflect added in v2.2.1 

func (x *GetProtocolSignatureRequestProto) ProtoReflect() protoreflect.Message

func (*GetProtocolSignatureRequestProto) Reset 

func (x *GetProtocolSignatureRequestProto) Reset()

func (*GetProtocolSignatureRequestProto) String 

func (x *GetProtocolSignatureRequestProto) String() string

type GetProtocolSignatureResponseProto 

type GetProtocolSignatureResponseProto struct {
	ProtocolSignature []*ProtocolSignatureProto `protobuf:"bytes,1,rep,name=protocolSignature" json:"protocolSignature,omitempty"`
	// contains filtered or unexported fields
}

* Get protocol signature response.

func (*GetProtocolSignatureResponseProto) Descriptor deprecated 

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

Deprecated: Use GetProtocolSignatureResponseProto.ProtoReflect.Descriptor instead.

func (*GetProtocolSignatureResponseProto) GetProtocolSignature 

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

func (*GetProtocolSignatureResponseProto) ProtoMessage 

func (*GetProtocolSignatureResponseProto) ProtoMessage()

func (*GetProtocolSignatureResponseProto) ProtoReflect added in v2.2.1 

func (x *GetProtocolSignatureResponseProto) ProtoReflect() protoreflect.Message

func (*GetProtocolSignatureResponseProto) Reset 

func (x *GetProtocolSignatureResponseProto) Reset()

func (*GetProtocolSignatureResponseProto) String 

func (x *GetProtocolSignatureResponseProto) String() string

type GetProtocolVersionsRequestProto 

type GetProtocolVersionsRequestProto struct {
	Protocol *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"` // Protocol name
	// contains filtered or unexported fields
}

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

func (*GetProtocolVersionsRequestProto) Descriptor deprecated 

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

Deprecated: Use GetProtocolVersionsRequestProto.ProtoReflect.Descriptor instead.

func (*GetProtocolVersionsRequestProto) GetProtocol 

func (x *GetProtocolVersionsRequestProto) GetProtocol() string

func (*GetProtocolVersionsRequestProto) ProtoMessage 

func (*GetProtocolVersionsRequestProto) ProtoMessage()

func (*GetProtocolVersionsRequestProto) ProtoReflect added in v2.2.1 

func (x *GetProtocolVersionsRequestProto) ProtoReflect() protoreflect.Message

func (*GetProtocolVersionsRequestProto) Reset 

func (x *GetProtocolVersionsRequestProto) Reset()

func (*GetProtocolVersionsRequestProto) String 

func (x *GetProtocolVersionsRequestProto) String() string

type GetProtocolVersionsResponseProto 

type GetProtocolVersionsResponseProto struct {
	ProtocolVersions []*ProtocolVersionProto `protobuf:"bytes,1,rep,name=protocolVersions" json:"protocolVersions,omitempty"`
	// contains filtered or unexported fields
}

* Get protocol version response.

func (*GetProtocolVersionsResponseProto) Descriptor deprecated 

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

Deprecated: Use GetProtocolVersionsResponseProto.ProtoReflect.Descriptor instead.

func (*GetProtocolVersionsResponseProto) GetProtocolVersions 

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

func (*GetProtocolVersionsResponseProto) ProtoMessage 

func (*GetProtocolVersionsResponseProto) ProtoMessage()

func (*GetProtocolVersionsResponseProto) ProtoReflect added in v2.2.1 

func (x *GetProtocolVersionsResponseProto) ProtoReflect() protoreflect.Message

func (*GetProtocolVersionsResponseProto) Reset 

func (x *GetProtocolVersionsResponseProto) Reset()

func (*GetProtocolVersionsResponseProto) String 

func (x *GetProtocolVersionsResponseProto) String() string

type GetServiceStatusRequestProto 

type GetServiceStatusRequestProto struct {
	// contains filtered or unexported fields
}

* void request

func (*GetServiceStatusRequestProto) Descriptor deprecated 

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

Deprecated: Use GetServiceStatusRequestProto.ProtoReflect.Descriptor instead.

func (*GetServiceStatusRequestProto) ProtoMessage 

func (*GetServiceStatusRequestProto) ProtoMessage()

func (*GetServiceStatusRequestProto) ProtoReflect added in v2.2.1 

func (x *GetServiceStatusRequestProto) ProtoReflect() protoreflect.Message

func (*GetServiceStatusRequestProto) Reset 

func (x *GetServiceStatusRequestProto) Reset()

func (*GetServiceStatusRequestProto) String 

func (x *GetServiceStatusRequestProto) String() string

type GetServiceStatusResponseProto 

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

* Returns the state of the service

func (*GetServiceStatusResponseProto) Descriptor deprecated 

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

Deprecated: Use GetServiceStatusResponseProto.ProtoReflect.Descriptor instead.

func (*GetServiceStatusResponseProto) GetNotReadyReason 

func (x *GetServiceStatusResponseProto) GetNotReadyReason() string

func (*GetServiceStatusResponseProto) GetReadyToBecomeActive 

func (x *GetServiceStatusResponseProto) GetReadyToBecomeActive() bool

func (*GetServiceStatusResponseProto) GetState 

func (x *GetServiceStatusResponseProto) GetState() HAServiceStateProto

func (*GetServiceStatusResponseProto) ProtoMessage 

func (*GetServiceStatusResponseProto) ProtoMessage()

func (*GetServiceStatusResponseProto) ProtoReflect added in v2.2.1 

func (x *GetServiceStatusResponseProto) ProtoReflect() protoreflect.Message

func (*GetServiceStatusResponseProto) Reset 

func (x *GetServiceStatusResponseProto) Reset()

func (*GetServiceStatusResponseProto) String 

func (x *GetServiceStatusResponseProto) String() string

type GracefulFailoverRequestProto 

type GracefulFailoverRequestProto struct {
	// contains filtered or unexported fields
}

func (*GracefulFailoverRequestProto) Descriptor deprecated 

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

Deprecated: Use GracefulFailoverRequestProto.ProtoReflect.Descriptor instead.

func (*GracefulFailoverRequestProto) ProtoMessage 

func (*GracefulFailoverRequestProto) ProtoMessage()

func (*GracefulFailoverRequestProto) ProtoReflect added in v2.2.1 

func (x *GracefulFailoverRequestProto) ProtoReflect() protoreflect.Message

func (*GracefulFailoverRequestProto) Reset 

func (x *GracefulFailoverRequestProto) Reset()

func (*GracefulFailoverRequestProto) String 

func (x *GracefulFailoverRequestProto) String() string

type GracefulFailoverResponseProto 

type GracefulFailoverResponseProto struct {
	// contains filtered or unexported fields
}

func (*GracefulFailoverResponseProto) Descriptor deprecated 

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

Deprecated: Use GracefulFailoverResponseProto.ProtoReflect.Descriptor instead.

func (*GracefulFailoverResponseProto) ProtoMessage 

func (*GracefulFailoverResponseProto) ProtoMessage()

func (*GracefulFailoverResponseProto) ProtoReflect added in v2.2.1 

func (x *GracefulFailoverResponseProto) ProtoReflect() protoreflect.Message

func (*GracefulFailoverResponseProto) Reset 

func (x *GracefulFailoverResponseProto) Reset()

func (*GracefulFailoverResponseProto) String 

func (x *GracefulFailoverResponseProto) String() string

type HARequestSource 

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

func (HARequestSource) Descriptor added in v2.2.1 

func (HARequestSource) Descriptor() protoreflect.EnumDescriptor

func (HARequestSource) Enum 

func (x HARequestSource) Enum() *HARequestSource

func (HARequestSource) EnumDescriptor deprecated 

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

Deprecated: Use HARequestSource.Descriptor instead.

func (HARequestSource) Number added in v2.2.1 

func (x HARequestSource) Number() protoreflect.EnumNumber

func (HARequestSource) String 

func (x HARequestSource) String() string

func (HARequestSource) Type added in v2.2.1 

func (HARequestSource) Type() protoreflect.EnumType

func (*HARequestSource) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type HAServiceStateProto 

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

func (HAServiceStateProto) Descriptor added in v2.2.1 

func (HAServiceStateProto) Descriptor() protoreflect.EnumDescriptor

func (HAServiceStateProto) Enum 

func (x HAServiceStateProto) Enum() *HAServiceStateProto

func (HAServiceStateProto) EnumDescriptor deprecated 

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

Deprecated: Use HAServiceStateProto.Descriptor instead.

func (HAServiceStateProto) Number added in v2.2.1 

func (x HAServiceStateProto) Number() protoreflect.EnumNumber

func (HAServiceStateProto) String 

func (x HAServiceStateProto) String() string

func (HAServiceStateProto) Type added in v2.2.1 

func (HAServiceStateProto) Type() protoreflect.EnumType

func (*HAServiceStateProto) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type HAStateChangeRequestInfoProto 

type HAStateChangeRequestInfoProto struct {
	ReqSource *HARequestSource `protobuf:"varint,1,req,name=reqSource,enum=hadoop.common.HARequestSource" json:"reqSource,omitempty"`
	// contains filtered or unexported fields
}

func (*HAStateChangeRequestInfoProto) Descriptor deprecated 

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

Deprecated: Use HAStateChangeRequestInfoProto.ProtoReflect.Descriptor instead.

func (*HAStateChangeRequestInfoProto) GetReqSource 

func (x *HAStateChangeRequestInfoProto) GetReqSource() HARequestSource

func (*HAStateChangeRequestInfoProto) ProtoMessage 

func (*HAStateChangeRequestInfoProto) ProtoMessage()

func (*HAStateChangeRequestInfoProto) ProtoReflect added in v2.2.1 

func (x *HAStateChangeRequestInfoProto) ProtoReflect() protoreflect.Message

func (*HAStateChangeRequestInfoProto) Reset 

func (x *HAStateChangeRequestInfoProto) Reset()

func (*HAStateChangeRequestInfoProto) String 

func (x *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"`
	// contains filtered or unexported fields
}

* 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 deprecated 

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

Deprecated: Use IpcConnectionContextProto.ProtoReflect.Descriptor instead.

func (*IpcConnectionContextProto) GetProtocol 

func (x *IpcConnectionContextProto) GetProtocol() string

func (*IpcConnectionContextProto) GetUserInfo 

func (x *IpcConnectionContextProto) GetUserInfo() *UserInformationProto

func (*IpcConnectionContextProto) ProtoMessage 

func (*IpcConnectionContextProto) ProtoMessage()

func (*IpcConnectionContextProto) ProtoReflect added in v2.2.1 

func (x *IpcConnectionContextProto) ProtoReflect() protoreflect.Message

func (*IpcConnectionContextProto) Reset 

func (x *IpcConnectionContextProto) Reset()

func (*IpcConnectionContextProto) String 

func (x *IpcConnectionContextProto) String() string

type ListSpanReceiversRequestProto 

type ListSpanReceiversRequestProto struct {
	// contains filtered or unexported fields
}

func (*ListSpanReceiversRequestProto) Descriptor deprecated 

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

Deprecated: Use ListSpanReceiversRequestProto.ProtoReflect.Descriptor instead.

func (*ListSpanReceiversRequestProto) ProtoMessage 

func (*ListSpanReceiversRequestProto) ProtoMessage()

func (*ListSpanReceiversRequestProto) ProtoReflect added in v2.2.1 

func (x *ListSpanReceiversRequestProto) ProtoReflect() protoreflect.Message

func (*ListSpanReceiversRequestProto) Reset 

func (x *ListSpanReceiversRequestProto) Reset()

func (*ListSpanReceiversRequestProto) String 

func (x *ListSpanReceiversRequestProto) String() string

type ListSpanReceiversResponseProto 

type ListSpanReceiversResponseProto struct {
	Descriptions []*SpanReceiverListInfo `protobuf:"bytes,1,rep,name=descriptions" json:"descriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSpanReceiversResponseProto) Descriptor deprecated 

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

Deprecated: Use ListSpanReceiversResponseProto.ProtoReflect.Descriptor instead.

func (*ListSpanReceiversResponseProto) GetDescriptions 

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

func (*ListSpanReceiversResponseProto) ProtoMessage 

func (*ListSpanReceiversResponseProto) ProtoMessage()

func (*ListSpanReceiversResponseProto) ProtoReflect added in v2.2.1 

func (x *ListSpanReceiversResponseProto) ProtoReflect() protoreflect.Message

func (*ListSpanReceiversResponseProto) Reset 

func (x *ListSpanReceiversResponseProto) Reset()

func (*ListSpanReceiversResponseProto) String 

func (x *ListSpanReceiversResponseProto) String() string

type MonitorHealthRequestProto 

type MonitorHealthRequestProto struct {
	// contains filtered or unexported fields
}

* void request

func (*MonitorHealthRequestProto) Descriptor deprecated 

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

Deprecated: Use MonitorHealthRequestProto.ProtoReflect.Descriptor instead.

func (*MonitorHealthRequestProto) ProtoMessage 

func (*MonitorHealthRequestProto) ProtoMessage()

func (*MonitorHealthRequestProto) ProtoReflect added in v2.2.1 

func (x *MonitorHealthRequestProto) ProtoReflect() protoreflect.Message

func (*MonitorHealthRequestProto) Reset 

func (x *MonitorHealthRequestProto) Reset()

func (*MonitorHealthRequestProto) String 

func (x *MonitorHealthRequestProto) String() string

type MonitorHealthResponseProto 

type MonitorHealthResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*MonitorHealthResponseProto) Descriptor deprecated 

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

Deprecated: Use MonitorHealthResponseProto.ProtoReflect.Descriptor instead.

func (*MonitorHealthResponseProto) ProtoMessage 

func (*MonitorHealthResponseProto) ProtoMessage()

func (*MonitorHealthResponseProto) ProtoReflect added in v2.2.1 

func (x *MonitorHealthResponseProto) ProtoReflect() protoreflect.Message

func (*MonitorHealthResponseProto) Reset 

func (x *MonitorHealthResponseProto) Reset()

func (*MonitorHealthResponseProto) String 

func (x *MonitorHealthResponseProto) String() string

type ProtocolSignatureProto 

type ProtocolSignatureProto struct {
	Version *uint64  `protobuf:"varint,1,req,name=version" json:"version,omitempty"`
	Methods []uint32 `protobuf:"varint,2,rep,name=methods" json:"methods,omitempty"`
	// contains filtered or unexported fields
}

func (*ProtocolSignatureProto) Descriptor deprecated 

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

Deprecated: Use ProtocolSignatureProto.ProtoReflect.Descriptor instead.

func (*ProtocolSignatureProto) GetMethods 

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

func (*ProtocolSignatureProto) GetVersion 

func (x *ProtocolSignatureProto) GetVersion() uint64

func (*ProtocolSignatureProto) ProtoMessage 

func (*ProtocolSignatureProto) ProtoMessage()

func (*ProtocolSignatureProto) ProtoReflect added in v2.2.1 

func (x *ProtocolSignatureProto) ProtoReflect() protoreflect.Message

func (*ProtocolSignatureProto) Reset 

func (x *ProtocolSignatureProto) Reset()

func (*ProtocolSignatureProto) String 

func (x *ProtocolSignatureProto) String() string

type ProtocolVersionProto 

type ProtocolVersionProto struct {
	RpcKind  *string  `protobuf:"bytes,1,req,name=rpcKind" json:"rpcKind,omitempty"`    //RPC kind
	Versions []uint64 `protobuf:"varint,2,rep,name=versions" json:"versions,omitempty"` //Protocol version corresponding to the rpc kind.
	// contains filtered or unexported fields
}

* Protocol version with corresponding rpc kind.

func (*ProtocolVersionProto) Descriptor deprecated 

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

Deprecated: Use ProtocolVersionProto.ProtoReflect.Descriptor instead.

func (*ProtocolVersionProto) GetRpcKind 

func (x *ProtocolVersionProto) GetRpcKind() string

func (*ProtocolVersionProto) GetVersions 

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

func (*ProtocolVersionProto) ProtoMessage 

func (*ProtocolVersionProto) ProtoMessage()

func (*ProtocolVersionProto) ProtoReflect added in v2.2.1 

func (x *ProtocolVersionProto) ProtoReflect() protoreflect.Message

func (*ProtocolVersionProto) Reset 

func (x *ProtocolVersionProto) Reset()

func (*ProtocolVersionProto) String 

func (x *ProtocolVersionProto) String() string

type RPCCallerContextProto 

type RPCCallerContextProto struct {
	Context   *string `protobuf:"bytes,1,req,name=context" json:"context,omitempty"`
	Signature []byte  `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

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

func (*RPCCallerContextProto) Descriptor deprecated 

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

Deprecated: Use RPCCallerContextProto.ProtoReflect.Descriptor instead.

func (*RPCCallerContextProto) GetContext 

func (x *RPCCallerContextProto) GetContext() string

func (*RPCCallerContextProto) GetSignature 

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

func (*RPCCallerContextProto) ProtoMessage 

func (*RPCCallerContextProto) ProtoMessage()

func (*RPCCallerContextProto) ProtoReflect added in v2.2.1 

func (x *RPCCallerContextProto) ProtoReflect() protoreflect.Message

func (*RPCCallerContextProto) Reset 

func (x *RPCCallerContextProto) Reset()

func (*RPCCallerContextProto) String 

func (x *RPCCallerContextProto) String() string

type RPCTraceInfoProto 

type RPCTraceInfoProto struct {
	TraceId  *int64 `protobuf:"varint,1,opt,name=traceId" json:"traceId,omitempty"`   // parentIdHigh
	ParentId *int64 `protobuf:"varint,2,opt,name=parentId" json:"parentId,omitempty"` // parentIdLow
	// contains filtered or unexported fields
}

* 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 deprecated 

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

Deprecated: Use RPCTraceInfoProto.ProtoReflect.Descriptor instead.

func (*RPCTraceInfoProto) GetParentId 

func (x *RPCTraceInfoProto) GetParentId() int64

func (*RPCTraceInfoProto) GetTraceId 

func (x *RPCTraceInfoProto) GetTraceId() int64

func (*RPCTraceInfoProto) ProtoMessage 

func (*RPCTraceInfoProto) ProtoMessage()

func (*RPCTraceInfoProto) ProtoReflect added in v2.2.1 

func (x *RPCTraceInfoProto) ProtoReflect() protoreflect.Message

func (*RPCTraceInfoProto) Reset 

func (x *RPCTraceInfoProto) Reset()

func (*RPCTraceInfoProto) String 

func (x *RPCTraceInfoProto) String() string

type RefreshCallQueueRequestProto 

type RefreshCallQueueRequestProto struct {
	// contains filtered or unexported fields
}

* 

Refresh callqueue request.

func (*RefreshCallQueueRequestProto) Descriptor deprecated 

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

Deprecated: Use RefreshCallQueueRequestProto.ProtoReflect.Descriptor instead.

func (*RefreshCallQueueRequestProto) ProtoMessage 

func (*RefreshCallQueueRequestProto) ProtoMessage()

func (*RefreshCallQueueRequestProto) ProtoReflect added in v2.2.1 

func (x *RefreshCallQueueRequestProto) ProtoReflect() protoreflect.Message

func (*RefreshCallQueueRequestProto) Reset 

func (x *RefreshCallQueueRequestProto) Reset()

func (*RefreshCallQueueRequestProto) String 

func (x *RefreshCallQueueRequestProto) String() string

type RefreshCallQueueResponseProto 

type RefreshCallQueueResponseProto struct {
	// contains filtered or unexported fields
}

* void response.

func (*RefreshCallQueueResponseProto) Descriptor deprecated 

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

Deprecated: Use RefreshCallQueueResponseProto.ProtoReflect.Descriptor instead.

func (*RefreshCallQueueResponseProto) ProtoMessage 

func (*RefreshCallQueueResponseProto) ProtoMessage()

func (*RefreshCallQueueResponseProto) ProtoReflect added in v2.2.1 

func (x *RefreshCallQueueResponseProto) ProtoReflect() protoreflect.Message

func (*RefreshCallQueueResponseProto) Reset 

func (x *RefreshCallQueueResponseProto) Reset()

func (*RefreshCallQueueResponseProto) String 

func (x *RefreshCallQueueResponseProto) String() string

type RefreshServiceAclRequestProto 

type RefreshServiceAclRequestProto struct {
	// contains filtered or unexported fields
}

* 

Refresh service acl request.

func (*RefreshServiceAclRequestProto) Descriptor deprecated 

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

Deprecated: Use RefreshServiceAclRequestProto.ProtoReflect.Descriptor instead.

func (*RefreshServiceAclRequestProto) ProtoMessage 

func (*RefreshServiceAclRequestProto) ProtoMessage()

func (*RefreshServiceAclRequestProto) ProtoReflect added in v2.2.1 

func (x *RefreshServiceAclRequestProto) ProtoReflect() protoreflect.Message

func (*RefreshServiceAclRequestProto) Reset 

func (x *RefreshServiceAclRequestProto) Reset()

func (*RefreshServiceAclRequestProto) String 

func (x *RefreshServiceAclRequestProto) String() string

type RefreshServiceAclResponseProto 

type RefreshServiceAclResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*RefreshServiceAclResponseProto) Descriptor deprecated 

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

Deprecated: Use RefreshServiceAclResponseProto.ProtoReflect.Descriptor instead.

func (*RefreshServiceAclResponseProto) ProtoMessage 

func (*RefreshServiceAclResponseProto) ProtoMessage()

func (*RefreshServiceAclResponseProto) ProtoReflect added in v2.2.1 

func (x *RefreshServiceAclResponseProto) ProtoReflect() protoreflect.Message

func (*RefreshServiceAclResponseProto) Reset 

func (x *RefreshServiceAclResponseProto) Reset()

func (*RefreshServiceAclResponseProto) String 

func (x *RefreshServiceAclResponseProto) String() string

type RefreshSuperUserGroupsConfigurationRequestProto 

type RefreshSuperUserGroupsConfigurationRequestProto struct {
	// contains filtered or unexported fields
}

* Refresh superuser configuration request.

func (*RefreshSuperUserGroupsConfigurationRequestProto) Descriptor deprecated 

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

Deprecated: Use RefreshSuperUserGroupsConfigurationRequestProto.ProtoReflect.Descriptor instead.

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage 

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoReflect added in v2.2.1 

func (x *RefreshSuperUserGroupsConfigurationRequestProto) ProtoReflect() protoreflect.Message

func (*RefreshSuperUserGroupsConfigurationRequestProto) Reset 

func (x *RefreshSuperUserGroupsConfigurationRequestProto) Reset()

func (*RefreshSuperUserGroupsConfigurationRequestProto) String 

func (x *RefreshSuperUserGroupsConfigurationRequestProto) String() string

type RefreshSuperUserGroupsConfigurationResponseProto 

type RefreshSuperUserGroupsConfigurationResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*RefreshSuperUserGroupsConfigurationResponseProto) Descriptor deprecated 

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

Deprecated: Use RefreshSuperUserGroupsConfigurationResponseProto.ProtoReflect.Descriptor instead.

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage 

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoReflect added in v2.2.1 

func (x *RefreshSuperUserGroupsConfigurationResponseProto) ProtoReflect() protoreflect.Message

func (*RefreshSuperUserGroupsConfigurationResponseProto) Reset 

func (x *RefreshSuperUserGroupsConfigurationResponseProto) Reset()

func (*RefreshSuperUserGroupsConfigurationResponseProto) String 

func (x *RefreshSuperUserGroupsConfigurationResponseProto) String() string

type RefreshUserToGroupsMappingsRequestProto 

type RefreshUserToGroupsMappingsRequestProto struct {
	// contains filtered or unexported fields
}

* 

Refresh user to group mappings request.

func (*RefreshUserToGroupsMappingsRequestProto) Descriptor deprecated 

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

Deprecated: Use RefreshUserToGroupsMappingsRequestProto.ProtoReflect.Descriptor instead.

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage 

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsRequestProto) ProtoReflect added in v2.2.1 

func (x *RefreshUserToGroupsMappingsRequestProto) ProtoReflect() protoreflect.Message

func (*RefreshUserToGroupsMappingsRequestProto) Reset 

func (x *RefreshUserToGroupsMappingsRequestProto) Reset()

func (*RefreshUserToGroupsMappingsRequestProto) String 

func (x *RefreshUserToGroupsMappingsRequestProto) String() string

type RefreshUserToGroupsMappingsResponseProto 

type RefreshUserToGroupsMappingsResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*RefreshUserToGroupsMappingsResponseProto) Descriptor deprecated 

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

Deprecated: Use RefreshUserToGroupsMappingsResponseProto.ProtoReflect.Descriptor instead.

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage 

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsResponseProto) ProtoReflect added in v2.2.1 

func (x *RefreshUserToGroupsMappingsResponseProto) ProtoReflect() protoreflect.Message

func (*RefreshUserToGroupsMappingsResponseProto) Reset 

func (x *RefreshUserToGroupsMappingsResponseProto) Reset()

func (*RefreshUserToGroupsMappingsResponseProto) String 

func (x *RefreshUserToGroupsMappingsResponseProto) String() string

type RemoveSpanReceiverRequestProto 

type RemoveSpanReceiverRequestProto struct {
	Id *int64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSpanReceiverRequestProto) Descriptor deprecated 

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

Deprecated: Use RemoveSpanReceiverRequestProto.ProtoReflect.Descriptor instead.

func (*RemoveSpanReceiverRequestProto) GetId 

func (x *RemoveSpanReceiverRequestProto) GetId() int64

func (*RemoveSpanReceiverRequestProto) ProtoMessage 

func (*RemoveSpanReceiverRequestProto) ProtoMessage()

func (*RemoveSpanReceiverRequestProto) ProtoReflect added in v2.2.1 

func (x *RemoveSpanReceiverRequestProto) ProtoReflect() protoreflect.Message

func (*RemoveSpanReceiverRequestProto) Reset 

func (x *RemoveSpanReceiverRequestProto) Reset()

func (*RemoveSpanReceiverRequestProto) String 

func (x *RemoveSpanReceiverRequestProto) String() string

type RemoveSpanReceiverResponseProto 

type RemoveSpanReceiverResponseProto struct {
	// contains filtered or unexported fields
}

func (*RemoveSpanReceiverResponseProto) Descriptor deprecated 

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

Deprecated: Use RemoveSpanReceiverResponseProto.ProtoReflect.Descriptor instead.

func (*RemoveSpanReceiverResponseProto) ProtoMessage 

func (*RemoveSpanReceiverResponseProto) ProtoMessage()

func (*RemoveSpanReceiverResponseProto) ProtoReflect added in v2.2.1 

func (x *RemoveSpanReceiverResponseProto) ProtoReflect() protoreflect.Message

func (*RemoveSpanReceiverResponseProto) Reset 

func (x *RemoveSpanReceiverResponseProto) Reset()

func (*RemoveSpanReceiverResponseProto) String 

func (x *RemoveSpanReceiverResponseProto) String() string

type RenewDelegationTokenRequestProto 

type RenewDelegationTokenRequestProto struct {
	Token *TokenProto `protobuf:"bytes,1,req,name=token" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewDelegationTokenRequestProto) Descriptor deprecated 

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

Deprecated: Use RenewDelegationTokenRequestProto.ProtoReflect.Descriptor instead.

func (*RenewDelegationTokenRequestProto) GetToken 

func (x *RenewDelegationTokenRequestProto) GetToken() *TokenProto

func (*RenewDelegationTokenRequestProto) ProtoMessage 

func (*RenewDelegationTokenRequestProto) ProtoMessage()

func (*RenewDelegationTokenRequestProto) ProtoReflect added in v2.2.1 

func (x *RenewDelegationTokenRequestProto) ProtoReflect() protoreflect.Message

func (*RenewDelegationTokenRequestProto) Reset 

func (x *RenewDelegationTokenRequestProto) Reset()

func (*RenewDelegationTokenRequestProto) String 

func (x *RenewDelegationTokenRequestProto) String() string

type RenewDelegationTokenResponseProto 

type RenewDelegationTokenResponseProto struct {
	NewExpiryTime *uint64 `protobuf:"varint,1,req,name=newExpiryTime" json:"newExpiryTime,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewDelegationTokenResponseProto) Descriptor deprecated 

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

Deprecated: Use RenewDelegationTokenResponseProto.ProtoReflect.Descriptor instead.

func (*RenewDelegationTokenResponseProto) GetNewExpiryTime 

func (x *RenewDelegationTokenResponseProto) GetNewExpiryTime() uint64

func (*RenewDelegationTokenResponseProto) ProtoMessage 

func (*RenewDelegationTokenResponseProto) ProtoMessage()

func (*RenewDelegationTokenResponseProto) ProtoReflect added in v2.2.1 

func (x *RenewDelegationTokenResponseProto) ProtoReflect() protoreflect.Message

func (*RenewDelegationTokenResponseProto) Reset 

func (x *RenewDelegationTokenResponseProto) Reset()

func (*RenewDelegationTokenResponseProto) String 

func (x *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"`
	// contains filtered or unexported fields
}

* 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 deprecated 

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

Deprecated: Use RequestHeaderProto.ProtoReflect.Descriptor instead.

func (*RequestHeaderProto) GetClientProtocolVersion 

func (x *RequestHeaderProto) GetClientProtocolVersion() uint64

func (*RequestHeaderProto) GetDeclaringClassProtocolName 

func (x *RequestHeaderProto) GetDeclaringClassProtocolName() string

func (*RequestHeaderProto) GetMethodName 

func (x *RequestHeaderProto) GetMethodName() string

func (*RequestHeaderProto) ProtoMessage 

func (*RequestHeaderProto) ProtoMessage()

func (*RequestHeaderProto) ProtoReflect added in v2.2.1 

func (x *RequestHeaderProto) ProtoReflect() protoreflect.Message

func (*RequestHeaderProto) Reset 

func (x *RequestHeaderProto) Reset()

func (*RequestHeaderProto) String 

func (x *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 // Used for built in calls by tests
	RpcKindProto_RPC_WRITABLE        RpcKindProto = 1 // Use WritableRpcEngine
	RpcKindProto_RPC_PROTOCOL_BUFFER RpcKindProto = 2 // Use ProtobufRpcEngine
)

func (RpcKindProto) Descriptor added in v2.2.1 

func (RpcKindProto) Descriptor() protoreflect.EnumDescriptor

func (RpcKindProto) Enum 

func (x RpcKindProto) Enum() *RpcKindProto

func (RpcKindProto) EnumDescriptor deprecated 

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

Deprecated: Use RpcKindProto.Descriptor instead.

func (RpcKindProto) Number added in v2.2.1 

func (x RpcKindProto) Number() protoreflect.EnumNumber

func (RpcKindProto) String 

func (x RpcKindProto) String() string

func (RpcKindProto) Type added in v2.2.1 

func (RpcKindProto) Type() protoreflect.EnumType

func (*RpcKindProto) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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"`  // a sequence number that is sent back in response
	ClientId []byte                                `protobuf:"bytes,4,req,name=clientId" json:"clientId,omitempty"` // Globally unique client ID
	// 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"`         // tracing info
	CallerContext *RPCCallerContextProto `protobuf:"bytes,7,opt,name=callerContext" json:"callerContext,omitempty"` // call context
	StateId       *int64                 `protobuf:"varint,8,opt,name=stateId" json:"stateId,omitempty"`            // The last seen Global State ID
	// contains filtered or unexported fields
}

func (*RpcRequestHeaderProto) Descriptor deprecated 

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

Deprecated: Use RpcRequestHeaderProto.ProtoReflect.Descriptor instead.

func (*RpcRequestHeaderProto) GetCallId 

func (x *RpcRequestHeaderProto) GetCallId() int32

func (*RpcRequestHeaderProto) GetCallerContext 

func (x *RpcRequestHeaderProto) GetCallerContext() *RPCCallerContextProto

func (*RpcRequestHeaderProto) GetClientId 

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

func (*RpcRequestHeaderProto) GetRetryCount 

func (x *RpcRequestHeaderProto) GetRetryCount() int32

func (*RpcRequestHeaderProto) GetRpcKind 

func (x *RpcRequestHeaderProto) GetRpcKind() RpcKindProto

func (*RpcRequestHeaderProto) GetRpcOp 

func (x *RpcRequestHeaderProto) GetRpcOp() RpcRequestHeaderProto_OperationProto

func (*RpcRequestHeaderProto) GetStateId added in v2.2.1 

func (x *RpcRequestHeaderProto) GetStateId() int64

func (*RpcRequestHeaderProto) GetTraceInfo 

func (x *RpcRequestHeaderProto) GetTraceInfo() *RPCTraceInfoProto

func (*RpcRequestHeaderProto) ProtoMessage 

func (*RpcRequestHeaderProto) ProtoMessage()

func (*RpcRequestHeaderProto) ProtoReflect added in v2.2.1 

func (x *RpcRequestHeaderProto) ProtoReflect() protoreflect.Message

func (*RpcRequestHeaderProto) Reset 

func (x *RpcRequestHeaderProto) Reset()

func (*RpcRequestHeaderProto) String 

func (x *RpcRequestHeaderProto) String() string

type RpcRequestHeaderProto_OperationProto 

type RpcRequestHeaderProto_OperationProto int32
const (
	RpcRequestHeaderProto_RPC_FINAL_PACKET        RpcRequestHeaderProto_OperationProto = 0 // The final RPC Packet
	RpcRequestHeaderProto_RPC_CONTINUATION_PACKET RpcRequestHeaderProto_OperationProto = 1 // not implemented yet
	RpcRequestHeaderProto_RPC_CLOSE_CONNECTION    RpcRequestHeaderProto_OperationProto = 2 // close the rpc connection
)

func (RpcRequestHeaderProto_OperationProto) Descriptor added in v2.2.1 

func (RpcRequestHeaderProto_OperationProto) Descriptor() protoreflect.EnumDescriptor

func (RpcRequestHeaderProto_OperationProto) Enum 

func (x RpcRequestHeaderProto_OperationProto) Enum() *RpcRequestHeaderProto_OperationProto

func (RpcRequestHeaderProto_OperationProto) EnumDescriptor deprecated 

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

Deprecated: Use RpcRequestHeaderProto_OperationProto.Descriptor instead.

func (RpcRequestHeaderProto_OperationProto) Number added in v2.2.1 

func (x RpcRequestHeaderProto_OperationProto) Number() protoreflect.EnumNumber

func (RpcRequestHeaderProto_OperationProto) String 

func (x RpcRequestHeaderProto_OperationProto) String() string

func (RpcRequestHeaderProto_OperationProto) Type added in v2.2.1 

func (RpcRequestHeaderProto_OperationProto) Type() protoreflect.EnumType

func (*RpcRequestHeaderProto_OperationProto) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type RpcResponseHeaderProto 

type RpcResponseHeaderProto struct {
	CallId              *uint32                                   `protobuf:"varint,1,req,name=callId" json:"callId,omitempty"` // callId used in Request
	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"` // Sent if success or fail
	ExceptionClassName  *string                                   `protobuf:"bytes,4,opt,name=exceptionClassName" json:"exceptionClassName,omitempty"`    // if request fails
	ErrorMsg            *string                                   `protobuf:"bytes,5,opt,name=errorMsg" json:"errorMsg,omitempty"`                        // if request fails, often contains strack trace
	ErrorDetail         *RpcResponseHeaderProto_RpcErrorCodeProto ``                                                                                      // in case of error
	/* 129-byte string literal not displayed */
	ClientId   []byte `protobuf:"bytes,7,opt,name=clientId" json:"clientId,omitempty"` // Globally unique client ID
	RetryCount *int32 `protobuf:"zigzag32,8,opt,name=retryCount,def=-1" json:"retryCount,omitempty"`
	StateId    *int64 `protobuf:"varint,9,opt,name=stateId" json:"stateId,omitempty"` // The last written Global State ID
	// contains filtered or unexported fields
}

* 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 deprecated 

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

Deprecated: Use RpcResponseHeaderProto.ProtoReflect.Descriptor instead.

func (*RpcResponseHeaderProto) GetCallId 

func (x *RpcResponseHeaderProto) GetCallId() uint32

func (*RpcResponseHeaderProto) GetClientId 

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

func (*RpcResponseHeaderProto) GetErrorDetail 

func (x *RpcResponseHeaderProto) GetErrorDetail() RpcResponseHeaderProto_RpcErrorCodeProto

func (*RpcResponseHeaderProto) GetErrorMsg 

func (x *RpcResponseHeaderProto) GetErrorMsg() string

func (*RpcResponseHeaderProto) GetExceptionClassName 

func (x *RpcResponseHeaderProto) GetExceptionClassName() string

func (*RpcResponseHeaderProto) GetRetryCount 

func (x *RpcResponseHeaderProto) GetRetryCount() int32

func (*RpcResponseHeaderProto) GetServerIpcVersionNum 

func (x *RpcResponseHeaderProto) GetServerIpcVersionNum() uint32

func (*RpcResponseHeaderProto) GetStateId added in v2.2.1 

func (x *RpcResponseHeaderProto) GetStateId() int64

func (*RpcResponseHeaderProto) GetStatus 

func (x *RpcResponseHeaderProto) GetStatus() RpcResponseHeaderProto_RpcStatusProto

func (*RpcResponseHeaderProto) ProtoMessage 

func (*RpcResponseHeaderProto) ProtoMessage()

func (*RpcResponseHeaderProto) ProtoReflect added in v2.2.1 

func (x *RpcResponseHeaderProto) ProtoReflect() protoreflect.Message

func (*RpcResponseHeaderProto) Reset 

func (x *RpcResponseHeaderProto) Reset()

func (*RpcResponseHeaderProto) String 

func (x *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 // RPC Failed - rpc app threw exception
	RpcResponseHeaderProto_ERROR_NO_SUCH_METHOD       RpcResponseHeaderProto_RpcErrorCodeProto = 2 // Rpc error - no such method
	RpcResponseHeaderProto_ERROR_NO_SUCH_PROTOCOL     RpcResponseHeaderProto_RpcErrorCodeProto = 3 // Rpc error - no such protocol
	RpcResponseHeaderProto_ERROR_RPC_SERVER           RpcResponseHeaderProto_RpcErrorCodeProto = 4 // Rpc error on server side
	RpcResponseHeaderProto_ERROR_SERIALIZING_RESPONSE RpcResponseHeaderProto_RpcErrorCodeProto = 5 // error serializign response
	RpcResponseHeaderProto_ERROR_RPC_VERSION_MISMATCH RpcResponseHeaderProto_RpcErrorCodeProto = 6 // Rpc protocol version mismatch
	// Fatal Server side Rpc error - connection closed
	RpcResponseHeaderProto_FATAL_UNKNOWN                   RpcResponseHeaderProto_RpcErrorCodeProto = 10 // unknown Fatal error
	RpcResponseHeaderProto_FATAL_UNSUPPORTED_SERIALIZATION RpcResponseHeaderProto_RpcErrorCodeProto = 11 // IPC layer serilization type invalid
	RpcResponseHeaderProto_FATAL_INVALID_RPC_HEADER        RpcResponseHeaderProto_RpcErrorCodeProto = 12 // fields of RpcHeader are invalid
	RpcResponseHeaderProto_FATAL_DESERIALIZING_REQUEST     RpcResponseHeaderProto_RpcErrorCodeProto = 13 // could not deserilize rpc request
	RpcResponseHeaderProto_FATAL_VERSION_MISMATCH          RpcResponseHeaderProto_RpcErrorCodeProto = 14 // Ipc Layer version mismatch
	RpcResponseHeaderProto_FATAL_UNAUTHORIZED              RpcResponseHeaderProto_RpcErrorCodeProto = 15 // Auth failed
)

func (RpcResponseHeaderProto_RpcErrorCodeProto) Descriptor added in v2.2.1 

func (RpcResponseHeaderProto_RpcErrorCodeProto) Descriptor() protoreflect.EnumDescriptor

func (RpcResponseHeaderProto_RpcErrorCodeProto) Enum 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) Enum() *RpcResponseHeaderProto_RpcErrorCodeProto

func (RpcResponseHeaderProto_RpcErrorCodeProto) EnumDescriptor deprecated 

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

Deprecated: Use RpcResponseHeaderProto_RpcErrorCodeProto.Descriptor instead.

func (RpcResponseHeaderProto_RpcErrorCodeProto) Number added in v2.2.1 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) Number() protoreflect.EnumNumber

func (RpcResponseHeaderProto_RpcErrorCodeProto) String 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) String() string

func (RpcResponseHeaderProto_RpcErrorCodeProto) Type added in v2.2.1 

func (RpcResponseHeaderProto_RpcErrorCodeProto) Type() protoreflect.EnumType

func (*RpcResponseHeaderProto_RpcErrorCodeProto) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type RpcResponseHeaderProto_RpcStatusProto 

type RpcResponseHeaderProto_RpcStatusProto int32
const (
	RpcResponseHeaderProto_SUCCESS RpcResponseHeaderProto_RpcStatusProto = 0 // RPC succeeded
	RpcResponseHeaderProto_ERROR   RpcResponseHeaderProto_RpcStatusProto = 1 // RPC or error - connection left open for future calls
	RpcResponseHeaderProto_FATAL   RpcResponseHeaderProto_RpcStatusProto = 2 // Fatal error - connection closed
)

func (RpcResponseHeaderProto_RpcStatusProto) Descriptor added in v2.2.1 

func (RpcResponseHeaderProto_RpcStatusProto) Descriptor() protoreflect.EnumDescriptor

func (RpcResponseHeaderProto_RpcStatusProto) Enum 

func (x RpcResponseHeaderProto_RpcStatusProto) Enum() *RpcResponseHeaderProto_RpcStatusProto

func (RpcResponseHeaderProto_RpcStatusProto) EnumDescriptor deprecated 

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

Deprecated: Use RpcResponseHeaderProto_RpcStatusProto.Descriptor instead.

func (RpcResponseHeaderProto_RpcStatusProto) Number added in v2.2.1 

func (x RpcResponseHeaderProto_RpcStatusProto) Number() protoreflect.EnumNumber

func (RpcResponseHeaderProto_RpcStatusProto) String 

func (x RpcResponseHeaderProto_RpcStatusProto) String() string

func (RpcResponseHeaderProto_RpcStatusProto) Type added in v2.2.1 

func (RpcResponseHeaderProto_RpcStatusProto) Type() protoreflect.EnumType

func (*RpcResponseHeaderProto_RpcStatusProto) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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"`
	// contains filtered or unexported fields
}

func (*RpcSaslProto) Descriptor deprecated 

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

Deprecated: Use RpcSaslProto.ProtoReflect.Descriptor instead.

func (*RpcSaslProto) GetAuths 

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

func (*RpcSaslProto) GetState 

func (x *RpcSaslProto) GetState() RpcSaslProto_SaslState

func (*RpcSaslProto) GetToken 

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

func (*RpcSaslProto) GetVersion 

func (x *RpcSaslProto) GetVersion() uint32

func (*RpcSaslProto) ProtoMessage 

func (*RpcSaslProto) ProtoMessage()

func (*RpcSaslProto) ProtoReflect added in v2.2.1 

func (x *RpcSaslProto) ProtoReflect() protoreflect.Message

func (*RpcSaslProto) Reset 

func (x *RpcSaslProto) Reset()

func (*RpcSaslProto) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*RpcSaslProto_SaslAuth) Descriptor deprecated 

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

Deprecated: Use RpcSaslProto_SaslAuth.ProtoReflect.Descriptor instead.

func (*RpcSaslProto_SaslAuth) GetChallenge 

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

func (*RpcSaslProto_SaslAuth) GetMechanism 

func (x *RpcSaslProto_SaslAuth) GetMechanism() string

func (*RpcSaslProto_SaslAuth) GetMethod 

func (x *RpcSaslProto_SaslAuth) GetMethod() string

func (*RpcSaslProto_SaslAuth) GetProtocol 

func (x *RpcSaslProto_SaslAuth) GetProtocol() string

func (*RpcSaslProto_SaslAuth) GetServerId 

func (x *RpcSaslProto_SaslAuth) GetServerId() string

func (*RpcSaslProto_SaslAuth) ProtoMessage 

func (*RpcSaslProto_SaslAuth) ProtoMessage()

func (*RpcSaslProto_SaslAuth) ProtoReflect added in v2.2.1 

func (x *RpcSaslProto_SaslAuth) ProtoReflect() protoreflect.Message

func (*RpcSaslProto_SaslAuth) Reset 

func (x *RpcSaslProto_SaslAuth) Reset()

func (*RpcSaslProto_SaslAuth) String 

func (x *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) Descriptor added in v2.2.1 

func (RpcSaslProto_SaslState) Descriptor() protoreflect.EnumDescriptor

func (RpcSaslProto_SaslState) Enum 

func (x RpcSaslProto_SaslState) Enum() *RpcSaslProto_SaslState

func (RpcSaslProto_SaslState) EnumDescriptor deprecated 

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

Deprecated: Use RpcSaslProto_SaslState.Descriptor instead.

func (RpcSaslProto_SaslState) Number added in v2.2.1 

func (x RpcSaslProto_SaslState) Number() protoreflect.EnumNumber

func (RpcSaslProto_SaslState) String 

func (x RpcSaslProto_SaslState) String() string

func (RpcSaslProto_SaslState) Type added in v2.2.1 

func (RpcSaslProto_SaslState) Type() protoreflect.EnumType

func (*RpcSaslProto_SaslState) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type SpanReceiverListInfo 

type SpanReceiverListInfo struct {
	Id        *int64  `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	ClassName *string `protobuf:"bytes,2,req,name=className" json:"className,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanReceiverListInfo) Descriptor deprecated 

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

Deprecated: Use SpanReceiverListInfo.ProtoReflect.Descriptor instead.

func (*SpanReceiverListInfo) GetClassName 

func (x *SpanReceiverListInfo) GetClassName() string

func (*SpanReceiverListInfo) GetId 

func (x *SpanReceiverListInfo) GetId() int64

func (*SpanReceiverListInfo) ProtoMessage 

func (*SpanReceiverListInfo) ProtoMessage()

func (*SpanReceiverListInfo) ProtoReflect added in v2.2.1 

func (x *SpanReceiverListInfo) ProtoReflect() protoreflect.Message

func (*SpanReceiverListInfo) Reset 

func (x *SpanReceiverListInfo) Reset()

func (*SpanReceiverListInfo) String 

func (x *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"`
	// contains filtered or unexported fields
}

* Security token identifier

func (*TokenProto) Descriptor deprecated 

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

Deprecated: Use TokenProto.ProtoReflect.Descriptor instead.

func (*TokenProto) GetIdentifier 

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

func (*TokenProto) GetKind 

func (x *TokenProto) GetKind() string

func (*TokenProto) GetPassword 

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

func (*TokenProto) GetService 

func (x *TokenProto) GetService() string

func (*TokenProto) ProtoMessage 

func (*TokenProto) ProtoMessage()

func (*TokenProto) ProtoReflect added in v2.2.1 

func (x *TokenProto) ProtoReflect() protoreflect.Message

func (*TokenProto) Reset 

func (x *TokenProto) Reset()

func (*TokenProto) String 

func (x *TokenProto) String() string

type TransitionToActiveRequestProto 

type TransitionToActiveRequestProto struct {
	ReqInfo *HAStateChangeRequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	// contains filtered or unexported fields
}

* void request

func (*TransitionToActiveRequestProto) Descriptor deprecated 

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

Deprecated: Use TransitionToActiveRequestProto.ProtoReflect.Descriptor instead.

func (*TransitionToActiveRequestProto) GetReqInfo 

func (x *TransitionToActiveRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToActiveRequestProto) ProtoMessage 

func (*TransitionToActiveRequestProto) ProtoMessage()

func (*TransitionToActiveRequestProto) ProtoReflect added in v2.2.1 

func (x *TransitionToActiveRequestProto) ProtoReflect() protoreflect.Message

func (*TransitionToActiveRequestProto) Reset 

func (x *TransitionToActiveRequestProto) Reset()

func (*TransitionToActiveRequestProto) String 

func (x *TransitionToActiveRequestProto) String() string

type TransitionToActiveResponseProto 

type TransitionToActiveResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*TransitionToActiveResponseProto) Descriptor deprecated 

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

Deprecated: Use TransitionToActiveResponseProto.ProtoReflect.Descriptor instead.

func (*TransitionToActiveResponseProto) ProtoMessage 

func (*TransitionToActiveResponseProto) ProtoMessage()

func (*TransitionToActiveResponseProto) ProtoReflect added in v2.2.1 

func (x *TransitionToActiveResponseProto) ProtoReflect() protoreflect.Message

func (*TransitionToActiveResponseProto) Reset 

func (x *TransitionToActiveResponseProto) Reset()

func (*TransitionToActiveResponseProto) String 

func (x *TransitionToActiveResponseProto) String() string

type TransitionToObserverRequestProto added in v2.2.1 

type TransitionToObserverRequestProto struct {
	ReqInfo *HAStateChangeRequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	// contains filtered or unexported fields
}

* void request

func (*TransitionToObserverRequestProto) Descriptor deprecated added in v2.2.1 

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

Deprecated: Use TransitionToObserverRequestProto.ProtoReflect.Descriptor instead.

func (*TransitionToObserverRequestProto) GetReqInfo added in v2.2.1 

func (x *TransitionToObserverRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToObserverRequestProto) ProtoMessage added in v2.2.1 

func (*TransitionToObserverRequestProto) ProtoMessage()

func (*TransitionToObserverRequestProto) ProtoReflect added in v2.2.1 

func (x *TransitionToObserverRequestProto) ProtoReflect() protoreflect.Message

func (*TransitionToObserverRequestProto) Reset added in v2.2.1 

func (x *TransitionToObserverRequestProto) Reset()

func (*TransitionToObserverRequestProto) String added in v2.2.1 

func (x *TransitionToObserverRequestProto) String() string

type TransitionToObserverResponseProto added in v2.2.1 

type TransitionToObserverResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*TransitionToObserverResponseProto) Descriptor deprecated added in v2.2.1 

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

Deprecated: Use TransitionToObserverResponseProto.ProtoReflect.Descriptor instead.

func (*TransitionToObserverResponseProto) ProtoMessage added in v2.2.1 

func (*TransitionToObserverResponseProto) ProtoMessage()

func (*TransitionToObserverResponseProto) ProtoReflect added in v2.2.1 

func (x *TransitionToObserverResponseProto) ProtoReflect() protoreflect.Message

func (*TransitionToObserverResponseProto) Reset added in v2.2.1 

func (x *TransitionToObserverResponseProto) Reset()

func (*TransitionToObserverResponseProto) String added in v2.2.1 

func (x *TransitionToObserverResponseProto) String() string

type TransitionToStandbyRequestProto 

type TransitionToStandbyRequestProto struct {
	ReqInfo *HAStateChangeRequestInfoProto `protobuf:"bytes,1,req,name=reqInfo" json:"reqInfo,omitempty"`
	// contains filtered or unexported fields
}

* void request

func (*TransitionToStandbyRequestProto) Descriptor deprecated 

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

Deprecated: Use TransitionToStandbyRequestProto.ProtoReflect.Descriptor instead.

func (*TransitionToStandbyRequestProto) GetReqInfo 

func (x *TransitionToStandbyRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToStandbyRequestProto) ProtoMessage 

func (*TransitionToStandbyRequestProto) ProtoMessage()

func (*TransitionToStandbyRequestProto) ProtoReflect added in v2.2.1 

func (x *TransitionToStandbyRequestProto) ProtoReflect() protoreflect.Message

func (*TransitionToStandbyRequestProto) Reset 

func (x *TransitionToStandbyRequestProto) Reset()

func (*TransitionToStandbyRequestProto) String 

func (x *TransitionToStandbyRequestProto) String() string

type TransitionToStandbyResponseProto 

type TransitionToStandbyResponseProto struct {
	// contains filtered or unexported fields
}

* void response

func (*TransitionToStandbyResponseProto) Descriptor deprecated 

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

Deprecated: Use TransitionToStandbyResponseProto.ProtoReflect.Descriptor instead.

func (*TransitionToStandbyResponseProto) ProtoMessage 

func (*TransitionToStandbyResponseProto) ProtoMessage()

func (*TransitionToStandbyResponseProto) ProtoReflect added in v2.2.1 

func (x *TransitionToStandbyResponseProto) ProtoReflect() protoreflect.Message

func (*TransitionToStandbyResponseProto) Reset 

func (x *TransitionToStandbyResponseProto) Reset()

func (*TransitionToStandbyResponseProto) String 

func (x *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"`
	// contains filtered or unexported fields
}

* Spec for UserInformationProto is specified in ProtoUtil#makeIpcConnectionContext

func (*UserInformationProto) Descriptor deprecated 

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

Deprecated: Use UserInformationProto.ProtoReflect.Descriptor instead.

func (*UserInformationProto) GetEffectiveUser 

func (x *UserInformationProto) GetEffectiveUser() string

func (*UserInformationProto) GetRealUser 

func (x *UserInformationProto) GetRealUser() string

func (*UserInformationProto) ProtoMessage 

func (*UserInformationProto) ProtoMessage()

func (*UserInformationProto) ProtoReflect added in v2.2.1 

func (x *UserInformationProto) ProtoReflect() protoreflect.Message

func (*UserInformationProto) Reset 

func (x *UserInformationProto) Reset()

func (*UserInformationProto) String 

func (x *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.