Influxdata
/
chronograf
mirror of https://github.com/influxdata/chronograf.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Rename Org field on stores to Organization 

Signed-off-by: Michael de Sa <mjdesa@gmail.com>
pull/5028/head
Jared Scheib 2017-10-23 12:08:11 -07:00 committed by Michael de Sa
parent d220fc3e5e
commit ff575f3ca8
6 changed files with 50 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
bolt/dashboards.go
View File

@ -17,9 +17,9 @@ var DashboardBucket = []byte("Dashoard")
// DashboardsStore is the bolt implementation of storing dashboards // DashboardsStore is the bolt implementation of storing dashboards
type DashboardsStore struct { type DashboardsStore struct {
client *Client client *Client
IDs chronograf.ID IDs chronograf.ID
Org string Organization string
} }
// AddIDs is a migration function that adds ID information to existing dashboards // AddIDs is a migration function that adds ID information to existing dashboards
@ -62,7 +62,7 @@ func (d *DashboardsStore) Migrate(ctx context.Context) error {
func (d *DashboardsStore) All(ctx context.Context) ([]chronograf.Dashboard, error) { func (d *DashboardsStore) All(ctx context.Context) ([]chronograf.Dashboard, error) {
var srcs []chronograf.Dashboard var srcs []chronograf.Dashboard
if err := d.client.db.View(func(tx *bolt.Tx) error { if err := d.client.db.View(func(tx *bolt.Tx) error {
if err := tx.Bucket(bucket(DashboardBucket, d.Org)).ForEach(func(k, v []byte) error { if err := tx.Bucket(bucket(DashboardBucket, d.Organization)).ForEach(func(k, v []byte) error {
var src chronograf.Dashboard var src chronograf.Dashboard
if err := internal.UnmarshalDashboard(v, &src); err != nil { if err := internal.UnmarshalDashboard(v, &src); err != nil {
return err return err
@ -83,7 +83,7 @@ func (d *DashboardsStore) All(ctx context.Context) ([]chronograf.Dashboard, erro
// Add creates a new Dashboard in the DashboardsStore // Add creates a new Dashboard in the DashboardsStore
func (d *DashboardsStore) Add(ctx context.Context, src chronograf.Dashboard) (chronograf.Dashboard, error) { func (d *DashboardsStore) Add(ctx context.Context, src chronograf.Dashboard) (chronograf.Dashboard, error) {
if err := d.client.db.Update(func(tx *bolt.Tx) error { if err := d.client.db.Update(func(tx *bolt.Tx) error {
b := tx.Bucket(bucket(DashboardBucket, d.Org)) b := tx.Bucket(bucket(DashboardBucket, d.Organization))
id, _ := b.NextSequence() id, _ := b.NextSequence()
src.ID = chronograf.DashboardID(id) src.ID = chronograf.DashboardID(id)
@ -114,7 +114,7 @@ func (d *DashboardsStore) Get(ctx context.Context, id chronograf.DashboardID) (c
var src chronograf.Dashboard var src chronograf.Dashboard
if err := d.client.db.View(func(tx *bolt.Tx) error { if err := d.client.db.View(func(tx *bolt.Tx) error {
strID := strconv.Itoa(int(id)) strID := strconv.Itoa(int(id))
if v := tx.Bucket(bucket(DashboardBucket, d.Org)).Get([]byte(strID)); v == nil { if v := tx.Bucket(bucket(DashboardBucket, d.Organization)).Get([]byte(strID)); v == nil {
return chronograf.ErrDashboardNotFound return chronograf.ErrDashboardNotFound
} else if err := internal.UnmarshalDashboard(v, &src); err != nil { } else if err := internal.UnmarshalDashboard(v, &src); err != nil {
return err return err
@ -131,7 +131,7 @@ func (d *DashboardsStore) Get(ctx context.Context, id chronograf.DashboardID) (c
func (d *DashboardsStore) Delete(ctx context.Context, dash chronograf.Dashboard) error { func (d *DashboardsStore) Delete(ctx context.Context, dash chronograf.Dashboard) error {
if err := d.client.db.Update(func(tx *bolt.Tx) error { if err := d.client.db.Update(func(tx *bolt.Tx) error {
strID := strconv.Itoa(int(dash.ID)) strID := strconv.Itoa(int(dash.ID))
if err := tx.Bucket(bucket(DashboardBucket, d.Org)).Delete([]byte(strID)); err != nil { if err := tx.Bucket(bucket(DashboardBucket, d.Organization)).Delete([]byte(strID)); err != nil {
return err return err
} }
return nil return nil
@ -146,7 +146,7 @@ func (d *DashboardsStore) Delete(ctx context.Context, dash chronograf.Dashboard)
func (d *DashboardsStore) Update(ctx context.Context, dash chronograf.Dashboard) error { func (d *DashboardsStore) Update(ctx context.Context, dash chronograf.Dashboard) error {
if err := d.client.db.Update(func(tx *bolt.Tx) error { if err := d.client.db.Update(func(tx *bolt.Tx) error {
// Get an existing dashboard with the same ID. // Get an existing dashboard with the same ID.
b := tx.Bucket(bucket(DashboardBucket, d.Org)) b := tx.Bucket(bucket(DashboardBucket, d.Organization))
strID := strconv.Itoa(int(dash.ID)) strID := strconv.Itoa(int(dash.ID))
if v := b.Get([]byte(strID)); v == nil { if v := b.Get([]byte(strID)); v == nil {
return chronograf.ErrDashboardNotFound return chronograf.ErrDashboardNotFound

16
bolt/layouts.go
View File

@ -16,16 +16,16 @@ var LayoutBucket = []byte("Layout")
// LayoutStore is the bolt implementation to store layouts // LayoutStore is the bolt implementation to store layouts
type LayoutStore struct { type LayoutStore struct {
client *Client client *Client
IDs chronograf.ID IDs chronograf.ID
Org string Organization string
} }
// All returns all known layouts // All returns all known layouts
func (s *LayoutStore) All(ctx context.Context) ([]chronograf.Layout, error) { func (s *LayoutStore) All(ctx context.Context) ([]chronograf.Layout, error) {
var srcs []chronograf.Layout var srcs []chronograf.Layout
if err := s.client.db.View(func(tx *bolt.Tx) error { if err := s.client.db.View(func(tx *bolt.Tx) error {
if err := tx.Bucket(bucket(LayoutBucket, s.Org)).ForEach(func(k, v []byte) error { if err := tx.Bucket(bucket(LayoutBucket, s.Organization)).ForEach(func(k, v []byte) error {
var src chronograf.Layout var src chronograf.Layout
if err := internal.UnmarshalLayout(v, &src); err != nil { if err := internal.UnmarshalLayout(v, &src); err != nil {
return err return err
@ -47,7 +47,7 @@ func (s *LayoutStore) All(ctx context.Context) ([]chronograf.Layout, error) {
// Add creates a new Layout in the LayoutStore. // Add creates a new Layout in the LayoutStore.
func (s *LayoutStore) Add(ctx context.Context, src chronograf.Layout) (chronograf.Layout, error) { func (s *LayoutStore) Add(ctx context.Context, src chronograf.Layout) (chronograf.Layout, error) {
if err := s.client.db.Update(func(tx *bolt.Tx) error { if err := s.client.db.Update(func(tx *bolt.Tx) error {
b := tx.Bucket(bucket(LayoutBucket, s.Org)) b := tx.Bucket(bucket(LayoutBucket, s.Organization))
id, err := s.IDs.Generate() id, err := s.IDs.Generate()
if err != nil { if err != nil {
return err return err
@ -74,7 +74,7 @@ func (s *LayoutStore) Delete(ctx context.Context, src chronograf.Layout) error {
return err return err
} }
if err := s.client.db.Update(func(tx *bolt.Tx) error { if err := s.client.db.Update(func(tx *bolt.Tx) error {
if err := tx.Bucket(bucket(LayoutBucket, s.Org)).Delete([]byte(src.ID)); err != nil { if err := tx.Bucket(bucket(LayoutBucket, s.Organization)).Delete([]byte(src.ID)); err != nil {
return err return err
} }
return nil return nil
@ -89,7 +89,7 @@ func (s *LayoutStore) Delete(ctx context.Context, src chronograf.Layout) error {
func (s *LayoutStore) Get(ctx context.Context, id string) (chronograf.Layout, error) { func (s *LayoutStore) Get(ctx context.Context, id string) (chronograf.Layout, error) {
var src chronograf.Layout var src chronograf.Layout
if err := s.client.db.View(func(tx *bolt.Tx) error { if err := s.client.db.View(func(tx *bolt.Tx) error {
if v := tx.Bucket(bucket(LayoutBucket, s.Org)).Get([]byte(id)); v == nil { if v := tx.Bucket(bucket(LayoutBucket, s.Organization)).Get([]byte(id)); v == nil {
return chronograf.ErrLayoutNotFound return chronograf.ErrLayoutNotFound
} else if err := internal.UnmarshalLayout(v, &src); err != nil { } else if err := internal.UnmarshalLayout(v, &src); err != nil {
return err return err
@ -106,7 +106,7 @@ func (s *LayoutStore) Get(ctx context.Context, id string) (chronograf.Layout, er
func (s *LayoutStore) Update(ctx context.Context, src chronograf.Layout) error { func (s *LayoutStore) Update(ctx context.Context, src chronograf.Layout) error {
if err := s.client.db.Update(func(tx *bolt.Tx) error { if err := s.client.db.Update(func(tx *bolt.Tx) error {
// Get an existing layout with the same ID. // Get an existing layout with the same ID.
b := tx.Bucket(bucket(LayoutBucket, s.Org)) b := tx.Bucket(bucket(LayoutBucket, s.Organization))
if v := b.Get([]byte(src.ID)); v == nil { if v := b.Get([]byte(src.ID)); v == nil {
return chronograf.ErrLayoutNotFound return chronograf.ErrLayoutNotFound
} }

20
bolt/organizations.go
View File

@ -167,22 +167,22 @@ func (s *OrganizationsStore) get(ctx context.Context, id uint64) (*chronograf.Or
func (s *OrganizationsStore) appendStores(o *chronograf.Organization) { func (s *OrganizationsStore) appendStores(o *chronograf.Organization) {
idStr := strconv.FormatUint(o.ID, 10) idStr := strconv.FormatUint(o.ID, 10)
o.SourcesStore = &SourcesStore{ o.SourcesStore = &SourcesStore{
client: s.client, client: s.client,
Org: idStr, Organization: idStr,
} }
o.ServersStore = &ServersStore{ o.ServersStore = &ServersStore{
client: s.client, client: s.client,
Org: idStr, Organization: idStr,
} }
o.LayoutStore = &LayoutStore{ o.LayoutStore = &LayoutStore{
client: s.client, client: s.client,
Org: idStr, Organization: idStr,
IDs: &uuid.V4{}, IDs: &uuid.V4{},
} }
o.DashboardsStore = &DashboardsStore{ o.DashboardsStore = &DashboardsStore{
client: s.client, client: s.client,
Org: idStr, Organization: idStr,
IDs: &uuid.V4{}, IDs: &uuid.V4{},
} }
} }

16
bolt/organizations_test.go
View File

@ -93,7 +93,7 @@ func TestOrganizationsStore_GetWithName(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltSourcesStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltSourcesStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() SourcesStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() SourcesStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -103,7 +103,7 @@ func TestOrganizationsStore_GetWithName(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltServersStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltServersStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() ServerssStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() ServerssStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -113,7 +113,7 @@ func TestOrganizationsStore_GetWithName(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltLayoutStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltLayoutStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() LayoutStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() LayoutStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -123,7 +123,7 @@ func TestOrganizationsStore_GetWithName(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltDashboardsStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltDashboardsStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() DashboardsStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() DashboardsStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -204,7 +204,7 @@ func TestOrganizationsStore_GetWithID(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltSourcesStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltSourcesStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() SourcesStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() SourcesStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -214,7 +214,7 @@ func TestOrganizationsStore_GetWithID(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltServersStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltServersStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() ServerssStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() ServerssStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -224,7 +224,7 @@ func TestOrganizationsStore_GetWithID(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltLayoutStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltLayoutStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() LayoutStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() LayoutStore.org = %s, want %s", gotOrg, wantOrg)
} }
@ -234,7 +234,7 @@ func TestOrganizationsStore_GetWithID(t *testing.T) {
return return
} }
if gotOrg, wantOrg := boltDashboardsStore.Org, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg { if gotOrg, wantOrg := boltDashboardsStore.Organization, strconv.FormatUint(got.ID, 10); gotOrg != wantOrg {
t.Errorf("%q. OrganizationsStore.Get() DashboardsStore.org = %s, want %s", gotOrg, wantOrg) t.Errorf("%q. OrganizationsStore.Get() DashboardsStore.org = %s, want %s", gotOrg, wantOrg)
} }
}) })

16
bolt/servers.go
View File

@ -17,8 +17,8 @@ var ServersBucket = []byte("Servers")
// ServersStore is the bolt implementation to store servers in a store. // ServersStore is the bolt implementation to store servers in a store.
// Used store servers that are associated in some way with a source // Used store servers that are associated in some way with a source
type ServersStore struct { type ServersStore struct {
client *Client client *Client
Org string Organization string
} }
// All returns all known servers // All returns all known servers
@ -42,7 +42,7 @@ func (s *ServersStore) All(ctx context.Context) ([]chronograf.Server, error) {
// Add creates a new Server in the ServerStore. // Add creates a new Server in the ServerStore.
func (s *ServersStore) Add(ctx context.Context, src chronograf.Server) (chronograf.Server, error) { func (s *ServersStore) Add(ctx context.Context, src chronograf.Server) (chronograf.Server, error) {
if err := s.client.db.Update(func(tx *bolt.Tx) error { if err := s.client.db.Update(func(tx *bolt.Tx) error {
b := tx.Bucket(bucket(ServersBucket, s.Org)) b := tx.Bucket(bucket(ServersBucket, s.Organization))
seq, err := b.NextSequence() seq, err := b.NextSequence()
if err != nil { if err != nil {
return err return err
@ -69,7 +69,7 @@ func (s *ServersStore) Add(ctx context.Context, src chronograf.Server) (chronogr
// Delete removes the Server from the ServersStore // Delete removes the Server from the ServersStore
func (s *ServersStore) Delete(ctx context.Context, src chronograf.Server) error { func (s *ServersStore) Delete(ctx context.Context, src chronograf.Server) error {
if err := s.client.db.Update(func(tx *bolt.Tx) error { if err := s.client.db.Update(func(tx *bolt.Tx) error {
if err := tx.Bucket(bucket(ServersBucket, s.Org)).Delete(itob(src.ID)); err != nil { if err := tx.Bucket(bucket(ServersBucket, s.Organization)).Delete(itob(src.ID)); err != nil {
return err return err
} }
return nil return nil
@ -84,7 +84,7 @@ func (s *ServersStore) Delete(ctx context.Context, src chronograf.Server) error
func (s *ServersStore) Get(ctx context.Context, id int) (chronograf.Server, error) { func (s *ServersStore) Get(ctx context.Context, id int) (chronograf.Server, error) {
var src chronograf.Server var src chronograf.Server
if err := s.client.db.View(func(tx *bolt.Tx) error { if err := s.client.db.View(func(tx *bolt.Tx) error {
if v := tx.Bucket(bucket(ServersBucket, s.Org)).Get(itob(id)); v == nil { if v := tx.Bucket(bucket(ServersBucket, s.Organization)).Get(itob(id)); v == nil {
return chronograf.ErrServerNotFound return chronograf.ErrServerNotFound
} else if err := internal.UnmarshalServer(v, &src); err != nil { } else if err := internal.UnmarshalServer(v, &src); err != nil {
return err return err
@ -101,7 +101,7 @@ func (s *ServersStore) Get(ctx context.Context, id int) (chronograf.Server, erro
func (s *ServersStore) Update(ctx context.Context, src chronograf.Server) error { func (s *ServersStore) Update(ctx context.Context, src chronograf.Server) error {
if err := s.client.db.Update(func(tx *bolt.Tx) error { if err := s.client.db.Update(func(tx *bolt.Tx) error {
// Get an existing server with the same ID. // Get an existing server with the same ID.
b := tx.Bucket(bucket(ServersBucket, s.Org)) b := tx.Bucket(bucket(ServersBucket, s.Organization))
if v := b.Get(itob(src.ID)); v == nil { if v := b.Get(itob(src.ID)); v == nil {
return chronograf.ErrServerNotFound return chronograf.ErrServerNotFound
} }
@ -126,7 +126,7 @@ func (s *ServersStore) Update(ctx context.Context, src chronograf.Server) error
func (s *ServersStore) all(ctx context.Context, tx *bolt.Tx) ([]chronograf.Server, error) { func (s *ServersStore) all(ctx context.Context, tx *bolt.Tx) ([]chronograf.Server, error) {
var srcs []chronograf.Server var srcs []chronograf.Server
if err := tx.Bucket(bucket(ServersBucket, s.Org)).ForEach(func(k, v []byte) error { if err := tx.Bucket(bucket(ServersBucket, s.Organization)).ForEach(func(k, v []byte) error {
var src chronograf.Server var src chronograf.Server
if err := internal.UnmarshalServer(v, &src); err != nil { if err := internal.UnmarshalServer(v, &src); err != nil {
return err return err
@ -141,7 +141,7 @@ func (s *ServersStore) all(ctx context.Context, tx *bolt.Tx) ([]chronograf.Serve
// resetActiveServer unsets the Active flag on all sources // resetActiveServer unsets the Active flag on all sources
func (s *ServersStore) resetActiveServer(ctx context.Context, tx *bolt.Tx) error { func (s *ServersStore) resetActiveServer(ctx context.Context, tx *bolt.Tx) error {
b := tx.Bucket(bucket(ServersBucket, s.Org)) b := tx.Bucket(bucket(ServersBucket, s.Organization))
srcs, err := s.all(ctx, tx) srcs, err := s.all(ctx, tx)
if err != nil { if err != nil {
return err return err

16
bolt/sources.go
View File

@ -16,8 +16,8 @@ var SourcesBucket = []byte("Sources")
// SourcesStore is a bolt implementation to store time-series source information. // SourcesStore is a bolt implementation to store time-series source information.
type SourcesStore struct { type SourcesStore struct {
client *Client client *Client
Org string Organization string
} }
// All returns all known sources // All returns all known sources
@ -101,7 +101,7 @@ func (s *SourcesStore) Update(ctx context.Context, src chronograf.Source) error
func (s *SourcesStore) all(ctx context.Context, tx *bolt.Tx) ([]chronograf.Source, error) { func (s *SourcesStore) all(ctx context.Context, tx *bolt.Tx) ([]chronograf.Source, error) {
var srcs []chronograf.Source var srcs []chronograf.Source
if err := tx.Bucket(bucket(SourcesBucket, s.Org)).ForEach(func(k, v []byte) error { if err := tx.Bucket(bucket(SourcesBucket, s.Organization)).ForEach(func(k, v []byte) error {
var src chronograf.Source var src chronograf.Source
if err := internal.UnmarshalSource(v, &src); err != nil { if err := internal.UnmarshalSource(v, &src); err != nil {
return err return err
@ -115,7 +115,7 @@ func (s *SourcesStore) all(ctx context.Context, tx *bolt.Tx) ([]chronograf.Sourc
} }
func (s *SourcesStore) add(ctx context.Context, src *chronograf.Source, tx *bolt.Tx) error { func (s *SourcesStore) add(ctx context.Context, src *chronograf.Source, tx *bolt.Tx) error {
b := tx.Bucket(bucket(SourcesBucket, s.Org)) b := tx.Bucket(bucket(SourcesBucket, s.Organization))
seq, err := b.NextSequence() seq, err := b.NextSequence()
if err != nil { if err != nil {
return err return err
@ -137,7 +137,7 @@ func (s *SourcesStore) add(ctx context.Context, src *chronograf.Source, tx *bolt
} }
func (s *SourcesStore) delete(ctx context.Context, src chronograf.Source, tx *bolt.Tx) error { func (s *SourcesStore) delete(ctx context.Context, src chronograf.Source, tx *bolt.Tx) error {
if err := tx.Bucket(bucket(SourcesBucket, s.Org)).Delete(itob(src.ID)); err != nil { if err := tx.Bucket(bucket(SourcesBucket, s.Organization)).Delete(itob(src.ID)); err != nil {
return err return err
} }
return nil return nil
@ -145,7 +145,7 @@ func (s *SourcesStore) delete(ctx context.Context, src chronograf.Source, tx *bo
func (s *SourcesStore) get(ctx context.Context, id int, tx *bolt.Tx) (chronograf.Source, error) { func (s *SourcesStore) get(ctx context.Context, id int, tx *bolt.Tx) (chronograf.Source, error) {
var src chronograf.Source var src chronograf.Source
if v := tx.Bucket(bucket(SourcesBucket, s.Org)).Get(itob(id)); v == nil { if v := tx.Bucket(bucket(SourcesBucket, s.Organization)).Get(itob(id)); v == nil {
return src, chronograf.ErrSourceNotFound return src, chronograf.ErrSourceNotFound
} else if err := internal.UnmarshalSource(v, &src); err != nil { } else if err := internal.UnmarshalSource(v, &src); err != nil {
return src, err return src, err
@ -155,7 +155,7 @@ func (s *SourcesStore) get(ctx context.Context, id int, tx *bolt.Tx) (chronograf
func (s *SourcesStore) update(ctx context.Context, src chronograf.Source, tx *bolt.Tx) error { func (s *SourcesStore) update(ctx context.Context, src chronograf.Source, tx *bolt.Tx) error {
// Get an existing soource with the same ID. // Get an existing soource with the same ID.
b := tx.Bucket(bucket(SourcesBucket, s.Org)) b := tx.Bucket(bucket(SourcesBucket, s.Organization))
if v := b.Get(itob(src.ID)); v == nil { if v := b.Get(itob(src.ID)); v == nil {
return chronograf.ErrSourceNotFound return chronograf.ErrSourceNotFound
} }
@ -176,7 +176,7 @@ func (s *SourcesStore) update(ctx context.Context, src chronograf.Source, tx *bo
// resetDefaultSource unsets the Default flag on all sources // resetDefaultSource unsets the Default flag on all sources
func (s *SourcesStore) resetDefaultSource(ctx context.Context, tx *bolt.Tx) error { func (s *SourcesStore) resetDefaultSource(ctx context.Context, tx *bolt.Tx) error {
b := tx.Bucket(bucket(SourcesBucket, s.Org)) b := tx.Bucket(bucket(SourcesBucket, s.Organization))
srcs, err := s.all(ctx, tx) srcs, err := s.all(ctx, tx)
if err != nil { if err != nil {
return err return err