diff options
author | 2019-10-02 23:18:36 +0100 | |
---|---|---|
committer | 2019-10-02 15:18:36 -0700 | |
commit | 8fde7407d94feec02027de69d1ffa278ae0221ad (patch) | |
tree | ccaf4261e34bbf4d675ad6037e6b371207d04892 /plugin/clouddns/setup.go | |
parent | 0da2c0c366a583b192004052bd9484712b07a636 (diff) | |
download | coredns-8fde7407d94feec02027de69d1ffa278ae0221ad.tar.gz coredns-8fde7407d94feec02027de69d1ffa278ae0221ad.tar.zst coredns-8fde7407d94feec02027de69d1ffa278ae0221ad.zip |
plugin/clouddns: remove initialization from init (#3349)
* plugin/clouddns: remove initialization from init
Init should just call the plugin.Register with a setup function.
Fixes: #3343
Signed-off-by: Miek Gieben <miek@miek.nl>
* Fix placement for var f
Signed-off-by: Miek Gieben <miek@miek.nl>
Diffstat (limited to 'plugin/clouddns/setup.go')
-rw-r--r-- | plugin/clouddns/setup.go | 34 |
1 files changed, 15 insertions, 19 deletions
diff --git a/plugin/clouddns/setup.go b/plugin/clouddns/setup.go index 35c7e9179..7de8efe89 100644 --- a/plugin/clouddns/setup.go +++ b/plugin/clouddns/setup.go @@ -17,27 +17,23 @@ import ( var log = clog.NewWithPlugin("clouddns") -func init() { - plugin.Register("clouddns", - func(c *caddy.Controller) error { - f := func(ctx context.Context, opt option.ClientOption) (gcpDNS, error) { - var err error - var client *gcp.Service - if opt != nil { - client, err = gcp.NewService(ctx, opt) - } else { - // if credentials file is not provided in the Corefile - // authenticate the client using env variables - client, err = gcp.NewService(ctx) - } - return gcpClient{client}, err - } - return setup(c, f) - }, - ) +func init() { plugin.Register("clouddns", setup) } + +// exposed for testing +var f = func(ctx context.Context, opt option.ClientOption) (gcpDNS, error) { + var err error + var client *gcp.Service + if opt != nil { + client, err = gcp.NewService(ctx, opt) + } else { + // if credentials file is not provided in the Corefile + // authenticate the client using env variables + client, err = gcp.NewService(ctx) + } + return gcpClient{client}, err } -func setup(c *caddy.Controller, f func(ctx context.Context, opt option.ClientOption) (gcpDNS, error)) error { +func setup(c *caddy.Controller) error { for c.Next() { keyPairs := map[string]struct{}{} keys := map[string][]string{} |