push

type MockWorker struct {
	Sub       amsPb.Subscription
	SubStatus string
	// contains filtered or unexported fields
}

type PushError struct {
	ErrMsg  string
	SubName string
}

type Worker interface {
	// Start starts the the push functionality based on the type of the worker
	Start()
	// Stop cancels the push functionality
	Stop()
	// Subscription returns the currently active subscription that is being handled by the worker
	Subscription() *amsPb.Subscription
	// Consumer returns the consumer that the worker is using
	Consumer() consumers.Consumer
	// Status returns the status of the worker
	Status() string
}

type WorkerStatus string