pubsub

type EventHandler interface {
	// Handle runs the logic to handle the event as appropriate for the event
	// Returns a bool whether the event was handled and an error if occurred
	Handle(event []byte) (bool, error)
	// Name returns a readable name for this particular event handler
	Name() string
}

type GooglePubSub struct {
	SubscribeChan    chan *pubsub.Message
	SubscribeErrChan chan error
	// contains filtered or unexported fields
}

type GooglePubSubMsg struct {
	Topic   string
	Payload string
}

type SubscribeConfig struct {
	Name    string
	AutoAck bool
}

type Workers struct {
	Errors chan error
	// contains filtered or unexported fields
}

type WorkersConfig struct {
	PubSubProjectID        string
	PubSubTopicName        string
	PubSubSubscriptionName string
	NumWorkers             int
	QuitChan               chan struct{}
	EventHandlers          []EventHandler
}