astrolib

type AQueue interface {
	QueueRequest(r *AReq) (*ARes, error)
	GetRequest(name string) (*AReq, error)
}

type AReq struct {
	ID        string `json:"id"`
	QueueName string `json:"-"`
	Body      []byte `json:"originalRequest"`
	Response  *ARes  `json:"-"`
}

type ARes struct {
	ID           string
	ResponseChan chan ([]byte)
	ErrorChan    chan (error)
}

type RequestQueue struct {
	Queues map[string]chan (*AReq)
}

type ResponseMap struct {
	Responses map[string]chan ([]byte)
	Errors    map[string]chan (error)
}