publisher

Documentation

Index

• Variables
• func NewPubSubTopic(ctx context.Context, client *pubsub.Client, topicID TopicID) *pubsub.Topic
• type HttpMessageReceiver
• type PubSubPublisher
• type Publisher
  • func NewPublisher(ctx context.Context, inbound HttpMessageReceiver, topic *pubsub.Topic) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, event *cev2.Event) protocol.Result
  • func (p *Publisher) ServeHTTP(response nethttp.ResponseWriter, request *nethttp.Request)
  • func (p *Publisher) Start(ctx context.Context) error
• type TopicID

Variables

var PublisherSet wire.ProviderSet = wire.NewSet(
	NewPublisher,
	clients.NewHTTPMessageReceiver,
	clients.NewPubsubClient,
	NewPubSubTopic,
	wire.Bind(new(HttpMessageReceiver), new(*kncloudevents.HTTPMessageReceiver)),
)

PublisherSet provides a handler with a real HTTPMessageReceiver and a PubSub client.

Functions

func NewPubSubTopic

func NewPubSubTopic(ctx context.Context, client *pubsub.Client, topicID TopicID) *pubsub.Topic

NewPubSubTopic provides a pubsub topic from a PubSub client.

Types

type HttpMessageReceiver

type HttpMessageReceiver interface {
	StartListen(ctx context.Context, handler nethttp.Handler) error
}

HttpMessageReceiver is an interface to listen on http requests.

type PubSubPublisher

type PubSubPublisher interface {
	Publish(ctx context.Context, event cev2.Event) protocol.Result
}

PubSubPublisher is an interface to publish events to a pubsub topic.

type Publisher

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

Publisher receives HTTP events and sends them to Pubsub.

func NewPublisher

func NewPublisher(ctx context.Context, inbound HttpMessageReceiver, topic *pubsub.Topic) *Publisher

NewPublisher creates a new publisher.

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, event *cev2.Event) protocol.Result

Publish publishes an incoming event to a pubsub topic.

func (*Publisher) ServeHTTP

func (p *Publisher) ServeHTTP(response nethttp.ResponseWriter, request *nethttp.Request)

ServeHTTP implements net/http Publisher interface method. 1. Performs basic validation of the request. 2. Converts the request to an event. 3. Sends the event to pubsub.

func (*Publisher) Start

func (p *Publisher) Start(ctx context.Context) error

Start blocks to receive events over HTTP.

type TopicID

type TopicID string