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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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