utils

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

type MessageBus interface {
	Subscribe(ctx context.Context, channel string) (PubSub, error)
	// like subscribe, but ensuring only a single instance gets to process the message
	SubscribeQueue(ctx context.Context, channel string) (PubSub, error)
	Publish(ctx context.Context, channel string, msg proto.Message) error
}

type PubSub interface {
	Channel() <-chan interface{}
	Payload(msg interface{}) []byte
	Close() error
}

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

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