Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

hadoop_common

package

Go to main page

Versions in this module

v2

v2.1.4

Jul 2, 2020

v2.1.3

Jul 2, 2020

v2.1.2

Jul 2, 2020

Changes in this version

+ const Default_RpcRequestHeaderProto_RetryCount

+ const Default_RpcResponseHeaderProto_RetryCount

+ var HARequestSource_name = map[int32]string

+ var HARequestSource_value = map[string]int32

+ var HAServiceStateProto_name = map[int32]string

+ var HAServiceStateProto_value = map[string]int32

+ var RpcKindProto_name = map[int32]string

+ var RpcKindProto_value = map[string]int32

+ var RpcRequestHeaderProto_OperationProto_name = map[int32]string

+ var RpcRequestHeaderProto_OperationProto_value = map[string]int32

+ var RpcResponseHeaderProto_RpcErrorCodeProto_name = map[int32]string

+ var RpcResponseHeaderProto_RpcErrorCodeProto_value = map[string]int32

+ var RpcResponseHeaderProto_RpcStatusProto_name = map[int32]string

+ var RpcResponseHeaderProto_RpcStatusProto_value = map[string]int32

+ var RpcSaslProto_SaslState_name = map[int32]string

+ var RpcSaslProto_SaslState_value = map[string]int32

+ type AddSpanReceiverRequestProto struct

+ ClassName *string

+ Config []*ConfigPair

+ XXX_unrecognized []byte

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

+ func (*AddSpanReceiverRequestProto) ProtoMessage()

+ func (m *AddSpanReceiverRequestProto) GetClassName() string

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

+ func (m *AddSpanReceiverRequestProto) Reset()

+ func (m *AddSpanReceiverRequestProto) String() string

+ type AddSpanReceiverResponseProto struct

+ Id *int64

+ XXX_unrecognized []byte

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

+ func (*AddSpanReceiverResponseProto) ProtoMessage()

+ func (m *AddSpanReceiverResponseProto) GetId() int64

+ func (m *AddSpanReceiverResponseProto) Reset()

+ func (m *AddSpanReceiverResponseProto) String() string

+ type CancelDelegationTokenRequestProto struct

+ Token *TokenProto

+ XXX_unrecognized []byte

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

+ func (*CancelDelegationTokenRequestProto) ProtoMessage()

+ func (m *CancelDelegationTokenRequestProto) GetToken() *TokenProto

+ func (m *CancelDelegationTokenRequestProto) Reset()

+ func (m *CancelDelegationTokenRequestProto) String() string

+ type CancelDelegationTokenResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*CancelDelegationTokenResponseProto) ProtoMessage()

+ func (m *CancelDelegationTokenResponseProto) Reset()

+ func (m *CancelDelegationTokenResponseProto) String() string

+ type CedeActiveRequestProto struct

+ MillisToCede *uint32

+ XXX_unrecognized []byte

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

+ func (*CedeActiveRequestProto) ProtoMessage()

+ func (m *CedeActiveRequestProto) GetMillisToCede() uint32

+ func (m *CedeActiveRequestProto) Reset()

+ func (m *CedeActiveRequestProto) String() string

+ type CedeActiveResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*CedeActiveResponseProto) ProtoMessage()

+ func (m *CedeActiveResponseProto) Reset()

+ func (m *CedeActiveResponseProto) String() string

+ type ConfigPair struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

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

+ func (*ConfigPair) ProtoMessage()

+ func (m *ConfigPair) GetKey() string

+ func (m *ConfigPair) GetValue() string

+ func (m *ConfigPair) Reset()

+ func (m *ConfigPair) String() string

+ type GenericRefreshRequestProto struct

+ Args []string

+ Identifier *string

+ XXX_unrecognized []byte

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

+ func (*GenericRefreshRequestProto) ProtoMessage()

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

+ func (m *GenericRefreshRequestProto) GetIdentifier() string

+ func (m *GenericRefreshRequestProto) Reset()

+ func (m *GenericRefreshRequestProto) String() string

+ type GenericRefreshResponseCollectionProto struct

+ Responses []*GenericRefreshResponseProto

+ XXX_unrecognized []byte

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

+ func (*GenericRefreshResponseCollectionProto) ProtoMessage()

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

+ func (m *GenericRefreshResponseCollectionProto) Reset()

+ func (m *GenericRefreshResponseCollectionProto) String() string

+ type GenericRefreshResponseProto struct

+ ExitStatus *int32

