controllers

type AppData struct {
	SeedData  *config.SeedData
	AppStatus data.AppStatus
}

type BroadcastController struct {
	MessageRepository  storage.MessageRepository
	ChannelRepository  storage.ChannelRepository
	ProducerRepository storage.ProducerRepository
	Dispatcher         dispatcher.MessageDispatcher
}

type ChannelController struct {
	ChannelRepo            storage.ChannelRepository
	ConsumersEndpoint      EndpointController
	MessagesEndpoint       EndpointController
	BroadcastEndpoint      EndpointController
	MessagesStatusEndpoint EndpointController
}

type ChannelModel struct {
	MsgStakeholder
	ConsumersURL      string
	MessagesURL       string
	BroadcastURL      string
	MessagesStatusURL string
}

type ChannelsController struct {
	ChannelRepo     storage.ChannelRepository
	ChannelEndpoint EndpointController
}

type ConsumerController struct {
	ConsumerRepo storage.ConsumerRepository
	ChannelRepo  storage.ChannelRepository
	DLQEndpoint  EndpointController
}

type ConsumerModel struct {
	MsgStakeholder
	CallbackURL        string
	DeadLetterQueueURL string
	Type               string
}

type ConsumersController struct {
	ConsumerRepo     storage.ConsumerRepository
	ConsumerEndpoint EndpointController
}

type Controllers struct {
	StatusController         *StatusController
	ProducersController      *ProducersController
	ProducerController       *ProducerController
	ChannelController        *ChannelController
	ChannelsController       *ChannelsController
	ConsumerController       *ConsumerController
	ConsumersController      *ConsumersController
	JobsController           *JobsController
	JobController            *JobController
	BroadcastController      *BroadcastController
	MessageController        *MessageController
	MessagesController       *MessagesController
	DLQController            *DLQController
	MessagesStatusController *MessagesStatusController
	JobRequeueController     *JobRequeueController
	JobStatusController      *JobStatusController
	MetricsHandler           http.Handler
}

type DLQController struct {
	MessageController    EndpointController
	DeliveryJobRepo      storage.DeliveryJobRepository
	ConsumerRepo         storage.ConsumerRepository
	JobRequeueController EndpointController
}

type DLQList struct {
	DeadJobs []*DeadDeliveryJobModel
	Pages    map[string]string
}

type DeadDeliveryJobModel struct {
	DeliveryJobModel
	MessageURL    string
	JobRequeueURL string
}

type Delete interface {
	Delete(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
}

type DeliveryJobModel struct {
	ListenerEndpoint string
	ListenerName     string
	Status           string
	StatusChangedAt  time.Time
}

type EndpointController interface {
	GetPath() string
	FormatAsRelativeLink(params ...httprouter.Param) string
}

type Get interface {
	Get(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
}

type HyperlinkedDeliveryJobModel struct {
	DeliveryJobModel
	MessageURL    string
	ChannelURL    string
	ConsumerURL   string
	ProducerURL   string
	JobRequeueURL string
}

type JobController struct {
	MsgController      EndpointController
	ChannelController  EndpointController
	ProducerController EndpointController
	ConsumerController EndpointController
	ChannelRepo        storage.ChannelRepository
	ConsumerRepo       storage.ConsumerRepository
	DeliveryJobRepo    storage.DeliveryJobRepository
}

type JobListResult struct {
	Result []*QueuedDeliveryJobModel
}

type JobRequeueController struct {
	DeliveryJobRepo storage.DeliveryJobRepository
	ChannelRepo     storage.ChannelRepository
	ConsumerRepo    storage.ConsumerRepository
}

type JobStatusController struct {
	DeliveryJobRepo storage.DeliveryJobRepository
}

type JobsController struct {
	ChannelRepo     storage.ChannelRepository
	ConsumerRepo    storage.ConsumerRepository
	DeliveryJobRepo storage.DeliveryJobRepository
}

type ListResult struct {
	Result []string
	Pages  map[string]string
	Links  map[string]string
}

type MessageController struct {
	MessageRepo     storage.MessageRepository
	DeliveryJobRepo storage.DeliveryJobRepository
}

type MessageModel struct {
	ID           string
	Payload      string
	ContentType  string
	ProducedBy   string
	ReceivedAt   time.Time
	DispatchedAt time.Time
	Status       string
	Jobs         []*DeliveryJobModel
	Headers      data.HeadersMap
}

type MessagesController struct {
	MessageController EndpointController
	MessageRepo       storage.MessageRepository
}

type MessagesStatusController struct {
	MessagesController EndpointController
	MessageRepo        storage.MessageRepository
}

type MsgStakeholder struct {
	ID        string
	Name      string
	Token     string
	ChangedAt time.Time
}

type Post interface {
	Post(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
}

type ProducerController struct {
	ProducerRepo storage.ProducerRepository
}

type ProducersController struct {
	ProducerRepo     storage.ProducerRepository
	ProducerEndpoint EndpointController
}

type Put interface {
	Put(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
}

type QeuedMessageModel struct {
	MessageID   string
	Payload     string
	Headers     data.HeadersMap
	ContentType string
}

type QueuedDeliveryJobModel struct {
	ID                 xid.ID
	Priority           uint
	IncrementalTimeout uint // in second
	Message            *QeuedMessageModel
}

type ServerLifecycleListener interface {
	StartingServer()
	ServerStartFailed(err error)
	ServerShutdownCompleted()
}

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

type StatusCount struct {
	Counts map[string]TheCount
}

type TheCount struct {
	Count int
	Links map[string]string
}