fakepubsub

Documentation

Index

• type Client
  • func NewClient(projectID, pubsubEmulatorHost string) (*Client, error)
  • func (c *Client) CreateSubscription(ctx context.Context, projectID, topicID, subscriptionID string) error
  • func (c *Client) PublishMessage(ctx context.Context, msg PubSubMessageForSub, topicID string) error
• type PubSubMessageForSub

Types

type Client

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

func NewClient

func NewClient(projectID, pubsubEmulatorHost string) (*Client, error)

func (*Client) CreateSubscription

func (c *Client) CreateSubscription(ctx context.Context, projectID, topicID, subscriptionID string) error

CreateSubscription creates a Pub/Sub topic and a corresponding subscription.

func (*Client) PublishMessage

func (c *Client) PublishMessage(ctx context.Context, msg PubSubMessageForSub, topicID string) error

PublishMessage creates a Pub/Sub message that sub understands (to create a ProwJob). The podName parameter is used by the integration tests; specifically, each test case invocation generates a UUID which is used as the name of the ProwJob CR. Then when the test pod is created, it is also named with the same UUID. This makes checking for the creation of jobs and pods very easy in the tests.

type PubSubMessageForSub

type PubSubMessageForSub struct {
	Attributes map[string]string
	Data       subscriber.ProwJobEvent
}