+ SenderName *string

+ UserMessage *string

+ XXX_unrecognized []byte

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

+ func (*GenericRefreshResponseProto) ProtoMessage()

+ func (m *GenericRefreshResponseProto) GetExitStatus() int32

+ func (m *GenericRefreshResponseProto) GetSenderName() string

+ func (m *GenericRefreshResponseProto) GetUserMessage() string

+ func (m *GenericRefreshResponseProto) Reset()

+ func (m *GenericRefreshResponseProto) String() string

+ type GetDelegationTokenRequestProto struct

+ Renewer *string

+ XXX_unrecognized []byte

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

+ func (*GetDelegationTokenRequestProto) ProtoMessage()

+ func (m *GetDelegationTokenRequestProto) GetRenewer() string

+ func (m *GetDelegationTokenRequestProto) Reset()

+ func (m *GetDelegationTokenRequestProto) String() string

+ type GetDelegationTokenResponseProto struct

+ Token *TokenProto

+ XXX_unrecognized []byte

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

+ func (*GetDelegationTokenResponseProto) ProtoMessage()

+ func (m *GetDelegationTokenResponseProto) GetToken() *TokenProto

+ func (m *GetDelegationTokenResponseProto) Reset()

+ func (m *GetDelegationTokenResponseProto) String() string

+ type GetGroupsForUserRequestProto struct

+ User *string

+ XXX_unrecognized []byte

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

+ func (*GetGroupsForUserRequestProto) ProtoMessage()

+ func (m *GetGroupsForUserRequestProto) GetUser() string

+ func (m *GetGroupsForUserRequestProto) Reset()

+ func (m *GetGroupsForUserRequestProto) String() string

+ type GetGroupsForUserResponseProto struct

+ Groups []string

+ XXX_unrecognized []byte

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

+ func (*GetGroupsForUserResponseProto) ProtoMessage()

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

+ func (m *GetGroupsForUserResponseProto) Reset()

+ func (m *GetGroupsForUserResponseProto) String() string

+ type GetProtocolSignatureRequestProto struct

+ Protocol *string

+ RpcKind *string

+ XXX_unrecognized []byte

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

+ func (*GetProtocolSignatureRequestProto) ProtoMessage()

+ func (m *GetProtocolSignatureRequestProto) GetProtocol() string

+ func (m *GetProtocolSignatureRequestProto) GetRpcKind() string

+ func (m *GetProtocolSignatureRequestProto) Reset()

+ func (m *GetProtocolSignatureRequestProto) String() string

+ type GetProtocolSignatureResponseProto struct

+ ProtocolSignature []*ProtocolSignatureProto

+ XXX_unrecognized []byte

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

+ func (*GetProtocolSignatureResponseProto) ProtoMessage()

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

+ func (m *GetProtocolSignatureResponseProto) Reset()

+ func (m *GetProtocolSignatureResponseProto) String() string

+ type GetProtocolVersionsRequestProto struct

+ Protocol *string

+ XXX_unrecognized []byte

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

+ func (*GetProtocolVersionsRequestProto) ProtoMessage()

+ func (m *GetProtocolVersionsRequestProto) GetProtocol() string

+ func (m *GetProtocolVersionsRequestProto) Reset()

+ func (m *GetProtocolVersionsRequestProto) String() string

+ type GetProtocolVersionsResponseProto struct

+ ProtocolVersions []*ProtocolVersionProto

+ XXX_unrecognized []byte

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

+ func (*GetProtocolVersionsResponseProto) ProtoMessage()

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

+ func (m *GetProtocolVersionsResponseProto) Reset()

+ func (m *GetProtocolVersionsResponseProto) String() string

+ type GetServiceStatusRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*GetServiceStatusRequestProto) ProtoMessage()

+ func (m *GetServiceStatusRequestProto) Reset()

+ func (m *GetServiceStatusRequestProto) String() string

+ type GetServiceStatusResponseProto struct

+ NotReadyReason *string

+ ReadyToBecomeActive *bool

+ State *HAServiceStateProto

+ XXX_unrecognized []byte

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

+ func (*GetServiceStatusResponseProto) ProtoMessage()

+ func (m *GetServiceStatusResponseProto) GetNotReadyReason() string

+ func (m *GetServiceStatusResponseProto) GetReadyToBecomeActive() bool

+ func (m *GetServiceStatusResponseProto) GetState() HAServiceStateProto

+ func (m *GetServiceStatusResponseProto) Reset()

