hadoop_common

package
v0.0.0-...-4e92e14 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2018 License: Apache-2.0 Imports: 3 Imported by: 27

Documentation

Index

Constants

View Source 
const Default_RpcRequestHeaderProto_RetryCount int32 = -1
View Source 
const Default_RpcResponseHeaderProto_RetryCount int32 = -1

Variables

View Source 
var HARequestSource_name = map[int32]string{
	0: "REQUEST_BY_USER",
	1: "REQUEST_BY_USER_FORCED",
	2: "REQUEST_BY_ZKFC",
}
View Source 
var HARequestSource_value = map[string]int32{
	"REQUEST_BY_USER":        0,
	"REQUEST_BY_USER_FORCED": 1,
	"REQUEST_BY_ZKFC":        2,
}
View Source 
var HAServiceStateProto_name = map[int32]string{
	0: "INITIALIZING",
	1: "ACTIVE",
	2: "STANDBY",
}
View Source 
var HAServiceStateProto_value = map[string]int32{
	"INITIALIZING": 0,
	"ACTIVE":       1,
	"STANDBY":      2,
}
View Source 
var RpcKindProto_name = map[int32]string{
	0: "RPC_BUILTIN",
	1: "RPC_WRITABLE",
	2: "RPC_PROTOCOL_BUFFER",
}
View Source 
var RpcKindProto_value = map[string]int32{
	"RPC_BUILTIN":         0,
	"RPC_WRITABLE":        1,
	"RPC_PROTOCOL_BUFFER": 2,
}
View Source 
var RpcRequestHeaderProto_OperationProto_name = map[int32]string{
	0: "RPC_FINAL_PACKET",
	1: "RPC_CONTINUATION_PACKET",
	2: "RPC_CLOSE_CONNECTION",
}
View Source 
var RpcRequestHeaderProto_OperationProto_value = map[string]int32{
	"RPC_FINAL_PACKET":        0,
	"RPC_CONTINUATION_PACKET": 1,
	"RPC_CLOSE_CONNECTION":    2,
}
View Source 
var RpcResponseHeaderProto_RpcErrorCodeProto_name = map[int32]string{
	1:  "ERROR_APPLICATION",
	2:  "ERROR_NO_SUCH_METHOD",
	3:  "ERROR_NO_SUCH_PROTOCOL",
	4:  "ERROR_RPC_SERVER",
	5:  "ERROR_SERIALIZING_RESPONSE",
	6:  "ERROR_RPC_VERSION_MISMATCH",
	10: "FATAL_UNKNOWN",
	11: "FATAL_UNSUPPORTED_SERIALIZATION",
	12: "FATAL_INVALID_RPC_HEADER",
	13: "FATAL_DESERIALIZING_REQUEST",
	14: "FATAL_VERSION_MISMATCH",
	15: "FATAL_UNAUTHORIZED",
}
View Source 
var RpcResponseHeaderProto_RpcErrorCodeProto_value = map[string]int32{
	"ERROR_APPLICATION":               1,
	"ERROR_NO_SUCH_METHOD":            2,
	"ERROR_NO_SUCH_PROTOCOL":          3,
	"ERROR_RPC_SERVER":                4,
	"ERROR_SERIALIZING_RESPONSE":      5,
	"ERROR_RPC_VERSION_MISMATCH":      6,
	"FATAL_UNKNOWN":                   10,
	"FATAL_UNSUPPORTED_SERIALIZATION": 11,
	"FATAL_INVALID_RPC_HEADER":        12,
	"FATAL_DESERIALIZING_REQUEST":     13,
	"FATAL_VERSION_MISMATCH":          14,
	"FATAL_UNAUTHORIZED":              15,
}
View Source 
var RpcResponseHeaderProto_RpcStatusProto_name = map[int32]string{
	0: "SUCCESS",
	1: "ERROR",
	2: "FATAL",
}
View Source 
var RpcResponseHeaderProto_RpcStatusProto_value = map[string]int32{
	"SUCCESS": 0,
	"ERROR":   1,
	"FATAL":   2,
}
View Source 
var RpcSaslProto_SaslState_name = map[int32]string{
	0: "SUCCESS",
	1: "NEGOTIATE",
	2: "INITIATE",
	3: "CHALLENGE",
	4: "RESPONSE",
	5: "WRAP",
}
View Source 
var RpcSaslProto_SaslState_value = map[string]int32{
	"SUCCESS":   0,
	"NEGOTIATE": 1,
	"INITIATE":  2,
	"CHALLENGE": 3,
	"RESPONSE":  4,
	"WRAP":      5,
}

Functions

This section is empty.

Types

type CancelDelegationTokenRequestProto 

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

func (*CancelDelegationTokenRequestProto) GetToken 

func (m *CancelDelegationTokenRequestProto) GetToken() *TokenProto

func (*CancelDelegationTokenRequestProto) ProtoMessage 

func (*CancelDelegationTokenRequestProto) ProtoMessage()

func (*CancelDelegationTokenRequestProto) Reset 

func (m *CancelDelegationTokenRequestProto) Reset()

func (*CancelDelegationTokenRequestProto) String 

func (m *CancelDelegationTokenRequestProto) String() string

type CancelDelegationTokenResponseProto 

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

