diff --git a/config.go b/config.go index 7835e47..9c75776 100644 --- a/config.go +++ b/config.go @@ -71,7 +71,7 @@ type InfluxdbConfig struct { Enabled bool InfluxdbURL string AccessToken string - Orgnization string + Organization string Bucket string } type Retension struct { @@ -172,7 +172,7 @@ func loadConfig() Config { Enabled: v.GetBool("InfluxdbConfig.Enabled"), InfluxdbURL: v.GetString("InfluxdbConfig.InfluxdbURL"), AccessToken: v.GetString("InfluxdbConfig.AccessToken"), - Orgnization: v.GetString("InfluxdbConfig.Orgnization"), + Organization: v.GetString("InfluxdbConfig.Organization"), Bucket: v.GetString("InfluxdbConfig.Bucket"), } // setup config.yaml (Retension) diff --git a/influxdb.go b/influxdb.go index 0aff3af..ff3dfee 100644 --- a/influxdb.go +++ b/influxdb.go @@ -27,6 +27,7 @@ func NewInfluxdbClient(config InfluxdbConfig) *InfluxdbClient { c.Bucket = config.Bucket c.AccessToken = config.AccessToken c.InfluxCloudURL = config.InfluxdbURL + c.Organization = config.Organization c.Client = influxdb2.NewClientWithOptions(c.InfluxCloudURL, c.AccessToken, influxdb2.DefaultOptions().SetBatchSize(InfluxdbAsyncBatchSize)) return c