+ func (m *GetServiceStatusResponseProto) String() string

+ type GracefulFailoverRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*GracefulFailoverRequestProto) ProtoMessage()

+ func (m *GracefulFailoverRequestProto) Reset()

+ func (m *GracefulFailoverRequestProto) String() string

+ type GracefulFailoverResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*GracefulFailoverResponseProto) ProtoMessage()

+ func (m *GracefulFailoverResponseProto) Reset()

+ func (m *GracefulFailoverResponseProto) String() string

+ type HARequestSource int32

+ const HARequestSource_REQUEST_BY_USER

+ const HARequestSource_REQUEST_BY_USER_FORCED

+ const HARequestSource_REQUEST_BY_ZKFC

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

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

+ func (x HARequestSource) Enum() *HARequestSource

+ func (x HARequestSource) String() string

+ type HAServiceStateProto int32

+ const HAServiceStateProto_ACTIVE

+ const HAServiceStateProto_INITIALIZING

+ const HAServiceStateProto_STANDBY

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

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

+ func (x HAServiceStateProto) Enum() *HAServiceStateProto

+ func (x HAServiceStateProto) String() string

+ type HAStateChangeRequestInfoProto struct

+ ReqSource *HARequestSource

+ XXX_unrecognized []byte

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

+ func (*HAStateChangeRequestInfoProto) ProtoMessage()

+ func (m *HAStateChangeRequestInfoProto) GetReqSource() HARequestSource

+ func (m *HAStateChangeRequestInfoProto) Reset()

+ func (m *HAStateChangeRequestInfoProto) String() string

+ type IpcConnectionContextProto struct

+ Protocol *string

+ UserInfo *UserInformationProto

+ XXX_unrecognized []byte

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

+ func (*IpcConnectionContextProto) ProtoMessage()

+ func (m *IpcConnectionContextProto) GetProtocol() string

+ func (m *IpcConnectionContextProto) GetUserInfo() *UserInformationProto

+ func (m *IpcConnectionContextProto) Reset()

+ func (m *IpcConnectionContextProto) String() string

+ type ListSpanReceiversRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*ListSpanReceiversRequestProto) ProtoMessage()

+ func (m *ListSpanReceiversRequestProto) Reset()

+ func (m *ListSpanReceiversRequestProto) String() string

+ type ListSpanReceiversResponseProto struct

+ Descriptions []*SpanReceiverListInfo

+ XXX_unrecognized []byte

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

+ func (*ListSpanReceiversResponseProto) ProtoMessage()

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

+ func (m *ListSpanReceiversResponseProto) Reset()

+ func (m *ListSpanReceiversResponseProto) String() string

+ type MonitorHealthRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*MonitorHealthRequestProto) ProtoMessage()

+ func (m *MonitorHealthRequestProto) Reset()

+ func (m *MonitorHealthRequestProto) String() string

+ type MonitorHealthResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*MonitorHealthResponseProto) ProtoMessage()

+ func (m *MonitorHealthResponseProto) Reset()

+ func (m *MonitorHealthResponseProto) String() string

+ type ProtocolSignatureProto struct

+ Methods []uint32

+ Version *uint64

+ XXX_unrecognized []byte

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

+ func (*ProtocolSignatureProto) ProtoMessage()

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

+ func (m *ProtocolSignatureProto) GetVersion() uint64

+ func (m *ProtocolSignatureProto) Reset()

+ func (m *ProtocolSignatureProto) String() string

+ type ProtocolVersionProto struct

+ RpcKind *string

+ Versions []uint64

+ XXX_unrecognized []byte

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

+ func (*ProtocolVersionProto) ProtoMessage()

+ func (m *ProtocolVersionProto) GetRpcKind() string

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

+ func (m *ProtocolVersionProto) Reset()

+ func (m *ProtocolVersionProto) String() string

+ type RPCCallerContextProto struct

+ Context *string

+ Signature []byte

+ XXX_unrecognized []byte

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

+ func (*RPCCallerContextProto) ProtoMessage()

+ func (m *RPCCallerContextProto) GetContext() string

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

+ func (m *RPCCallerContextProto) Reset()

+ func (m *RPCCallerContextProto) String() string

+ type RPCTraceInfoProto struct

+ ParentId *int64

+ TraceId *int64

+ XXX_unrecognized []byte

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

+ func (*RPCTraceInfoProto) ProtoMessage()

+ func (m *RPCTraceInfoProto) GetParentId() int64