func (*CancelDelegationTokenResponseProto) ProtoMessage 

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) Reset 

func (m *CancelDelegationTokenResponseProto) Reset()

func (*CancelDelegationTokenResponseProto) String 

func (m *CancelDelegationTokenResponseProto) String() string

type CedeActiveRequestProto 

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

func (*CedeActiveRequestProto) GetMillisToCede 

func (m *CedeActiveRequestProto) GetMillisToCede() uint32

func (*CedeActiveRequestProto) ProtoMessage 

func (*CedeActiveRequestProto) ProtoMessage()

func (*CedeActiveRequestProto) Reset 

func (m *CedeActiveRequestProto) Reset()

func (*CedeActiveRequestProto) String 

func (m *CedeActiveRequestProto) String() string

type CedeActiveResponseProto 

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

func (*CedeActiveResponseProto) ProtoMessage 

func (*CedeActiveResponseProto) ProtoMessage()

func (*CedeActiveResponseProto) Reset 

func (m *CedeActiveResponseProto) Reset()

func (*CedeActiveResponseProto) String 

func (m *CedeActiveResponseProto) String() string

type GetDelegationTokenRequestProto 

type GetDelegationTokenRequestProto struct {
	Renewer          *string `protobuf:"bytes,1,req,name=renewer" json:"renewer,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetDelegationTokenRequestProto) GetRenewer 

func (m *GetDelegationTokenRequestProto) GetRenewer() string

func (*GetDelegationTokenRequestProto) ProtoMessage 

func (*GetDelegationTokenRequestProto) ProtoMessage()

func (*GetDelegationTokenRequestProto) Reset 

func (m *GetDelegationTokenRequestProto) Reset()

func (*GetDelegationTokenRequestProto) String 

func (m *GetDelegationTokenRequestProto) String() string

type GetDelegationTokenResponseProto 

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

func (*GetDelegationTokenResponseProto) GetToken 

func (m *GetDelegationTokenResponseProto) GetToken() *TokenProto

func (*GetDelegationTokenResponseProto) ProtoMessage 

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) Reset 

func (m *GetDelegationTokenResponseProto) Reset()

func (*GetDelegationTokenResponseProto) String 

func (m *GetDelegationTokenResponseProto) String() string

type GetGroupsForUserRequestProto 

type GetGroupsForUserRequestProto struct {
	User             *string `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* 

Get groups for user request.

func (*GetGroupsForUserRequestProto) GetUser 

func (m *GetGroupsForUserRequestProto) GetUser() string

func (*GetGroupsForUserRequestProto) ProtoMessage 

func (*GetGroupsForUserRequestProto) ProtoMessage()

func (*GetGroupsForUserRequestProto) Reset 

func (m *GetGroupsForUserRequestProto) Reset()

func (*GetGroupsForUserRequestProto) String 

func (m *GetGroupsForUserRequestProto) String() string

type GetGroupsForUserResponseProto 

type GetGroupsForUserResponseProto struct {
	Groups           []string `protobuf:"bytes,1,rep,name=groups" json:"groups,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Response for get groups.

func (*GetGroupsForUserResponseProto) GetGroups 

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

func (*GetGroupsForUserResponseProto) ProtoMessage 

func (*GetGroupsForUserResponseProto) ProtoMessage()

func (*GetGroupsForUserResponseProto) Reset 

func (m *GetGroupsForUserResponseProto) Reset()

func (*GetGroupsForUserResponseProto) String 

func (m *GetGroupsForUserResponseProto) String() string

type GetProtocolSignatureRequestProto 

type GetProtocolSignatureRequestProto struct {
	Protocol         *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"`
	RpcKind          *string `protobuf:"bytes,2,req,name=rpcKind" json:"rpcKind,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Get protocol signature request.

func (*GetProtocolSignatureRequestProto) GetProtocol 

func (m *GetProtocolSignatureRequestProto) GetProtocol() string

func (*GetProtocolSignatureRequestProto) GetRpcKind 

func (m *GetProtocolSignatureRequestProto) GetRpcKind() string

func (*GetProtocolSignatureRequestProto) ProtoMessage 

func (*GetProtocolSignatureRequestProto) ProtoMessage()

func (*GetProtocolSignatureRequestProto) Reset 

func (m *GetProtocolSignatureRequestProto) Reset()

func (*GetProtocolSignatureRequestProto) String 

func (m *GetProtocolSignatureRequestProto) String() string

type GetProtocolSignatureResponseProto 

type GetProtocolSignatureResponseProto struct {
	ProtocolSignature []*ProtocolSignatureProto `protobuf:"bytes,1,rep,name=protocolSignature" json:"protocolSignature,omitempty"`
	XXX_unrecognized  []byte                    `json:"-"`
}

* Get protocol signature response.

func (*GetProtocolSignatureResponseProto) GetProtocolSignature 

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

func (*GetProtocolSignatureResponseProto) ProtoMessage 

func (*GetProtocolSignatureResponseProto) ProtoMessage()

func (*GetProtocolSignatureResponseProto) Reset 

func (m *GetProtocolSignatureResponseProto) Reset()

func (*GetProtocolSignatureResponseProto) String 

func (m *GetProtocolSignatureResponseProto) String() string

type GetProtocolVersionsRequestProto 

type GetProtocolVersionsRequestProto struct {
	Protocol         *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

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

func (*GetProtocolVersionsRequestProto) GetProtocol 

func (m *GetProtocolVersionsRequestProto) GetProtocol() string

func (*GetProtocolVersionsRequestProto) ProtoMessage 

func (*GetProtocolVersionsRequestProto) ProtoMessage()

func (*GetProtocolVersionsRequestProto) Reset 

func (m *GetProtocolVersionsRequestProto) Reset()

func (*GetProtocolVersionsRequestProto) String 

func (m *GetProtocolVersionsRequestProto) String() string

type GetProtocolVersionsResponseProto 

type GetProtocolVersionsResponseProto struct {
	ProtocolVersions []*ProtocolVersionProto `protobuf:"bytes,1,rep,name=protocolVersions" json:"protocolVersions,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

* Get protocol version response.

func (*GetProtocolVersionsResponseProto) GetProtocolVersions 

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

func (*GetProtocolVersionsResponseProto) ProtoMessage 

func (*GetProtocolVersionsResponseProto) ProtoMessage()

func (*GetProtocolVersionsResponseProto) Reset 

func (m *GetProtocolVersionsResponseProto) Reset()

func (*GetProtocolVersionsResponseProto) String 

func (m *GetProtocolVersionsResponseProto) String() string

type GetServiceStatusRequestProto 

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

* void request

func (*GetServiceStatusRequestProto) ProtoMessage 

func (*GetServiceStatusRequestProto) ProtoMessage()

func (*GetServiceStatusRequestProto) Reset 

func (m *GetServiceStatusRequestProto) Reset()

func (*GetServiceStatusRequestProto) String 

func (m *GetServiceStatusRequestProto) String() string

type GetServiceStatusResponseProto 

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

* Returns the state of the service

func (*GetServiceStatusResponseProto) GetNotReadyReason 

func (m *GetServiceStatusResponseProto) GetNotReadyReason() string

func (*GetServiceStatusResponseProto) GetReadyToBecomeActive 

func (m *GetServiceStatusResponseProto) GetReadyToBecomeActive() bool

func (*GetServiceStatusResponseProto) GetState 

func (m *GetServiceStatusResponseProto) GetState() HAServiceStateProto

func (*GetServiceStatusResponseProto) ProtoMessage 

func (*GetServiceStatusResponseProto) ProtoMessage()

func (*GetServiceStatusResponseProto) Reset 

func (m *GetServiceStatusResponseProto) Reset()

func (*GetServiceStatusResponseProto) String 

func (m *GetServiceStatusResponseProto) String() string

type GracefulFailoverRequestProto 

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

func (*GracefulFailoverRequestProto) ProtoMessage 

func (*GracefulFailoverRequestProto) ProtoMessage()

func (*GracefulFailoverRequestProto) Reset 

func (m *GracefulFailoverRequestProto) Reset()

func (*GracefulFailoverRequestProto) String 

func (m *GracefulFailoverRequestProto) String() string

type GracefulFailoverResponseProto 

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

func (*GracefulFailoverResponseProto) ProtoMessage 

func (*GracefulFailoverResponseProto) ProtoMessage()

func (*GracefulFailoverResponseProto) Reset 

func (m *GracefulFailoverResponseProto) Reset()

func (*GracefulFailoverResponseProto) String 

func (m *GracefulFailoverResponseProto) String() string

type HARequestSource 

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

func (HARequestSource) Enum 

func (x HARequestSource) Enum() *HARequestSource

func (HARequestSource) MarshalJSON 

func (x HARequestSource) MarshalJSON() ([]byte, error)

func (HARequestSource) String 

func (x HARequestSource) String() string

func (*HARequestSource) UnmarshalJSON 

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

type HAServiceStateProto 

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

func (HAServiceStateProto) Enum 

func (x HAServiceStateProto) Enum() *HAServiceStateProto

func (HAServiceStateProto) MarshalJSON 

func (x HAServiceStateProto) MarshalJSON() ([]byte, error)

func (HAServiceStateProto) String 

func (x HAServiceStateProto) String() string

func (*HAServiceStateProto) UnmarshalJSON 

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

type HAStateChangeRequestInfoProto 

type HAStateChangeRequestInfoProto struct {
	ReqSource        *HARequestSource `protobuf:"varint,1,req,name=reqSource,enum=hadoop.common.HARequestSource" json:"reqSource,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*HAStateChangeRequestInfoProto) GetReqSource 

func (m *HAStateChangeRequestInfoProto) GetReqSource() HARequestSource

func (*HAStateChangeRequestInfoProto) ProtoMessage 

func (*HAStateChangeRequestInfoProto) ProtoMessage()

func (*HAStateChangeRequestInfoProto) Reset 

func (m *HAStateChangeRequestInfoProto) Reset()

func (*HAStateChangeRequestInfoProto) String 

func (m *HAStateChangeRequestInfoProto) String() string

type IpcConnectionContextProto 

type IpcConnectionContextProto struct {
	// UserInfo beyond what is determined as part of security handshake
	// at connection time (kerberos, tokens etc).
	UserInfo *UserInformationProto `protobuf:"bytes,2,opt,name=userInfo" json:"userInfo,omitempty"`
	// Protocol name for next rpc layer.
	// The client created a proxy with this protocol name
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* The connection context is sent as part of the connection establishment. It establishes the context for ALL Rpc calls within the connection.

func (*IpcConnectionContextProto) GetProtocol 

func (m *IpcConnectionContextProto) GetProtocol() string

func (*IpcConnectionContextProto) GetUserInfo 

func (m *IpcConnectionContextProto) GetUserInfo() *UserInformationProto

func (*IpcConnectionContextProto) ProtoMessage 

func (*IpcConnectionContextProto) ProtoMessage()

func (*IpcConnectionContextProto) Reset 

func (m *IpcConnectionContextProto) Reset()

func (*IpcConnectionContextProto) String 

func (m *IpcConnectionContextProto) String() string

type MonitorHealthRequestProto 

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

* void request

func (*MonitorHealthRequestProto) ProtoMessage 

func (*MonitorHealthRequestProto) ProtoMessage()

func (*MonitorHealthRequestProto) Reset 

func (m *MonitorHealthRequestProto) Reset()

func (*MonitorHealthRequestProto) String 

func (m *MonitorHealthRequestProto) String() string

type MonitorHealthResponseProto 

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

* void response

func (*MonitorHealthResponseProto) ProtoMessage 

func (*MonitorHealthResponseProto) ProtoMessage()

func (*MonitorHealthResponseProto) Reset 

func (m *MonitorHealthResponseProto) Reset()

func (*MonitorHealthResponseProto) String 

func (m *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"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ProtocolSignatureProto) GetMethods 

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

func (*ProtocolSignatureProto) GetVersion 

func (m *ProtocolSignatureProto) GetVersion() uint64

func (*ProtocolSignatureProto) ProtoMessage 

func (*ProtocolSignatureProto) ProtoMessage()

func (*ProtocolSignatureProto) Reset 

func (m *ProtocolSignatureProto) Reset()

func (*ProtocolSignatureProto) String 

func (m *ProtocolSignatureProto) String() string

type ProtocolVersionProto 

type ProtocolVersionProto struct {
	RpcKind          *string  `protobuf:"bytes,1,req,name=rpcKind" json:"rpcKind,omitempty"`
	Versions         []uint64 `protobuf:"varint,2,rep,name=versions" json:"versions,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Protocol version with corresponding rpc kind.

func (*ProtocolVersionProto) GetRpcKind 

func (m *ProtocolVersionProto) GetRpcKind() string

func (*ProtocolVersionProto) GetVersions 

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

func (*ProtocolVersionProto) ProtoMessage 

func (*ProtocolVersionProto) ProtoMessage()

func (*ProtocolVersionProto) Reset 

func (m *ProtocolVersionProto) Reset()

func (*ProtocolVersionProto) String 

func (m *ProtocolVersionProto) String() string

type RefreshServiceAclRequestProto 

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

* 

Refresh service acl request.

func (*RefreshServiceAclRequestProto) ProtoMessage 

func (*RefreshServiceAclRequestProto) ProtoMessage()

func (*RefreshServiceAclRequestProto) Reset 

func (m *RefreshServiceAclRequestProto) Reset()

func (*RefreshServiceAclRequestProto) String 

func (m *RefreshServiceAclRequestProto) String() string

type RefreshServiceAclResponseProto 

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

* void response

func (*RefreshServiceAclResponseProto) ProtoMessage 

func (*RefreshServiceAclResponseProto) ProtoMessage()

func (*RefreshServiceAclResponseProto) Reset 

func (m *RefreshServiceAclResponseProto) Reset()

func (*RefreshServiceAclResponseProto) String 

func (m *RefreshServiceAclResponseProto) String() string

type RefreshSuperUserGroupsConfigurationRequestProto 

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

* Refresh superuser configuration request.

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage 

func (*RefreshSuperUserGroupsConfigurationRequestProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationRequestProto) Reset 

func (m *RefreshSuperUserGroupsConfigurationRequestProto) Reset()

func (*RefreshSuperUserGroupsConfigurationRequestProto) String 

func (m *RefreshSuperUserGroupsConfigurationRequestProto) String() string

type RefreshSuperUserGroupsConfigurationResponseProto 

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

* void response

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage 

func (*RefreshSuperUserGroupsConfigurationResponseProto) ProtoMessage()

func (*RefreshSuperUserGroupsConfigurationResponseProto) Reset 

func (m *RefreshSuperUserGroupsConfigurationResponseProto) Reset()

func (*RefreshSuperUserGroupsConfigurationResponseProto) String 

func (m *RefreshSuperUserGroupsConfigurationResponseProto) String() string

type RefreshUserToGroupsMappingsRequestProto 

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

* 

Refresh user to group mappings request.

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage 

func (*RefreshUserToGroupsMappingsRequestProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsRequestProto) Reset 

func (m *RefreshUserToGroupsMappingsRequestProto) Reset()

func (*RefreshUserToGroupsMappingsRequestProto) String 

func (m *RefreshUserToGroupsMappingsRequestProto) String() string

type RefreshUserToGroupsMappingsResponseProto 

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

* void response

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage 

func (*RefreshUserToGroupsMappingsResponseProto) ProtoMessage()

func (*RefreshUserToGroupsMappingsResponseProto) Reset 

func (m *RefreshUserToGroupsMappingsResponseProto) Reset()

func (*RefreshUserToGroupsMappingsResponseProto) String 

func (m *RefreshUserToGroupsMappingsResponseProto) String() string

type RenewDelegationTokenRequestProto 

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

func (*RenewDelegationTokenRequestProto) GetToken 

func (m *RenewDelegationTokenRequestProto) GetToken() *TokenProto

func (*RenewDelegationTokenRequestProto) ProtoMessage 

func (*RenewDelegationTokenRequestProto) ProtoMessage()

func (*RenewDelegationTokenRequestProto) Reset 

func (m *RenewDelegationTokenRequestProto) Reset()

func (*RenewDelegationTokenRequestProto) String 

func (m *RenewDelegationTokenRequestProto) String() string

type RenewDelegationTokenResponseProto 

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

func (*RenewDelegationTokenResponseProto) GetNewExpiryTime 

func (m *RenewDelegationTokenResponseProto) GetNewExpiryTime() uint64

func (*RenewDelegationTokenResponseProto) ProtoMessage 

func (*RenewDelegationTokenResponseProto) ProtoMessage()

func (*RenewDelegationTokenResponseProto) Reset 

func (m *RenewDelegationTokenResponseProto) Reset()

func (*RenewDelegationTokenResponseProto) String 

func (m *RenewDelegationTokenResponseProto) String() string

type RequestHeaderProto 

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

* This message is the header for the Protobuf Rpc Engine when sending a RPC request from RPC client to the RPC server. The actual request (serialized as protobuf) follows this request.

No special header is needed for the Rpc Response for Protobuf Rpc Engine. The normal RPC response header (see RpcHeader.proto) are sufficient.

func (*RequestHeaderProto) GetClientProtocolVersion 

func (m *RequestHeaderProto) GetClientProtocolVersion() uint64

func (*RequestHeaderProto) GetDeclaringClassProtocolName 

func (m *RequestHeaderProto) GetDeclaringClassProtocolName() string

func (*RequestHeaderProto) GetMethodName 

func (m *RequestHeaderProto) GetMethodName() string

func (*RequestHeaderProto) ProtoMessage 

func (*RequestHeaderProto) ProtoMessage()

func (*RequestHeaderProto) Reset 

func (m *RequestHeaderProto) Reset()

func (*RequestHeaderProto) String 

func (m *RequestHeaderProto) String() string

type RpcKindProto 

type RpcKindProto int32

* RpcKind determine the rpcEngine and the serialization of the rpc request 

const (
	RpcKindProto_RPC_BUILTIN         RpcKindProto = 0
	RpcKindProto_RPC_WRITABLE        RpcKindProto = 1
	RpcKindProto_RPC_PROTOCOL_BUFFER RpcKindProto = 2
)

func (RpcKindProto) Enum 

func (x RpcKindProto) Enum() *RpcKindProto

func (RpcKindProto) MarshalJSON 

func (x RpcKindProto) MarshalJSON() ([]byte, error)

func (RpcKindProto) String 

func (x RpcKindProto) String() string

func (*RpcKindProto) UnmarshalJSON 

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

type RpcRequestHeaderProto 

type RpcRequestHeaderProto struct {
	RpcKind  *RpcKindProto                         `protobuf:"varint,1,opt,name=rpcKind,enum=hadoop.common.RpcKindProto" json:"rpcKind,omitempty"`
	RpcOp    *RpcRequestHeaderProto_OperationProto `protobuf:"varint,2,opt,name=rpcOp,enum=hadoop.common.RpcRequestHeaderProto_OperationProto" json:"rpcOp,omitempty"`
	CallId   *int32                                `protobuf:"zigzag32,3,req,name=callId" json:"callId,omitempty"`
	ClientId []byte                                `protobuf:"bytes,4,req,name=clientId" json:"clientId,omitempty"`
	// clientId + callId uniquely identifies a request
	// retry count, 1 means this is the first retry
	RetryCount       *int32 `protobuf:"zigzag32,5,opt,name=retryCount,def=-1" json:"retryCount,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RpcRequestHeaderProto) GetCallId 

func (m *RpcRequestHeaderProto) GetCallId() int32

func (*RpcRequestHeaderProto) GetClientId 

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

func (*RpcRequestHeaderProto) GetRetryCount 

func (m *RpcRequestHeaderProto) GetRetryCount() int32

func (*RpcRequestHeaderProto) GetRpcKind 

func (m *RpcRequestHeaderProto) GetRpcKind() RpcKindProto

func (*RpcRequestHeaderProto) GetRpcOp 

func (m *RpcRequestHeaderProto) GetRpcOp() RpcRequestHeaderProto_OperationProto

func (*RpcRequestHeaderProto) ProtoMessage 

func (*RpcRequestHeaderProto) ProtoMessage()

func (*RpcRequestHeaderProto) Reset 

func (m *RpcRequestHeaderProto) Reset()

func (*RpcRequestHeaderProto) String 

func (m *RpcRequestHeaderProto) String() string

type RpcRequestHeaderProto_OperationProto 

type RpcRequestHeaderProto_OperationProto int32
const (
	RpcRequestHeaderProto_RPC_FINAL_PACKET        RpcRequestHeaderProto_OperationProto = 0
	RpcRequestHeaderProto_RPC_CONTINUATION_PACKET RpcRequestHeaderProto_OperationProto = 1
	RpcRequestHeaderProto_RPC_CLOSE_CONNECTION    RpcRequestHeaderProto_OperationProto = 2
)

func (RpcRequestHeaderProto_OperationProto) Enum 

func (x RpcRequestHeaderProto_OperationProto) Enum() *RpcRequestHeaderProto_OperationProto

func (RpcRequestHeaderProto_OperationProto) MarshalJSON 

func (x RpcRequestHeaderProto_OperationProto) MarshalJSON() ([]byte, error)

func (RpcRequestHeaderProto_OperationProto) String 

func (x RpcRequestHeaderProto_OperationProto) String() string

func (*RpcRequestHeaderProto_OperationProto) UnmarshalJSON 

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

type RpcResponseHeaderProto 

type RpcResponseHeaderProto struct {
	CallId              *uint32                                   `protobuf:"varint,1,req,name=callId" json:"callId,omitempty"`
	Status              *RpcResponseHeaderProto_RpcStatusProto    `protobuf:"varint,2,req,name=status,enum=hadoop.common.RpcResponseHeaderProto_RpcStatusProto" json:"status,omitempty"`
	ServerIpcVersionNum *uint32                                   `protobuf:"varint,3,opt,name=serverIpcVersionNum" json:"serverIpcVersionNum,omitempty"`
	ExceptionClassName  *string                                   `protobuf:"bytes,4,opt,name=exceptionClassName" json:"exceptionClassName,omitempty"`
	ErrorMsg            *string                                   `protobuf:"bytes,5,opt,name=errorMsg" json:"errorMsg,omitempty"`
	ErrorDetail         *RpcResponseHeaderProto_RpcErrorCodeProto `` /* 129-byte string literal not displayed */
	ClientId            []byte                                    `protobuf:"bytes,7,opt,name=clientId" json:"clientId,omitempty"`
	RetryCount          *int32                                    `protobuf:"zigzag32,8,opt,name=retryCount,def=-1" json:"retryCount,omitempty"`
	XXX_unrecognized    []byte                                    `json:"-"`
}

* Rpc Response Header +------------------------------------------------------------------+ | Rpc total response length in bytes (4 bytes int) | | (sum of next two parts) | +------------------------------------------------------------------+ | RpcResponseHeaderProto - serialized delimited ie has len | +------------------------------------------------------------------+ | if request is successful: | | - RpcResponse - The actual rpc response bytes follow | | the response header | | This response is serialized based on RpcKindProto | | if request fails : | | The rpc response header contains the necessary info | +------------------------------------------------------------------+

Note that rpc response header is also used when connection setup fails. Ie the response looks like a rpc response with a fake callId.

func (*RpcResponseHeaderProto) GetCallId 

func (m *RpcResponseHeaderProto) GetCallId() uint32

func (*RpcResponseHeaderProto) GetClientId 

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

func (*RpcResponseHeaderProto) GetErrorDetail 

func (m *RpcResponseHeaderProto) GetErrorDetail() RpcResponseHeaderProto_RpcErrorCodeProto

func (*RpcResponseHeaderProto) GetErrorMsg 

func (m *RpcResponseHeaderProto) GetErrorMsg() string

func (*RpcResponseHeaderProto) GetExceptionClassName 

func (m *RpcResponseHeaderProto) GetExceptionClassName() string

func (*RpcResponseHeaderProto) GetRetryCount 

func (m *RpcResponseHeaderProto) GetRetryCount() int32

func (*RpcResponseHeaderProto) GetServerIpcVersionNum 

func (m *RpcResponseHeaderProto) GetServerIpcVersionNum() uint32

func (*RpcResponseHeaderProto) GetStatus 

func (m *RpcResponseHeaderProto) GetStatus() RpcResponseHeaderProto_RpcStatusProto

func (*RpcResponseHeaderProto) ProtoMessage 

func (*RpcResponseHeaderProto) ProtoMessage()

func (*RpcResponseHeaderProto) Reset 

func (m *RpcResponseHeaderProto) Reset()

func (*RpcResponseHeaderProto) String 

func (m *RpcResponseHeaderProto) String() string

type RpcResponseHeaderProto_RpcErrorCodeProto 

type RpcResponseHeaderProto_RpcErrorCodeProto int32
const (
	// Non-fatal Rpc error - connection left open for future rpc calls
	RpcResponseHeaderProto_ERROR_APPLICATION          RpcResponseHeaderProto_RpcErrorCodeProto = 1
	RpcResponseHeaderProto_ERROR_NO_SUCH_METHOD       RpcResponseHeaderProto_RpcErrorCodeProto = 2
	RpcResponseHeaderProto_ERROR_NO_SUCH_PROTOCOL     RpcResponseHeaderProto_RpcErrorCodeProto = 3
	RpcResponseHeaderProto_ERROR_RPC_SERVER           RpcResponseHeaderProto_RpcErrorCodeProto = 4
	RpcResponseHeaderProto_ERROR_SERIALIZING_RESPONSE RpcResponseHeaderProto_RpcErrorCodeProto = 5
	RpcResponseHeaderProto_ERROR_RPC_VERSION_MISMATCH RpcResponseHeaderProto_RpcErrorCodeProto = 6
	// Fatal Server side Rpc error - connection closed
	RpcResponseHeaderProto_FATAL_UNKNOWN                   RpcResponseHeaderProto_RpcErrorCodeProto = 10
	RpcResponseHeaderProto_FATAL_UNSUPPORTED_SERIALIZATION RpcResponseHeaderProto_RpcErrorCodeProto = 11
	RpcResponseHeaderProto_FATAL_INVALID_RPC_HEADER        RpcResponseHeaderProto_RpcErrorCodeProto = 12
	RpcResponseHeaderProto_FATAL_DESERIALIZING_REQUEST     RpcResponseHeaderProto_RpcErrorCodeProto = 13
	RpcResponseHeaderProto_FATAL_VERSION_MISMATCH          RpcResponseHeaderProto_RpcErrorCodeProto = 14
	RpcResponseHeaderProto_FATAL_UNAUTHORIZED              RpcResponseHeaderProto_RpcErrorCodeProto = 15
)

func (RpcResponseHeaderProto_RpcErrorCodeProto) Enum 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) Enum() *RpcResponseHeaderProto_RpcErrorCodeProto

func (RpcResponseHeaderProto_RpcErrorCodeProto) MarshalJSON 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) MarshalJSON() ([]byte, error)

func (RpcResponseHeaderProto_RpcErrorCodeProto) String 

func (x RpcResponseHeaderProto_RpcErrorCodeProto) String() string

func (*RpcResponseHeaderProto_RpcErrorCodeProto) UnmarshalJSON 

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

type RpcResponseHeaderProto_RpcStatusProto 

type RpcResponseHeaderProto_RpcStatusProto int32
const (
	RpcResponseHeaderProto_SUCCESS RpcResponseHeaderProto_RpcStatusProto = 0
	RpcResponseHeaderProto_ERROR   RpcResponseHeaderProto_RpcStatusProto = 1
	RpcResponseHeaderProto_FATAL   RpcResponseHeaderProto_RpcStatusProto = 2
)

func (RpcResponseHeaderProto_RpcStatusProto) Enum 

func (x RpcResponseHeaderProto_RpcStatusProto) Enum() *RpcResponseHeaderProto_RpcStatusProto

func (RpcResponseHeaderProto_RpcStatusProto) MarshalJSON 

func (x RpcResponseHeaderProto_RpcStatusProto) MarshalJSON() ([]byte, error)

func (RpcResponseHeaderProto_RpcStatusProto) String 

func (x RpcResponseHeaderProto_RpcStatusProto) String() string

func (*RpcResponseHeaderProto_RpcStatusProto) UnmarshalJSON 

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

type RpcSaslProto 

type RpcSaslProto struct {
	Version          *uint32                  `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	State            *RpcSaslProto_SaslState  `protobuf:"varint,2,req,name=state,enum=hadoop.common.RpcSaslProto_SaslState" json:"state,omitempty"`
	Token            []byte                   `protobuf:"bytes,3,opt,name=token" json:"token,omitempty"`
	Auths            []*RpcSaslProto_SaslAuth `protobuf:"bytes,4,rep,name=auths" json:"auths,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*RpcSaslProto) GetAuths 

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

func (*RpcSaslProto) GetState 

func (m *RpcSaslProto) GetState() RpcSaslProto_SaslState

func (*RpcSaslProto) GetToken 

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

func (*RpcSaslProto) GetVersion 

func (m *RpcSaslProto) GetVersion() uint32

func (*RpcSaslProto) ProtoMessage 

func (*RpcSaslProto) ProtoMessage()

func (*RpcSaslProto) Reset 

func (m *RpcSaslProto) Reset()

func (*RpcSaslProto) String 

func (m *RpcSaslProto) String() string

type RpcSaslProto_SaslAuth 

type RpcSaslProto_SaslAuth struct {
	Method           *string `protobuf:"bytes,1,req,name=method" json:"method,omitempty"`
	Mechanism        *string `protobuf:"bytes,2,req,name=mechanism" json:"mechanism,omitempty"`
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	ServerId         *string `protobuf:"bytes,4,opt,name=serverId" json:"serverId,omitempty"`
	Challenge        []byte  `protobuf:"bytes,5,opt,name=challenge" json:"challenge,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RpcSaslProto_SaslAuth) GetChallenge 

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

func (*RpcSaslProto_SaslAuth) GetMechanism 

func (m *RpcSaslProto_SaslAuth) GetMechanism() string

func (*RpcSaslProto_SaslAuth) GetMethod 

func (m *RpcSaslProto_SaslAuth) GetMethod() string

func (*RpcSaslProto_SaslAuth) GetProtocol 

func (m *RpcSaslProto_SaslAuth) GetProtocol() string

func (*RpcSaslProto_SaslAuth) GetServerId 

func (m *RpcSaslProto_SaslAuth) GetServerId() string

func (*RpcSaslProto_SaslAuth) ProtoMessage 

func (*RpcSaslProto_SaslAuth) ProtoMessage()

func (*RpcSaslProto_SaslAuth) Reset 

func (m *RpcSaslProto_SaslAuth) Reset()

func (*RpcSaslProto_SaslAuth) String 

func (m *RpcSaslProto_SaslAuth) String() string

type RpcSaslProto_SaslState 

type RpcSaslProto_SaslState int32
const (
	RpcSaslProto_SUCCESS   RpcSaslProto_SaslState = 0
	RpcSaslProto_NEGOTIATE RpcSaslProto_SaslState = 1
	RpcSaslProto_INITIATE  RpcSaslProto_SaslState = 2
	RpcSaslProto_CHALLENGE RpcSaslProto_SaslState = 3
	RpcSaslProto_RESPONSE  RpcSaslProto_SaslState = 4
	RpcSaslProto_WRAP      RpcSaslProto_SaslState = 5
)

func (RpcSaslProto_SaslState) Enum 

func (x RpcSaslProto_SaslState) Enum() *RpcSaslProto_SaslState

func (RpcSaslProto_SaslState) MarshalJSON 

func (x RpcSaslProto_SaslState) MarshalJSON() ([]byte, error)

func (RpcSaslProto_SaslState) String 

func (x RpcSaslProto_SaslState) String() string

func (*RpcSaslProto_SaslState) UnmarshalJSON 

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

type TokenProto 

type TokenProto struct {
	Identifier       []byte  `protobuf:"bytes,1,req,name=identifier" json:"identifier,omitempty"`
	Password         []byte  `protobuf:"bytes,2,req,name=password" json:"password,omitempty"`
	Kind             *string `protobuf:"bytes,3,req,name=kind" json:"kind,omitempty"`
	Service          *string `protobuf:"bytes,4,req,name=service" json:"service,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Security token identifier

func (*TokenProto) GetIdentifier 

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

func (*TokenProto) GetKind 

func (m *TokenProto) GetKind() string

func (*TokenProto) GetPassword 

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

func (*TokenProto) GetService 

func (m *TokenProto) GetService() string

func (*TokenProto) ProtoMessage 

func (*TokenProto) ProtoMessage()

func (*TokenProto) Reset 

func (m *TokenProto) Reset()

func (*TokenProto) String 

func (m *TokenProto) String() string

type TransitionToActiveRequestProto 

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

* void request

func (*TransitionToActiveRequestProto) GetReqInfo 

func (m *TransitionToActiveRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToActiveRequestProto) ProtoMessage 

func (*TransitionToActiveRequestProto) ProtoMessage()

func (*TransitionToActiveRequestProto) Reset 

func (m *TransitionToActiveRequestProto) Reset()

func (*TransitionToActiveRequestProto) String 

func (m *TransitionToActiveRequestProto) String() string

type TransitionToActiveResponseProto 

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

* void response

func (*TransitionToActiveResponseProto) ProtoMessage 

func (*TransitionToActiveResponseProto) ProtoMessage()

func (*TransitionToActiveResponseProto) Reset 

func (m *TransitionToActiveResponseProto) Reset()

func (*TransitionToActiveResponseProto) String 

func (m *TransitionToActiveResponseProto) String() string

type TransitionToStandbyRequestProto 

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

* void request

func (*TransitionToStandbyRequestProto) GetReqInfo 

func (m *TransitionToStandbyRequestProto) GetReqInfo() *HAStateChangeRequestInfoProto

func (*TransitionToStandbyRequestProto) ProtoMessage 

func (*TransitionToStandbyRequestProto) ProtoMessage()

func (*TransitionToStandbyRequestProto) Reset 

func (m *TransitionToStandbyRequestProto) Reset()

func (*TransitionToStandbyRequestProto) String 

func (m *TransitionToStandbyRequestProto) String() string

type TransitionToStandbyResponseProto 

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

* void response

func (*TransitionToStandbyResponseProto) ProtoMessage 

func (*TransitionToStandbyResponseProto) ProtoMessage()

func (*TransitionToStandbyResponseProto) Reset 

func (m *TransitionToStandbyResponseProto) Reset()

func (*TransitionToStandbyResponseProto) String 

func (m *TransitionToStandbyResponseProto) String() string

type UserInformationProto 

type UserInformationProto struct {
	EffectiveUser    *string `protobuf:"bytes,1,opt,name=effectiveUser" json:"effectiveUser,omitempty"`
	RealUser         *string `protobuf:"bytes,2,opt,name=realUser" json:"realUser,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Spec for UserInformationProto is specified in ProtoUtil#makeIpcConnectionContext

func (*UserInformationProto) GetEffectiveUser 

func (m *UserInformationProto) GetEffectiveUser() string

func (*UserInformationProto) GetRealUser 

func (m *UserInformationProto) GetRealUser() string

func (*UserInformationProto) ProtoMessage 

func (*UserInformationProto) ProtoMessage()

func (*UserInformationProto) Reset 

func (m *UserInformationProto) Reset()

func (*UserInformationProto) String 

func (m *UserInformationProto) String() string

Source Files

View all Source files

Directories

Path Synopsis
ipc
client

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.