security

Documentation

Index

• func CreateCurrentUserInfoProto() (*hadoop_common.UserInformationProto, error)
• func GetDigestMD5ChallengeResponse(protocol string, serverId string, challenge []byte, ...) (string, error)
• type UserGroupInformation
  • func Allocate(userInfo *hadoop_common.UserInformationProto, ...) *UserGroupInformation
  • func GetCurrentUser() *UserGroupInformation
  • func (ugi *UserGroupInformation) AddUserToken(token *hadoop_common.TokenProto)
  • func (ugi *UserGroupInformation) AddUserTokenWithAlias(alias string, token *hadoop_common.TokenProto)
  • func (ugi *UserGroupInformation) GetUserInformation() *hadoop_common.UserInformationProto
  • func (ugi *UserGroupInformation) GetUserTokens() map[string]*hadoop_common.TokenProto

Functions

func CreateCurrentUserInfoProto

func CreateCurrentUserInfoProto() (*hadoop_common.UserInformationProto, error)

func GetDigestMD5ChallengeResponse

func GetDigestMD5ChallengeResponse(protocol string, serverId string, challenge []byte, userToken *hadoop_common.TokenProto) (string, error)

Types

type UserGroupInformation

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

func Allocate

func Allocate(userInfo *hadoop_common.UserInformationProto, userTokens map[string]*hadoop_common.TokenProto) *UserGroupInformation

func GetCurrentUser

func GetCurrentUser() *UserGroupInformation

func (*UserGroupInformation) AddUserToken

func (ugi *UserGroupInformation) AddUserToken(token *hadoop_common.TokenProto)

func (*UserGroupInformation) AddUserTokenWithAlias

func (ugi *UserGroupInformation) AddUserTokenWithAlias(alias string, token *hadoop_common.TokenProto)

func (*UserGroupInformation) GetUserInformation

func (ugi *UserGroupInformation) GetUserInformation() *hadoop_common.UserInformationProto

func (*UserGroupInformation) GetUserTokens

func (ugi *UserGroupInformation) GetUserTokens() map[string]*hadoop_common.TokenProto