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

tasker

package module

Go to main page

Versions in this module

v0

v0.1.5

Jul 30, 2024

v0.1.4

Jun 16, 2024

v0.1.3

Mar 16, 2024

v0.1.2

Feb 25, 2024

v0.1.1

Feb 25, 2024

Changes in this version

type MultiTaskerConfig

+ ErrorHandler ErrorFn

+ NumTasksPerPart int

+ PartFn TaskIdPartIdTaskDetailsFn

+ ProcessFn ProcessFn

+ Reader *kafka.Reader

v0.1.0

Feb 25, 2024

Changes in this version

+ func CreateTopic(port, topic string) error

+ func GetLogger() zerolog.Logger

+ func InitKafkaWriter(ctx context.Context, kafkaBrokers, kafkaTopic string) *kafka.Writer

+ func ProcessFnWithRetryPersistence(ctx context.Context, kMsg kafka.Message, partFn TaskIdPartIdTaskDetailsFn, ...) error

+ func WrapError(err error, wrap string) error

+ type AttemptInf interface

+ CreateNewAttempt func(ctx context.Context, att TaskAttempt) error

+ FindPrevAttempts func(ctx context.Context, taskId string) ([]TaskAttempt, error)

+ UpdateAttemptStatus func(ctx context.Context, att TaskAttempt, status TaskStatus, msg string) error

+ type CleanupFunc func()

+ func InitKafkaForTesting() (CleanupFunc, string, error)

+ type CommitterInf interface

+ CommitMessages func(ctx context.Context, msgs ...kafka.Message) error

+ type ErrorFn func(ctx context.Context, kMsg kafka.Message) error

+ type ExecutionInf interface

+ Execute func(ctx context.Context, taskId string, attemptId int, prevAttempts []TaskAttempt, ...) (bool, string, error)

+ type KafkaMultiTasker struct

+ func NewKafkaMultiTasker(ctx context.Context, config MultiTaskerConfig) (KafkaMultiTasker, error)

+ func (c *KafkaMultiTasker) Start(ctx context.Context)

+ type LogConsumer struct

+ func (lc *LogConsumer) Accept(l testcontainers.Log)

+ type MultiTaskerConfig struct

+ type NoopCommitter struct

+ func (c *NoopCommitter) CommitMessages(ctx context.Context, msgs ...kafka.Message) error

+ type ProcessFn func(ctx context.Context, kMsg kafka.Message) (bool, error)

+ type SimpleCommitter struct

+ Reader *kafka.Reader

+ func (c *SimpleCommitter) CommitMessages(ctx context.Context, msgs ...kafka.Message) error

+ type TaskAttempt struct

+ AttemptId int

+ Msg string

+ Status TaskStatus

+ TaskId string

+ TimeMs int64

+ type TaskIdPartIdTaskDetailsFn func(ctx context.Context, kMsg kafka.Message) (string, string, any)

+ type TaskStatus int

+ const TASK_STATUS_ATTEMPT

+ const TASK_STATUS_CANCELLED

+ const TASK_STATUS_FAILURE

+ const TASK_STATUS_PRE

+ const TASK_STATUS_SUCCESS

v0.0.1

Feb 24, 2024