Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

drainer

package

Go to main page

Versions in this module

v0

v0.8.7-rc1

Dec 10, 2018

v0.8.6

Sep 26, 2018

v0.8.5

Sep 13, 2018

v0.8.4

Jun 11, 2018

Changes in this version

+ const NodeDrainEventComplete

+ const NodeDrainEventDetailDeadlined

v0.8.4-rc1

Jun 1, 2018

v0.8.3

Apr 27, 2018

v0.8.2

Apr 26, 2018

v0.8.1

Apr 17, 2018

v0.8.0

Apr 12, 2018

Changes in this version

+ const BatchUpdateInterval

+ const LimitStateQueriesPerSecond

+ const NodeDeadlineCoalesceWindow

+ func NewDeadlineHeap(ctx context.Context, coalesceWindow time.Duration) *deadlineHeap

+ func NewDrainingJobWatcher(ctx context.Context, limiter *rate.Limiter, state *state.StateStore, ...) *drainingJobWatcher

+ func NewDrainingNode(node *structs.Node, state *state.StateStore) *drainingNode

+ func NewNodeDrainWatcher(ctx context.Context, limiter *rate.Limiter, state *state.StateStore, ...) *nodeDrainWatcher

+ type DrainDeadlineNotifier interface

+ NextBatch func() <-chan []string

+ Remove func(nodeID string)

+ Watch func(nodeID string, deadline time.Time)

+ func GetDeadlineNotifier(ctx context.Context) DrainDeadlineNotifier

+ type DrainDeadlineNotifierFactory func(context.Context) DrainDeadlineNotifier

+ type DrainRequest struct

+ Allocs []*structs.Allocation

+ Resp *structs.BatchFuture

+ func NewDrainRequest(allocs []*structs.Allocation) *DrainRequest

+ type DrainingJobWatcher interface

+ Drain func() <-chan *DrainRequest

+ Migrated func() <-chan []*structs.Allocation

+ RegisterJobs func(job []structs.NamespacedID)

+ func GetDrainingJobWatcher(ctx context.Context, limiter *rate.Limiter, state *state.StateStore, ...) DrainingJobWatcher

+ type DrainingJobWatcherFactory func(context.Context, *rate.Limiter, *state.StateStore, *log.Logger) DrainingJobWatcher

+ type DrainingNodeWatcher interface

+ type DrainingNodeWatcherFactory func(context.Context, *rate.Limiter, *state.StateStore, *log.Logger, NodeTracker) DrainingNodeWatcher

+ func GetNodeWatcherFactory() DrainingNodeWatcherFactory

+ type MockNodeTracker struct

+ Events []*MockNodeTrackerEvent

+ Nodes map[string]*structs.Node

+ func NewMockNodeTracker() *MockNodeTracker

+ func (m *MockNodeTracker) Remove(nodeID string)

+ func (m *MockNodeTracker) TrackedNodes() map[string]*structs.Node

+ func (m *MockNodeTracker) Update(node *structs.Node)

+ type MockNodeTrackerEvent struct

+ NodeRemove string

+ NodeUpdate *structs.Node

+ type NodeDrainer struct

+ func NewNodeDrainer(c *NodeDrainerConfig) *NodeDrainer

+ func (n *NodeDrainer) Remove(nodeID string)

+ func (n *NodeDrainer) SetEnabled(enabled bool, state *state.StateStore)

+ func (n *NodeDrainer) TrackedNodes() map[string]*structs.Node

+ func (n *NodeDrainer) Update(node *structs.Node)

+ type NodeDrainerConfig struct

+ BatchUpdateInterval time.Duration

+ DrainDeadlineFactory DrainDeadlineNotifierFactory

+ JobFactory DrainingJobWatcherFactory

+ Logger *log.Logger

+ NodeFactory DrainingNodeWatcherFactory

+ Raft RaftApplier

+ StateQueriesPerSecond float64

+ type NodeTracker interface

+ Remove func(nodeID string)

+ TrackedNodes func() map[string]*structs.Node

+ Update func(node *structs.Node)

+ type RaftApplier interface

+ AllocUpdateDesiredTransition func(allocs map[string]*structs.DesiredTransition, evals []*structs.Evaluation) (uint64, error)

+ NodesDrainComplete func(nodes []string) (uint64, error)

v0.8.0-rc1

Mar 30, 2018