hadoop_common

package
v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2015 License: MIT Imports: 2 Imported by: 0

Documentation

Overview

Package hadoop_common is a generated protocol buffer package.

It is generated from these files:

IpcConnectionContext.proto
ProtobufRpcEngine.proto
RpcHeader.proto
Security.proto

It has these top-level messages:

UserInformationProto
IpcConnectionContextProto

Index

Constants

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

Variables

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

func (*CancelDelegationTokenRequestProto) ProtoMessage()

func (*CancelDelegationTokenRequestProto) Reset

func (*CancelDelegationTokenRequestProto) String

type CancelDelegationTokenResponseProto

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

func (*CancelDelegationTokenResponseProto) ProtoMessage

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) Reset

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

type GetDelegationTokenResponseProto

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

func (*GetDelegationTokenResponseProto) GetToken

func (*GetDelegationTokenResponseProto) ProtoMessage

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) Reset

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

func (*IpcConnectionContextProto) ProtoMessage()

func (*IpcConnectionContextProto) Reset

func (m *IpcConnectionContextProto) Reset()

func (*IpcConnectionContextProto) String

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

func (*RenewDelegationTokenRequestProto) ProtoMessage()

func (*RenewDelegationTokenRequestProto) Reset

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

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

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

func (*RequestHeaderProto) GetClientProtocolVersion

func (m *RequestHeaderProto) GetClientProtocolVersion() uint64

func (*RequestHeaderProto) GetDeclaringClassProtocolName

func (m *RequestHeaderProto) GetDeclaringClassProtocolName() string

func (*RequestHeaderProto) GetMethodName

func (m *RequestHeaderProto) GetMethodName() string

func (*RequestHeaderProto) ProtoMessage

func (*RequestHeaderProto) ProtoMessage()

func (*RequestHeaderProto) Reset

func (m *RequestHeaderProto) Reset()

func (*RequestHeaderProto) String

func (m *RequestHeaderProto) String() string

type RpcKindProto

type RpcKindProto int32

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

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

func (RpcKindProto) Enum

func (x RpcKindProto) Enum() *RpcKindProto

func (RpcKindProto) String

func (x RpcKindProto) String() string

func (*RpcKindProto) UnmarshalJSON

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

type RpcRequestHeaderProto

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

Jump to

Keyboard shortcuts

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