pubsub

Documentation

Index

• type EventSender
  • func NewEventSender(ctx context.Context, projectID, topicName string) (*EventSender, error)
  • func (s *EventSender) Close() error
  • func (s *EventSender) Publish(ctx context.Context, e *event.MetricReading) error

Types

type EventSender

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

EventSender sends events

func NewEventSender

func NewEventSender(ctx context.Context, projectID, topicName string) (*EventSender, error)

NewEventSender creates new EventSender

func (*EventSender) Close

func (s *EventSender) Close() error

Close closes the client connection

func (*EventSender) Publish

func (s *EventSender) Publish(ctx context.Context, e *event.MetricReading) error

Publish sends provied events to GCP PubSub