fleet/server/pubsub/errors.go

// Package pubsub implements pub/sub interfaces defined in package fleet.
package pubsub

// Error defines the interface of errors specific to the pubsub package
type Error interface {
	error
	// NoSubscriber returns true if the error occurred because there are no
	// subscribers on the channel
	NoSubscriber() bool
}

// NoSubscriberError can be returned when channel operations fail because there
// are no subscribers. Its NoSubscriber() method always returns true.
type noSubscriberError struct {
	Channel string
}

func (e noSubscriberError) Error() string {
	return "no subscriber for channel " + e.Channel
}

func (e noSubscriberError) NoSubscriber() bool {
	return true
}