pubsub

Documentation

Overview

Package pubsub handles interactions with PubSub framework.

Index

• Variables
• type Publisher
  • func CreatePublisher(ctx context.Context, topicURL string) (Publisher, error)
• type Subscriber
  • func CreateSubscriber(ctx context.Context, subscriptionURL string) (Subscriber, error)

Variables

var ErrorInParse = errors.New("error during protojson.Unmarshal")

ErrorInParse indicates there was an error while unmarshalling the protocol buffer message.

Types

type Publisher

type Publisher interface {
	Publish(request *data.ScorecardBatchRequest) error
	Close() error
}

Publisher interface is used to publish cron job requests to PubSub.

func CreatePublisher

func CreatePublisher(ctx context.Context, topicURL string) (Publisher, error)

CreatePublisher returns an implementation of the Publisher interface.

type Subscriber

type Subscriber interface {
	SynchronousPull() (*data.ScorecardBatchRequest, error)
	Ack()
	Nack()
	Close() error
}

Subscriber interface is used pull messages from PubSub.

func CreateSubscriber

func CreateSubscriber(ctx context.Context, subscriptionURL string) (Subscriber, error)

CreateSubscriber returns an implementation of Subscriber interface. Currently returns an instance of gcsSubscriber.