Documentation ¶
Overview ¶
Package app provides an empire.EventStream implementation that publishs events to the app's kinesis stream if available.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.