hadoop_common

package
v2.4.0 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2023 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 (*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 (*AddSpanReceiverResponseProto) ProtoMessage

func (*AddSpanReceiverResponseProto) ProtoMessage()

func (*AddSpanReceiverResponseProto) ProtoReflect added in v2.2.1

func (*AddSpanReceiverResponseProto) Reset

func (x *AddSpanReceiverResponseProto) Reset()

func (*AddSpanReceiverResponseProto) 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 (*CancelDelegationTokenRequestProto) ProtoMessage

func (*CancelDelegationTokenRequestProto) ProtoMessage()

func (*CancelDelegationTokenRequestProto) ProtoReflect added in v2.2.1

func (*CancelDelegationTokenRequestProto) Reset

func (*CancelDelegationTokenRequestProto) 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 (*CancelDelegationTokenResponseProto) Reset

func (*CancelDelegationTokenResponseProto) 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 (*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 (*GenericRefreshResponseCollectionProto) ProtoMessage

func (*GenericRefreshResponseCollectionProto) ProtoMessage()

func (*GenericRefreshResponseCollectionProto) ProtoReflect added in v2.2.1

func (*GenericRefreshResponseCollectionProto) Reset

func (*GenericRefreshResponseCollectionProto) 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 (*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 (*GetDelegationTokenRequestProto) Reset

func (x *GetDelegationTokenRequestProto) Reset()

func (*GetDelegationTokenRequestProto) 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 (*GetDelegationTokenResponseProto) ProtoMessage

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) ProtoReflect added in v2.2.1

func (*GetDelegationTokenResponseProto) Reset

func (*GetDelegationTokenResponseProto) 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 (*GetGroupsForUserRequestProto) Reset

func (x *GetGroupsForUserRequestProto) Reset()

func (*GetGroupsForUserRequestProto) 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 (*GetGroupsForUserResponseProto) Reset

func (x *GetGroupsForUserResponseProto) Reset()

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

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

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

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

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

func (x *GetServiceStatusRequestProto) Reset()

func (*GetServiceStatusRequestProto) 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 (*GetServiceStatusResponseProto) ProtoMessage

func (*GetServiceStatusResponseProto) ProtoMessage()

func (*GetServiceStatusResponseProto) ProtoReflect added in v2.2.1

func (*GetServiceStatusResponseProto) Reset

func (x *GetServiceStatusResponseProto) Reset()

func (*GetServiceStatusResponseProto) 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 (*GracefulFailoverRequestProto) Reset

func (x *GracefulFailoverRequestProto) Reset()

func (*GracefulFailoverRequestProto) 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 (*GracefulFailoverResponseProto) Reset

func (x *GracefulFailoverResponseProto) Reset()

func (*GracefulFailoverResponseProto) 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) 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 (HARequestSource) String

func (x HARequestSource) String() string

func (HARequestSource) Type added in v2.2.1

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

func (HAServiceStateProto) EnumDescriptor deprecated

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

Deprecated: Use HAServiceStateProto.Descriptor instead.

func (HAServiceStateProto) Number added in v2.2.1

func (HAServiceStateProto) String

func (x HAServiceStateProto) String() string

func (HAServiceStateProto) Type added in v2.2.1

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 (*HAStateChangeRequestInfoProto) ProtoMessage

func (*HAStateChangeRequestInfoProto) ProtoMessage()

func (*HAStateChangeRequestInfoProto) ProtoReflect added in v2.2.1

func (*HAStateChangeRequestInfoProto) Reset

func (x *HAStateChangeRequestInfoProto) Reset()

func (*HAStateChangeRequestInfoProto) 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 (*IpcConnectionContextProto) ProtoMessage

func (*IpcConnectionContextProto) ProtoMessage()

func (*IpcConnectionContextProto) ProtoReflect added in v2.2.1

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

func (x *ListSpanReceiversRequestProto) Reset()

func (*ListSpanReceiversRequestProto) 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 (*ListSpanReceiversResponseProto) Reset

func (x *ListSpanReceiversResponseProto) Reset()

func (*ListSpanReceiversResponseProto) 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 (*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 (*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 (*RefreshCallQueueRequestProto) Reset

func (x *RefreshCallQueueRequestProto) Reset()

func (*RefreshCallQueueRequestProto) 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 (*RefreshCallQueueResponseProto) Reset

func (x *RefreshCallQueueResponseProto) Reset()

func (*RefreshCallQueueResponseProto) 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 (*RefreshServiceAclRequestProto) Reset

func (x *RefreshServiceAclRequestProto) Reset()

func (*RefreshServiceAclRequestProto) 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 (*RefreshServiceAclResponseProto) Reset

func (x *RefreshServiceAclResponseProto) Reset()

func (*RefreshServiceAclResponseProto) String

type RefreshSuperUserGroupsConfigurationRequestProto

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

* Refresh superuser configuration request.

func (*RefreshSuperUserGroupsConfigurationRequestProto) Descriptor deprecated

Deprecated: Use RefreshSuperUserGroupsConfigurationRequestProto.ProtoReflect.Descriptor instead.

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoReflect added in v2.2.1

func (*RefreshSuperUserGroupsConfigurationRequestProto) Reset

func (*RefreshSuperUserGroupsConfigurationRequestProto) String

type RefreshSuperUserGroupsConfigurationResponseProto

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

* void response

func (*RefreshSuperUserGroupsConfigurationResponseProto) Descriptor deprecated

Deprecated: Use RefreshSuperUserGroupsConfigurationResponseProto.ProtoReflect.Descriptor instead.

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoReflect added in v2.2.1

func (*RefreshSuperUserGroupsConfigurationResponseProto) Reset

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

func (*RefreshUserToGroupsMappingsRequestProto) Reset

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

func (*RefreshUserToGroupsMappingsResponseProto) Reset

func (*RefreshUserToGroupsMappingsResponseProto) 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 (*RemoveSpanReceiverRequestProto) ProtoMessage

func (*RemoveSpanReceiverRequestProto) ProtoMessage()

func (*RemoveSpanReceiverRequestProto) ProtoReflect added in v2.2.1

func (*RemoveSpanReceiverRequestProto) Reset

func (x *RemoveSpanReceiverRequestProto) Reset()

func (*RemoveSpanReceiverRequestProto) 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 (*RemoveSpanReceiverResponseProto) Reset

func (*RemoveSpanReceiverResponseProto) 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 (*RenewDelegationTokenRequestProto) ProtoMessage

func (*RenewDelegationTokenRequestProto) ProtoMessage()

func (*RenewDelegationTokenRequestProto) ProtoReflect added in v2.2.1

func (*RenewDelegationTokenRequestProto) Reset

func (*RenewDelegationTokenRequestProto) 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 (*RenewDelegationTokenResponseProto) Reset

func (*RenewDelegationTokenResponseProto) String

type RequestHeaderProto

type RequestHeaderProto struct {

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

func (x RpcKindProto) String() string

func (RpcKindProto) Type added in v2.2.1

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

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 (RpcRequestHeaderProto_OperationProto) String

func (RpcRequestHeaderProto_OperationProto) Type added in v2.2.1

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

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 (RpcResponseHeaderProto_RpcErrorCodeProto) String

func (RpcResponseHeaderProto_RpcErrorCodeProto) Type added in v2.2.1

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

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 (RpcResponseHeaderProto_RpcStatusProto) String

func (RpcResponseHeaderProto_RpcStatusProto) Type added in v2.2.1

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

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 (RpcSaslProto_SaslState) String

func (x RpcSaslProto_SaslState) String() string

func (RpcSaslProto_SaslState) Type added in v2.2.1

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 (*TransitionToActiveRequestProto) ProtoMessage

func (*TransitionToActiveRequestProto) ProtoMessage()

func (*TransitionToActiveRequestProto) ProtoReflect added in v2.2.1

func (*TransitionToActiveRequestProto) Reset

func (x *TransitionToActiveRequestProto) Reset()

func (*TransitionToActiveRequestProto) 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 (*TransitionToActiveResponseProto) Reset

func (*TransitionToActiveResponseProto) 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 (*TransitionToObserverRequestProto) ProtoMessage added in v2.2.1

func (*TransitionToObserverRequestProto) ProtoMessage()

func (*TransitionToObserverRequestProto) ProtoReflect added in v2.2.1

func (*TransitionToObserverRequestProto) Reset added in v2.2.1

func (*TransitionToObserverRequestProto) String added in v2.2.1

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 (*TransitionToObserverResponseProto) Reset added in v2.2.1

func (*TransitionToObserverResponseProto) String added in v2.2.1

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 (*TransitionToStandbyRequestProto) ProtoMessage

func (*TransitionToStandbyRequestProto) ProtoMessage()

func (*TransitionToStandbyRequestProto) ProtoReflect added in v2.2.1

func (*TransitionToStandbyRequestProto) Reset

func (*TransitionToStandbyRequestProto) 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 (*TransitionToStandbyResponseProto) Reset

func (*TransitionToStandbyResponseProto) 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

Jump to

Keyboard shortcuts

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