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

celerygo

package module

Go to main page

Versions in this module

v1

v1.0.2

Mar 3, 2025

Changes in this version

+ const CorrelationIdKey

+ func GetCtxValueString(ctx context.Context, key string) string

type AdditionalParameters

+ CorrelationId *string

type Headers

+ CorrelationId string

v1.0.1

Mar 3, 2025

Changes in this version

+ const AMQP

+ const Debug

+ const ErrorLevel

+ const FatalLevel

+ const ISO8601

+ const InfoLevel

+ const PanicLevel

+ const TraceLevel

+ const WarnLevel

+ func GetBodyTuple(body Body) ([]interface{}, error)

+ func GetOrigin() (string, error)

+ func GetRetryDelayWithExponentialBackOff(currentRetries int64) time.Duration

+ func Ptr[T any](v T) *T

+ type AdditionalParameters struct

+ Callbacks []interface{}

+ Chain []interface{}

+ Chord interface{}

+ ContentEncoding *string

+ ContentType *string

+ CountdownSeconds *int

+ Errbacks []interface{}

+ Eta *string

+ Exchange string

+ ExpiresSeconds *int

+ Group *string

+ GroupId *string

+ GroupIndex *int

+ Immediate bool

+ Language *string

+ Mandatory bool

+ Method *string

+ ParentId *string

+ ReplacedTaskNesting int

+ ReplyTo string

+ Retries int

+ RootId *string

+ RouteName *string

+ RoutingKey *string

+ Shadow *string

+ SoftTimeLimit interface{}

+ TaskId *string

+ TaskType *string

+ TimeLimit []interface{}

+ func (i *AdditionalParameters) GetConsumerLanguage() string

+ func (i *AdditionalParameters) GetContentEncoding() string

+ func (i *AdditionalParameters) GetContentType() string

+ type Body struct

+ Args []interface{}

+ Embed Embed

+ Kwargs map[string]interface{}

+ type CeleryAMQPClient struct

+ func (c *CeleryAMQPClient) Channel() (*amqp.Channel, error)

+ func (c *CeleryAMQPClient) Close() error

+ func (c *CeleryAMQPClient) Connection() interface{}

+ func (c *CeleryAMQPClient) RegisterRoutes(routes map[string]string)

+ func (c *CeleryAMQPClient) SendCeleryTask(ctx context.Context, task string, args []interface{}, kwArgs map[string]any, ...) (*TaskInfo, error)

+ type CeleryClient interface

+ Close func() error

+ Connection func() interface{}

+ RegisterRoutes func(routes map[string]string)

+ SendCeleryTask func(ctx context.Context, task string, args []interface{}, kwArgs map[string]any, ...) (*TaskInfo, error)

+ func NewCeleryClient(dsn string, broker string, options *Options) (CeleryClient, error)

+ type Embed struct

+ Callbacks []interface{}

+ Chain []interface{}

+ Chord interface{}

+ Errbacks []interface{}

+ type Headers struct

+ ArgsRepr string

+ ETA *string

+ Expires *string

+ Group *string

+ ID string

+ KWArgsRepr string

+ Lang string

+ Method *string

+ Origin string

+ ParentID *string

+ ReplacedTaskNesting *int

+ Retries *int

+ RootID string

+ Shadow *string

+ Task string

+ TimeLimit *[]interface{}

+ type LogLevel logrus.Level

+ type Message struct

+ BodyTuple []interface{}

+ Headers Headers

+ type Options struct

+ LogLevel LogLevel

+ MaxBackOffDuration time.Duration

+ func NewDefaultOptions() *Options

+ type TaskInfo struct

+ Id string

+ Message Message

v1.0.0

Mar 3, 2025