+ func (m *RPCTraceInfoProto) GetTraceId() int64

+ func (m *RPCTraceInfoProto) Reset()

+ func (m *RPCTraceInfoProto) String() string

+ type RefreshCallQueueRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshCallQueueRequestProto) ProtoMessage()

+ func (m *RefreshCallQueueRequestProto) Reset()

+ func (m *RefreshCallQueueRequestProto) String() string

+ type RefreshCallQueueResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshCallQueueResponseProto) ProtoMessage()

+ func (m *RefreshCallQueueResponseProto) Reset()

+ func (m *RefreshCallQueueResponseProto) String() string

+ type RefreshServiceAclRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshServiceAclRequestProto) ProtoMessage()

+ func (m *RefreshServiceAclRequestProto) Reset()

+ func (m *RefreshServiceAclRequestProto) String() string

+ type RefreshServiceAclResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshServiceAclResponseProto) ProtoMessage()

+ func (m *RefreshServiceAclResponseProto) Reset()

+ func (m *RefreshServiceAclResponseProto) String() string

+ type RefreshSuperUserGroupsConfigurationRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage()

+ func (m *RefreshSuperUserGroupsConfigurationRequestProto) Reset()

+ func (m *RefreshSuperUserGroupsConfigurationRequestProto) String() string

+ type RefreshSuperUserGroupsConfigurationResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage()

+ func (m *RefreshSuperUserGroupsConfigurationResponseProto) Reset()

+ func (m *RefreshSuperUserGroupsConfigurationResponseProto) String() string

+ type RefreshUserToGroupsMappingsRequestProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage()

+ func (m *RefreshUserToGroupsMappingsRequestProto) Reset()

+ func (m *RefreshUserToGroupsMappingsRequestProto) String() string

+ type RefreshUserToGroupsMappingsResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage()

+ func (m *RefreshUserToGroupsMappingsResponseProto) Reset()

+ func (m *RefreshUserToGroupsMappingsResponseProto) String() string

+ type RemoveSpanReceiverRequestProto struct

+ Id *int64

+ XXX_unrecognized []byte

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

+ func (*RemoveSpanReceiverRequestProto) ProtoMessage()

+ func (m *RemoveSpanReceiverRequestProto) GetId() int64

+ func (m *RemoveSpanReceiverRequestProto) Reset()

+ func (m *RemoveSpanReceiverRequestProto) String() string

+ type RemoveSpanReceiverResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*RemoveSpanReceiverResponseProto) ProtoMessage()

+ func (m *RemoveSpanReceiverResponseProto) Reset()

+ func (m *RemoveSpanReceiverResponseProto) String() string

+ type RenewDelegationTokenRequestProto struct

+ Token *TokenProto

+ XXX_unrecognized []byte

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

+ func (*RenewDelegationTokenRequestProto) ProtoMessage()

+ func (m *RenewDelegationTokenRequestProto) GetToken() *TokenProto

+ func (m *RenewDelegationTokenRequestProto) Reset()

+ func (m *RenewDelegationTokenRequestProto) String() string

+ type RenewDelegationTokenResponseProto struct

+ NewExpiryTime *uint64

+ XXX_unrecognized []byte

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

+ func (*RenewDelegationTokenResponseProto) ProtoMessage()

+ func (m *RenewDelegationTokenResponseProto) GetNewExpiryTime() uint64

+ func (m *RenewDelegationTokenResponseProto) Reset()

+ func (m *RenewDelegationTokenResponseProto) String() string

+ type RequestHeaderProto struct

+ ClientProtocolVersion *uint64

+ DeclaringClassProtocolName *string

+ MethodName *string

+ XXX_unrecognized []byte

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

+ func (*RequestHeaderProto) ProtoMessage()

+ func (m *RequestHeaderProto) GetClientProtocolVersion() uint64

+ func (m *RequestHeaderProto) GetDeclaringClassProtocolName() string

+ func (m *RequestHeaderProto) GetMethodName() string

+ func (m *RequestHeaderProto) Reset()

+ func (m *RequestHeaderProto) String() string

+ type RpcKindProto int32

+ const RpcKindProto_RPC_BUILTIN

+ const RpcKindProto_RPC_PROTOCOL_BUFFER

+ const RpcKindProto_RPC_WRITABLE

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

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

+ func (x RpcKindProto) Enum() *RpcKindProto

+ func (x RpcKindProto) String() string

+ type RpcRequestHeaderProto struct

+ CallId *int32

