protocol

type DeleteMessage struct {
	Key   string
	Queue string
	ID    string
}

type ErrUnknownType error

type ErrorMessage struct {
	Key    string
	Reason string
}

type JobMessage struct {
	Key       string
	ID        string
	Queue     string
	Priority  float64
	HoldUntil int64
	TTR       uint64
	Content   string
}

type Message interface {
	GetKey() string
	SetKey(key string)
	Serialise() []byte
}

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

type PeekMessage struct {
	Key   string
	Queue string
}

type PingMessage struct {
	Key string
}

type ReserveMessage struct {
	Key   string
	Queue string
}

type SuccessMessage struct {
	Key string
}