task

Documentation

Overview

Code generated by pubsub generator DO NOT EDIT.

Code generated by pubsub generator DO NOT EDIT.

Index

• func NewPubSubHandler(sub Subscriber) *pubSubHandler
• type Publisher
  • func NewPublisher(pubsubClient infra.Client) Publisher
• type Subscriber
• type Task

Functions

func NewPubSubHandler

func NewPubSubHandler(sub Subscriber) *pubSubHandler

Types

type Publisher

type Publisher interface {
	PublishTask(ctx context.Context, subject *Task) error
}

func NewPublisher

func NewPublisher(pubsubClient infra.Client) Publisher

type Subscriber

type Subscriber interface {
	Run(ctx context.Context, message *Task) error
}

type Task

type Task struct {
	Message string
}