+ CallerContext *RPCCallerContextProto

+ ClientId []byte

+ RetryCount *int32

+ RpcKind *RpcKindProto

+ RpcOp *RpcRequestHeaderProto_OperationProto

+ TraceInfo *RPCTraceInfoProto

+ XXX_unrecognized []byte

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

+ func (*RpcRequestHeaderProto) ProtoMessage()

+ func (m *RpcRequestHeaderProto) GetCallId() int32

+ func (m *RpcRequestHeaderProto) GetCallerContext() *RPCCallerContextProto

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

+ func (m *RpcRequestHeaderProto) GetRetryCount() int32

+ func (m *RpcRequestHeaderProto) GetRpcKind() RpcKindProto

+ func (m *RpcRequestHeaderProto) GetRpcOp() RpcRequestHeaderProto_OperationProto

+ func (m *RpcRequestHeaderProto) GetTraceInfo() *RPCTraceInfoProto

+ func (m *RpcRequestHeaderProto) Reset()

+ func (m *RpcRequestHeaderProto) String() string

+ type RpcRequestHeaderProto_OperationProto int32

+ const RpcRequestHeaderProto_RPC_CLOSE_CONNECTION

+ const RpcRequestHeaderProto_RPC_CONTINUATION_PACKET

+ const RpcRequestHeaderProto_RPC_FINAL_PACKET

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

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

+ func (x RpcRequestHeaderProto_OperationProto) Enum() *RpcRequestHeaderProto_OperationProto

+ func (x RpcRequestHeaderProto_OperationProto) String() string

+ type RpcResponseHeaderProto struct

+ CallId *uint32

+ ClientId []byte

+ ErrorDetail *RpcResponseHeaderProto_RpcErrorCodeProto

+ ErrorMsg *string

+ ExceptionClassName *string

+ RetryCount *int32

+ ServerIpcVersionNum *uint32

+ Status *RpcResponseHeaderProto_RpcStatusProto

+ XXX_unrecognized []byte

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

+ func (*RpcResponseHeaderProto) ProtoMessage()

+ func (m *RpcResponseHeaderProto) GetCallId() uint32

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

+ func (m *RpcResponseHeaderProto) GetErrorDetail() RpcResponseHeaderProto_RpcErrorCodeProto

+ func (m *RpcResponseHeaderProto) GetErrorMsg() string

+ func (m *RpcResponseHeaderProto) GetExceptionClassName() string

+ func (m *RpcResponseHeaderProto) GetRetryCount() int32

+ func (m *RpcResponseHeaderProto) GetServerIpcVersionNum() uint32

+ func (m *RpcResponseHeaderProto) GetStatus() RpcResponseHeaderProto_RpcStatusProto

+ func (m *RpcResponseHeaderProto) Reset()

+ func (m *RpcResponseHeaderProto) String() string

+ type RpcResponseHeaderProto_RpcErrorCodeProto int32

+ const RpcResponseHeaderProto_ERROR_APPLICATION

+ const RpcResponseHeaderProto_ERROR_NO_SUCH_METHOD

+ const RpcResponseHeaderProto_ERROR_NO_SUCH_PROTOCOL

+ const RpcResponseHeaderProto_ERROR_RPC_SERVER

+ const RpcResponseHeaderProto_ERROR_RPC_VERSION_MISMATCH

+ const RpcResponseHeaderProto_ERROR_SERIALIZING_RESPONSE

+ const RpcResponseHeaderProto_FATAL_DESERIALIZING_REQUEST

+ const RpcResponseHeaderProto_FATAL_INVALID_RPC_HEADER

+ const RpcResponseHeaderProto_FATAL_UNAUTHORIZED

+ const RpcResponseHeaderProto_FATAL_UNKNOWN

+ const RpcResponseHeaderProto_FATAL_UNSUPPORTED_SERIALIZATION

+ const RpcResponseHeaderProto_FATAL_VERSION_MISMATCH

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

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

+ func (x RpcResponseHeaderProto_RpcErrorCodeProto) Enum() *RpcResponseHeaderProto_RpcErrorCodeProto

+ func (x RpcResponseHeaderProto_RpcErrorCodeProto) String() string

+ type RpcResponseHeaderProto_RpcStatusProto int32

+ const RpcResponseHeaderProto_ERROR

+ const RpcResponseHeaderProto_FATAL

+ const RpcResponseHeaderProto_SUCCESS

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

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

