subscriber

Documentation

Index

• type Client
  • func NewSubscriberClient(subName string) (*Client, error)
  • func (c *Client) ReceiveMessageAckAll(ctx context.Context, f func(*prowapi.ReportMessage)) error
• type Operation

Types

type Client

type Client struct {
	Operation
}

Client is a wrapper on the subscriber Operation

func NewSubscriberClient

func NewSubscriberClient(subName string) (*Client, error)

NewSubscriberClient returns a new SubscriberClient used to read crier pubsub messages

func (*Client) ReceiveMessageAckAll

func (c *Client) ReceiveMessageAckAll(ctx context.Context, f func(*prowapi.ReportMessage)) error

ReceiveMessageAckAll acknowledges all incoming pusub messages and convert the pubsub message to ReportMessage. It executes `f` only if the pubsub message can be converted to ReportMessage. Otherwise, ignore the message.

type Operation

type Operation interface {
	Receive(ctx context.Context, f func(context.Context, *pubsub.Message)) error
}

Operation defines a list of methods for subscribing messages