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

broker

package

Go to main page

Versions in this module

v0

v0.1.117

Jan 27, 2025

v0.1.116

Jan 20, 2025

v0.1.115

Jan 18, 2025

v0.1.114

Jan 8, 2025

v0.1.113

Jan 5, 2025

Changes in this version

+ const BROKER_INMEMORY

+ const BROKER_RABBITMQ

+ const QUEUE_COMPLETED

+ const QUEUE_DEFAULT

+ const QUEUE_ERROR

+ const QUEUE_EXCLUSIVE_PREFIX

+ const QUEUE_HEARTBEAT

+ const QUEUE_JOBS

+ const QUEUE_LOGS

+ const QUEUE_PENDING

+ const QUEUE_PROGRESS

+ const QUEUE_STARTED

+ const RABBITMQ_DEFAULT_CONSUMER_TIMEOUT

+ const TOPIC_JOB

+ const TOPIC_JOB_COMPLETED

+ const TOPIC_JOB_FAILED

+ const TOPIC_JOB_SCHEDULED

+ func IsCoordinatorQueue(qname string) bool

+ func IsTaskQueue(qname string) bool

+ func IsWorkerQueue(qname string) bool

+ type Broker interface

+ HealthCheck func(ctx context.Context) error

+ PublishEvent func(ctx context.Context, topic string, event any) error

+ PublishHeartbeat func(ctx context.Context, n *tork.Node) error

+ PublishJob func(ctx context.Context, j *tork.Job) error

+ PublishTask func(ctx context.Context, qname string, t *tork.Task) error

+ PublishTaskLogPart func(ctx context.Context, p *tork.TaskLogPart) error

+ PublishTaskProgress func(ctx context.Context, t *tork.Task) error

+ Queues func(ctx context.Context) ([]QueueInfo, error)

+ Shutdown func(ctx context.Context) error

+ SubscribeForEvents func(ctx context.Context, pattern string, handler func(event any)) error

+ SubscribeForHeartbeats func(handler func(n *tork.Node) error) error

+ SubscribeForJobs func(handler func(j *tork.Job) error) error

+ SubscribeForTaskLogPart func(handler func(p *tork.TaskLogPart)) error

+ SubscribeForTaskProgress func(handler func(t *tork.Task) error) error

+ SubscribeForTasks func(qname string, handler func(t *tork.Task) error) error

+ type InMemoryBroker struct

+ func NewInMemoryBroker() *InMemoryBroker

+ func (b *InMemoryBroker) HealthCheck(ctx context.Context) error

+ func (b *InMemoryBroker) PublishEvent(ctx context.Context, topicName string, event any) error

+ func (b *InMemoryBroker) PublishHeartbeat(_ context.Context, n *tork.Node) error

+ func (b *InMemoryBroker) PublishJob(ctx context.Context, j *tork.Job) error

+ func (b *InMemoryBroker) PublishTask(ctx context.Context, qname string, t *tork.Task) error

+ func (b *InMemoryBroker) PublishTaskLogPart(ctx context.Context, p *tork.TaskLogPart) error

+ func (b *InMemoryBroker) PublishTaskProgress(ctx context.Context, tp *tork.Task) error

+ func (b *InMemoryBroker) Queues(ctx context.Context) ([]QueueInfo, error)

+ func (b *InMemoryBroker) Shutdown(ctx context.Context) error

+ func (b *InMemoryBroker) SubscribeForEvents(ctx context.Context, topic string, handler func(event any)) error

+ func (b *InMemoryBroker) SubscribeForHeartbeats(handler func(n *tork.Node) error) error

+ func (b *InMemoryBroker) SubscribeForJobs(handler func(j *tork.Job) error) error

+ func (b *InMemoryBroker) SubscribeForTaskLogPart(handler func(p *tork.TaskLogPart)) error

+ func (b *InMemoryBroker) SubscribeForTaskProgress(handler func(tp *tork.Task) error) error

+ func (b *InMemoryBroker) SubscribeForTasks(qname string, handler func(t *tork.Task) error) error

+ type LogShipper struct

+ Broker Broker

+ TaskID string

+ func NewLogShipper(broker Broker, taskID string) *LogShipper

+ func (r *LogShipper) Write(p []byte) (int, error)

+ type Option = func(b *RabbitMQBroker)

+ func WithConsumerTimeoutMS(consumerTimeout time.Duration) Option

+ func WithDurableQueues(val bool) Option

+ func WithHeartbeatTTL(ttl int) Option

+ func WithManagementURL(url string) Option

+ type Provider func() (Broker, error)

+ type QueueInfo struct

+ Name string

+ Size int

+ Subscribers int

+ Unacked int

+ type RabbitMQBroker struct

+ func NewRabbitMQBroker(url string, opts ...Option) (*RabbitMQBroker, error)

+ func (b *RabbitMQBroker) HealthCheck(ctx context.Context) error

+ func (b *RabbitMQBroker) PublishEvent(ctx context.Context, topic string, event any) error

+ func (b *RabbitMQBroker) PublishHeartbeat(ctx context.Context, n *tork.Node) error

+ func (b *RabbitMQBroker) PublishJob(ctx context.Context, j *tork.Job) error

+ func (b *RabbitMQBroker) PublishTask(ctx context.Context, qname string, t *tork.Task) error

+ func (b *RabbitMQBroker) PublishTaskLogPart(ctx context.Context, p *tork.TaskLogPart) error

+ func (b *RabbitMQBroker) PublishTaskProgress(ctx context.Context, tp *tork.Task) error

+ func (b *RabbitMQBroker) Queues(ctx context.Context) ([]QueueInfo, error)

+ func (b *RabbitMQBroker) Shutdown(ctx context.Context) error

+ func (b *RabbitMQBroker) SubscribeForEvents(ctx context.Context, pattern string, handler func(event any)) error

+ func (b *RabbitMQBroker) SubscribeForHeartbeats(handler func(n *tork.Node) error) error

+ func (b *RabbitMQBroker) SubscribeForJobs(handler func(j *tork.Job) error) error

+ func (b *RabbitMQBroker) SubscribeForTaskLogPart(handler func(p *tork.TaskLogPart)) error

+ func (b *RabbitMQBroker) SubscribeForTaskProgress(handler func(t *tork.Task) error) error

+ func (b *RabbitMQBroker) SubscribeForTasks(qname string, handler func(t *tork.Task) error) error