twitter_post

Documentation

Index

• type TwitterPostArgs
  • func (TwitterPostArgs) InsertOpts() river.InsertOpts
  • func (TwitterPostArgs) Kind() string
• type TwitterPostWorker
  • func NewTwitterPostWorker(logger *zap.Logger, httpClient *http.Client, dbClient *db.DbClient) *TwitterPostWorker
  • func (w *TwitterPostWorker) NextRetry(job *river.Job[TwitterPostArgs]) time.Time
  • func (w *TwitterPostWorker) Timeout(job *river.Job[TwitterPostArgs]) time.Duration
  • func (w *TwitterPostWorker) Work(ctx context.Context, job *river.Job[TwitterPostArgs]) error

Types

type TwitterPostArgs

type TwitterPostArgs struct {
	Incident   api.Incident `json:"incident"`
	WebhookUrl string       `json:"webhook_url"`
}

func (TwitterPostArgs) InsertOpts

func (TwitterPostArgs) InsertOpts() river.InsertOpts

func (TwitterPostArgs) Kind

func (TwitterPostArgs) Kind() string

type TwitterPostWorker

type TwitterPostWorker struct {
	// An embedded WorkerDefaults sets up default methods to fulfill the rest of
	// the Worker interface:
	river.WorkerDefaults[TwitterPostArgs]
	// contains filtered or unexported fields
}

func NewTwitterPostWorker

func NewTwitterPostWorker(logger *zap.Logger, httpClient *http.Client, dbClient *db.DbClient) *TwitterPostWorker

func (*TwitterPostWorker) NextRetry

func (w *TwitterPostWorker) NextRetry(job *river.Job[TwitterPostArgs]) time.Time

NextRetry performs exponential backoff with a maximum of 120 seconds.

func (*TwitterPostWorker) Timeout

func (w *TwitterPostWorker) Timeout(job *river.Job[TwitterPostArgs]) time.Duration

func (*TwitterPostWorker) Work

func (w *TwitterPostWorker) Work(ctx context.Context, job *river.Job[TwitterPostArgs]) error