kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-04 17:35:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

address feedback review

Browse Source 
apply `s/requestAuthToken/requestACLToken/g`
This commit is contained in:
Mahmood Ali
2019-11-26 08:39:04 -05:00
parent 538695d1c1
commit e03ea9bd2b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
nomad/acl_endpoint.go
View File

@@ -137,7 +137,7 @@ func (a *ACL) ListPolicies(args *structs.ACLPolicyListRequest, reply *structs.AC
mgt := acl.IsManagement()
var policies map[string]struct{}
if !mgt {
token, err := a.requestAuthToken(args.AuthToken)
token, err := a.requestACLToken(args.AuthToken)
if err != nil {
return err
}
@@ -221,7 +221,7 @@ func (a *ACL) GetPolicy(args *structs.ACLPolicySpecificRequest, reply *structs.S
// If it is not a management token determine if it can get this policy
mgt := acl.IsManagement()
if !mgt && args.Name != "anonymous" {
token, err := a.requestAuthToken(args.AuthToken)
token, err := a.requestACLToken(args.AuthToken)
if err != nil {
return err
}
@@ -276,7 +276,7 @@ func (a *ACL) GetPolicy(args *structs.ACLPolicySpecificRequest, reply *structs.S
return a.srv.blockingRPC(&opts)
}
func (a *ACL) requestAuthToken(secretID string) (*structs.ACLToken, error) {
func (a *ACL) requestACLToken(secretID string) (*structs.ACLToken, error) {
if secretID == "" {
return structs.AnonymousACLToken, nil
}
@@ -302,7 +302,7 @@ func (a *ACL) GetPolicies(args *structs.ACLPolicySetRequest, reply *structs.ACLP
// For client typed tokens, allow them to query any policies associated with that token.
// This is used by clients which are resolving the policies to enforce. Any associated
// policies need to be fetched so that the client can determine what to allow.
token, err := a.requestAuthToken(args.AuthToken)
token, err := a.requestACLToken(args.AuthToken)
if err != nil {
return err
}