+ func (x RpcResponseHeaderProto_RpcStatusProto) Enum() *RpcResponseHeaderProto_RpcStatusProto

+ func (x RpcResponseHeaderProto_RpcStatusProto) String() string

+ type RpcSaslProto struct

+ Auths []*RpcSaslProto_SaslAuth

+ State *RpcSaslProto_SaslState

+ Token []byte

+ Version *uint32

+ XXX_unrecognized []byte

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

+ func (*RpcSaslProto) ProtoMessage()

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

+ func (m *RpcSaslProto) GetState() RpcSaslProto_SaslState

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

+ func (m *RpcSaslProto) GetVersion() uint32

+ func (m *RpcSaslProto) Reset()

+ func (m *RpcSaslProto) String() string

+ type RpcSaslProto_SaslAuth struct

+ Challenge []byte

+ Mechanism *string

+ Method *string

+ Protocol *string

+ ServerId *string

+ XXX_unrecognized []byte

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

+ func (*RpcSaslProto_SaslAuth) ProtoMessage()

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

+ func (m *RpcSaslProto_SaslAuth) GetMechanism() string

+ func (m *RpcSaslProto_SaslAuth) GetMethod() string

+ func (m *RpcSaslProto_SaslAuth) GetProtocol() string

+ func (m *RpcSaslProto_SaslAuth) GetServerId() string

+ func (m *RpcSaslProto_SaslAuth) Reset()

+ func (m *RpcSaslProto_SaslAuth) String() string

+ type RpcSaslProto_SaslState int32

+ const RpcSaslProto_CHALLENGE

+ const RpcSaslProto_INITIATE

+ const RpcSaslProto_NEGOTIATE

+ const RpcSaslProto_RESPONSE

+ const RpcSaslProto_SUCCESS

+ const RpcSaslProto_WRAP

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

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

+ func (x RpcSaslProto_SaslState) Enum() *RpcSaslProto_SaslState

+ func (x RpcSaslProto_SaslState) String() string

+ type SpanReceiverListInfo struct

+ ClassName *string

+ Id *int64

+ XXX_unrecognized []byte

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

+ func (*SpanReceiverListInfo) ProtoMessage()

+ func (m *SpanReceiverListInfo) GetClassName() string

+ func (m *SpanReceiverListInfo) GetId() int64

+ func (m *SpanReceiverListInfo) Reset()

+ func (m *SpanReceiverListInfo) String() string

+ type TokenProto struct

+ Identifier []byte

+ Kind *string

+ Password []byte

+ Service *string

+ XXX_unrecognized []byte

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

+ func (*TokenProto) ProtoMessage()

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

+ func (m *TokenProto) GetKind() string

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

+ func (m *TokenProto) GetService() string

+ func (m *TokenProto) Reset()

+ func (m *TokenProto) String() string

+ type TransitionToActiveRequestProto struct

+ ReqInfo *HAStateChangeRequestInfoProto

+ XXX_unrecognized []byte

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

+ func (*TransitionToActiveRequestProto) ProtoMessage()

+ func (m *TransitionToActiveRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

+ func (m *TransitionToActiveRequestProto) Reset()

+ func (m *TransitionToActiveRequestProto) String() string

+ type TransitionToActiveResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*TransitionToActiveResponseProto) ProtoMessage()

+ func (m *TransitionToActiveResponseProto) Reset()

+ func (m *TransitionToActiveResponseProto) String() string

+ type TransitionToStandbyRequestProto struct

+ ReqInfo *HAStateChangeRequestInfoProto

+ XXX_unrecognized []byte

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

+ func (*TransitionToStandbyRequestProto) ProtoMessage()

+ func (m *TransitionToStandbyRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

+ func (m *TransitionToStandbyRequestProto) Reset()

+ func (m *TransitionToStandbyRequestProto) String() string

+ type TransitionToStandbyResponseProto struct

+ XXX_unrecognized []byte

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

+ func (*TransitionToStandbyResponseProto) ProtoMessage()

+ func (m *TransitionToStandbyResponseProto) Reset()

+ func (m *TransitionToStandbyResponseProto) String() string

+ type UserInformationProto struct

+ EffectiveUser *string

+ RealUser *string

+ XXX_unrecognized []byte

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

+ func (*UserInformationProto) ProtoMessage()

+ func (m *UserInformationProto) GetEffectiveUser() string

+ func (m *UserInformationProto) GetRealUser() string

+ func (m *UserInformationProto) Reset()

+ func (m *UserInformationProto) String() string