pubsub

Documentation

Index

• type Pubsub
  • func New(ps pubsub.PubSub, topic string) *Pubsub
  • func (p *Pubsub) PublishParseAgency(ctx context.Context, data entity.ParseAgencyRequest) error
  • func (p *Pubsub) PublishParseVtuber(ctx context.Context, data entity.ParseVtuberRequest) 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) PublishParseAgency

func (p *Pubsub) PublishParseAgency(ctx context.Context, data entity.ParseAgencyRequest) error

PublishParseAgency to publish parse agency.

func (*Pubsub) PublishParseVtuber

func (p *Pubsub) PublishParseVtuber(ctx context.Context, data entity.ParseVtuberRequest) error

PublishParseVtuber to publish parse vtuber.