pubsub

Documentation

Index

• type Pubsub
  • func New(ps pubsub.PubSub, topic string) *Pubsub
  • func (p *Pubsub) PublishParseManga(ctx context.Context, data entity.ParseMangaRequest) error
  • func (p *Pubsub) PublishParseUserManga(ctx context.Context, data entity.ParseUserMangaRequest) error

Types

type Pubsub

type Pubsub struct {
	// contains filtered or unexported fields
}

Pubsub contains functions for pubsub.

func New

func New(ps pubsub.PubSub, topic string) *Pubsub

New to create new pubsub.

func (*Pubsub) PublishParseManga

func (p *Pubsub) PublishParseManga(ctx context.Context, data entity.ParseMangaRequest) error

PublishParseManga to publish parse manga.

func (*Pubsub) PublishParseUserManga

func (p *Pubsub) PublishParseUserManga(ctx context.Context, data entity.ParseUserMangaRequest) error

PublishParseUserManga to publish parse user manga.