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

triggered

package

Go to main page

Versions in this module

v0

v0.3.0

Oct 10, 2026

Changes in this version

+ type Config struct

+ Backpressure engine.Backpressure

+ ExecuteDo Handler[ITEM]

+ ItemsChanSize int

+ MaxPending int

+ Name string

+ QueueSize int

+ Recover basic.RecoverFunc

+ Shared *Share

type EventExecute

+ func RegisterExecuteEx[ITEM any](cfg *Config[ITEM]) *EventExecute[ITEM]

+ func (exec *EventExecute[ITEM]) Shared() *Share

+ func (exec *EventExecute[ITEM]) TryNotify(item ITEM) error

+ func (exec *EventExecute[ITEM]) WithOnExecute(fn func(basic.ExecuteEvent)) *EventExecute[ITEM]

+ type Handler func(items *Items[ITEM]) error

+ type Items struct

+ Shared *Share

+ Value []T

+ func (it *Items[T]) Len() int

+ func (it *Items[T]) Seq() uint64

+ type Share struct

+ func NewShare() *Share

+ func (s *Share) CompareAndSwap(old, new any) bool

+ func (s *Share) Load() any

+ func (s *Share) SetValue(v any)

+ func (s *Share) Store(value any)

+ func (s *Share) Swap(value any) any

+ func (s *Share) Value(do func(v any))

v0.2.2

Aug 4, 2023

Changes in this version

type EventExecute

+ func (exec *EventExecute[PARAMS]) RefCountAdd(count int64) int64

v0.2.1

Aug 4, 2023

v0.2.0

Aug 4, 2023

Changes in this version

type EventExecute

+ func (exec *EventExecute[PARAMS]) RefCount(count int64) int64

v0.1.1

Aug 1, 2023

v0.1.0

Aug 1, 2023

Changes in this version

type EventExecute

+ NULL PARAMS

+ func (e *EventExecute[PARAMS]) WithConcurrentNum(v int64) *EventExecute[PARAMS]

+ func (e *EventExecute[PARAMS]) WithRecover(recoverDo func(ierr any)) *EventExecute[PARAMS]

+ func (e *EventExecute[PARAMS]) WithShared(v any) *EventExecute[PARAMS]

v0.0.4

Aug 1, 2023

Changes in this version

type EventExecute

+ func (e *EventExecute[PARAMS]) SetRecover(recoverDo func(ierr any))

v0.0.3

Aug 1, 2023

Changes in this version

+ type EventExecute struct

+ func RegisterExecute(execDo func(params *Params[PARAMS]), recoverDo func(ierr any)) *EventExecute[PARAMS]

+ func (e *EventExecute[PARAMS]) SetConcurrentNum(v int64)

+ func (e *EventExecute[PARAMS]) SetShared(v any)

+ func (exec *EventExecute[PARAMS]) Notify(params *PARAMS)

+ type Shared struct

+ func (s *Shared) SetValue(v any)

+ func (s *Shared) Value(do func(v any))

v0.0.2

Jul 31, 2023

Changes in this version

+ type Event uint32

+ type EventTriggeredExecute struct

+ func NewEventTriggeredExecute() *EventTriggeredExecute[PARAMS]

+ func (be *EventTriggeredExecute[PARAMS]) CoverExecute(e Event, execDo func(params *Params[PARAMS]), recoverDo func(ierr any))

+ func (be *EventTriggeredExecute[PARAMS]) Notify(e Event, params *PARAMS)

+ func (be *EventTriggeredExecute[PARAMS]) RegisterExecute(execDo func(params *Params[PARAMS]), recoverDo func(ierr any)) Event

+ func (be *EventTriggeredExecute[PARAMS]) SetShared(e Event, v any)

+ type Params struct

+ Shared any

+ Value *T