Add oauth2 to the provider (apache#338)

--- *Motivation* Add oauth2 authentication can be constructed by name.
hrsakai · Jul 31, 2020 · 27a9c06 · 27a9c06
1 parent c0cba32
commit 27a9c06
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar/internal/auth/provider.go b/pulsar/internal/auth/provider.go
@@ -63,6 +63,9 @@ func NewProvider(name string, params string) (Provider, error) {
 	case "athenz", "org.apache.pulsar.client.impl.auth.AuthenticationAthenz":
 		return NewAuthenticationAthenzWithParams(m)
 
+	case "oauth2", "org.apache.pulsar.client.impl.auth.oauth2.AuthenticationOAuth2":
+		return NewAuthenticationOAuth2WithParams(m)
+
 	default:
 		return nil, errors.New(fmt.Sprintf("invalid auth provider '%s'", name))
 	}