app

Documentation

Overview

Package app provides an empire.EventStream implementation that publishs events to the app's kinesis stream if available.

Index

• type EventStream
  • func NewEventStream(c client.ConfigProvider) *EventStream
  • func (s *EventStream) PublishEvent(event empire.Event) error

Types

type EventStream

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

EventStream is an implementation of the empire.EventStream interface backed by Kinesis.

func NewEventStream

func NewEventStream(c client.ConfigProvider) *EventStream

func (*EventStream) PublishEvent

func (s *EventStream) PublishEvent(event empire.Event) error