Help us shape the future of Go! Take the 2026 Go Developer Survey

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
- API
  
  Reference documentation for the pkg.go.dev API
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.19.0

Oct 3, 2024

v0.18.1

Sep 16, 2024

v0.18.0

Sep 12, 2024

Changes in this version

+ const ClusterTypeAll

+ type ApplicationDetail struct

+ Application *v1alpha1.Application

+ StatusTime time.Time

+ type ClusterConfig struct

+ ClusterType string

+ type ExternalConfig struct

+ External bool

+ ListenerUrl string

+ Namespace string

+ Token string

+ type Informer struct

+ func NewStartController(logger *zap.SugaredLogger, client *pubsub.PubSubClientServiceImpl, ...) *Informer

+ func (impl *Informer) SendAppDelete(app *v1alpha1.Application, statusTime time.Time)

+ func (impl *Informer) SendAppUpdate(app *v1alpha1.Application, statusTime time.Time)

+ func (impl *Informer) Start(stopChan <-chan int)

v0.1.0

Jul 22, 2021

Changes in this version

+ func FireDailyMinuteEvent()

+ func PublishEventsOnRest(jsonBody []byte, topic string, externalCdConfig *ExternalCdConfig) error

+ func SendAppUpdate(app *v1alpha12.Application, client *PubSubClient)

+ func Start(conf *config.Config, eventHandler handlers.Handler)

+ type AcdConfig struct

+ ACDInformer bool

+ ACDNamespace string

+ type CdConfig struct

+ CdInformer bool

+ DefaultNamespace string

+ type CiConfig struct

+ CiInformer bool

+ DefaultNamespace string

+ type Controller struct

+ func (c *Controller) HasSynced() bool

+ func (c *Controller) LastSyncResourceVersion() string

+ func (c *Controller) Run(stopCh <-chan struct{})

+ type CronEvent struct

+ CorrelationId string

+ EventName string

+ EventTime string

+ EventTypeId int

+ Payload map[string]string

+ type Event struct

+ type EventType int

+ const Fail

+ const Success

+ const Trigger

+ type ExternalCdConfig struct

+ External bool

+ ListenerUrl string

+ Namespace string

+ Token string

+ type PubSubClient struct

+ Conn stan.Conn

+ func NewPubSubClient() (*PubSubClient, error)

+ type PubSubConfig struct

+ ClientId string

+ ClusterId string

+ NatsServerHost string

+ type PublishRequest struct

+ Payload json.RawMessage

+ Topic string

+ type WorkflowUpdateReq struct

+ Key string

+ Type string