Skip to content

Commit

Permalink
fixing lints
Browse files Browse the repository at this point in the history
  • Loading branch information
drewbailey committed Oct 6, 2020
1 parent fd0d8de commit a8d74ab
Show file tree
Hide file tree
Showing 7 changed files with 7 additions and 18 deletions.
1 change: 0 additions & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,6 @@ require (
github.com/coreos/go-iptables v0.4.3-0.20190724151750-969b135e941d
github.com/coreos/go-semver v0.3.0
github.com/cyphar/filepath-securejoin v0.2.3-0.20190205144030-7efe413b52e1 // indirect
github.com/davecgh/go-spew v1.1.1
github.com/docker/cli v0.0.0-20200303215952-eb310fca4956
github.com/docker/distribution v2.7.1+incompatible
github.com/docker/docker v17.12.0-ce-rc1.0.20200330121334-7f8b4b621b5d+incompatible
Expand Down
2 changes: 0 additions & 2 deletions nomad/fsm.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,6 @@ const (

// timeTableLimit is the maximum limit of our tracking
timeTableLimit = 72 * time.Hour

defaultDurableCount = 1000
)

// SnapshotType is prefixed to a record in the FSM snapshot
Expand Down
6 changes: 0 additions & 6 deletions nomad/stream/event.go

This file was deleted.

3 changes: 2 additions & 1 deletion nomad/stream/event_buffer.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,10 @@ import (
"context"
"errors"
"fmt"
"github.com/hashicorp/nomad/nomad/structs"
"sync/atomic"
"time"

"github.com/hashicorp/nomad/nomad/structs"
)

// eventBuffer is a single-writer, multiple-reader, fixed length concurrent
Expand Down
8 changes: 2 additions & 6 deletions nomad/stream/event_publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,11 @@ package stream

import (
"context"
"github.com/hashicorp/nomad/nomad/structs"
"sync"
"time"

"github.com/hashicorp/nomad/nomad/structs"

"github.com/hashicorp/go-hclog"
)

Expand Down Expand Up @@ -138,11 +139,6 @@ func (e *EventPublisher) periodicPrune(ctx context.Context) {
}
}

type changeEvents struct {
index uint64
events []structs.Event
}

// sendEvents sends the given events to the publishers event buffer.
func (e *EventPublisher) sendEvents(update structs.Events) {
e.lock.Lock()
Expand Down
4 changes: 3 additions & 1 deletion nomad/stream/subscription.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,11 +3,13 @@ package stream
import (
"context"
"errors"
"github.com/hashicorp/nomad/nomad/structs"
"sync/atomic"

"github.com/hashicorp/nomad/nomad/structs"
)

const (
AllKeys = "*"
// subscriptionStateOpen is the default state of a subscription. An open
// subscription may receive new events.
subscriptionStateOpen uint32 = 0
Expand Down
1 change: 0 additions & 1 deletion vendor/modules.txt
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,6 @@ github.com/coreos/go-systemd/v22/dbus
## explicit
github.com/cyphar/filepath-securejoin
# github.com/davecgh/go-spew v1.1.1
## explicit
github.com/davecgh/go-spew/spew
# github.com/denverdino/aliyungo v0.0.0-20190125010748-a747050bb1ba
github.com/denverdino/aliyungo/common
Expand Down

0 comments on commit a8d74ab

Please sign in to comment.