kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add docstrings for cloud.go

This commit is contained in:
andrewsykim 2017-07-12 20:38:01 -04:00
parent a866f70e1e
commit f396799bc9
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/resources/digitalocean/cloud.go
View File

@ -26,10 +26,12 @@ import (
"k8s.io/kubernetes/federation/pkg/dnsprovider" "k8s.io/kubernetes/federation/pkg/dnsprovider"
) )
// TokenSource implements oauth2.TokenSource
type TokenSource struct { type TokenSource struct {
AccessToken string AccessToken string
} }
// Token() returns oauth2.Token
func (t *TokenSource) Token() (*oauth2.Token, error) { func (t *TokenSource) Token() (*oauth2.Token, error) {
token := &oauth2.Token{ token := &oauth2.Token{
AccessToken: t.AccessToken, AccessToken: t.AccessToken,
@ -37,6 +39,7 @@ func (t *TokenSource) Token() (*oauth2.Token, error) {
return token, nil return token, nil
} }
// Cloud exposes all the interfaces required to operate on DigitalOcean resources
type Cloud struct { type Cloud struct {
client *godo.Client client *godo.Client
@ -44,6 +47,8 @@ type Cloud struct {
tags map[string]string tags map[string]string
} }
// NewCloud returns a Cloud, expecting the env var DO_ACCESS_TOKEN
// NewCloud will return an err if DO_ACCESS_TOKEN is not defined
func NewCloud() (*Cloud, error) { func NewCloud() (*Cloud, error) {
accessToken := os.Getenv("DO_ACCESS_TOKEN") accessToken := os.Getenv("DO_ACCESS_TOKEN")
if accessToken == "" { if accessToken == "" {
@ -62,6 +67,7 @@ func NewCloud() (*Cloud, error) {
}, nil }, nil
} }
// DNS returns a DO implementation for dnsprovider.Interface
func (c *Cloud) DNS() (dnsprovider.Interface, error) { func (c *Cloud) DNS() (dnsprovider.Interface, error) {
provider := dns.NewProvider(c.client) provider := dns.NewProvider(c.client)
return provider, nil return provider, nil