Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

controller

package

Go to main page

Versions in this module

v0

v0.0.7

May 23, 2018

v0.0.6

Apr 6, 2018

v0.0.5

Mar 21, 2018

Changes in this version

+ const DefaultScalerInterval

+ func DecorateWithDelayAndSmoothing(c Controller)

+ type Controller interface

+ Run func(closeCh <-chan struct{})

+ SetScalingInterval func(interval time.Duration)

+ func New(topicInformer informersV1.TopicInformer, ...) Controller

+ type Deployer interface

+ Deploy func(function *v1.Function) error

+ Scale func(function *v1.Function, replicas int) error

+ Undeploy func(function *v1.Function) error

+ Update func(function *v1.Function, replicas int) error

+ func NewDeployer(config *rest.Config, brokers []string) (Deployer, error)

+ type LagTracker interface

+ BeginTracking func(Subscription) error

+ Compute func() map[Subscription]PartitionedOffsets

+ StopTracking func(Subscription) error

+ func NewLagTracker(brokers []string) LagTracker

+ type Offsets struct

+ Current int64

+ End int64

+ PreviousCurrent int64

+ func (o Offsets) Activity() int64

+ func (o Offsets) Lag() int64

+ func (o Offsets) String() string

+ type PartitionedOffsets map[int32]Offsets

+ func (po PartitionedOffsets) String() string

+ type Subscription struct

+ Group string

+ Topic string