Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controllers

package

Go to main page

Versions in this module

v0

v0.1.2

Jan 22, 2022

v0.1.1

Jun 22, 2021

v0.1.0

Mar 30, 2021

Changes in this version

+ var ControllerInjector = wire.NewSet(ConfigureAPI, NewRouter, NewStatusController, NewProducersController, ...)

+ var ErrBadRequest = errors.New("Bad Request: Update is missing `If-Unmodified-Since` header ")

+ var ErrBadRequestForRequeue = errors.New("`requeue` form param must match consumer token")

+ var ErrConditionalFailed = errors.New("Update failed due to mismatch of `If-Unmodified-Since` header value")

+ var ErrNotFound = errors.New("Request resource not found")

+ var ErrUnsupportedMediaType = errors.New("Media type not supported")

+ var NotifyOnInterrupt = func(stop *chan os.Signal)

+ func ConfigureAPI(httpConfig config.HTTPConfig, iListener ServerLifecycleListener, ...) *http.Server

+ func NewRouter(controllers *Controllers) *httprouter.Router

+ type AppData struct

+ AppStatus data.AppStatus

+ SeedData *config.SeedData

+ type BroadcastController struct

+ ChannelRepository storage.ChannelRepository

+ Dispatcher dispatcher.MessageDispatcher

+ MessageRepository storage.MessageRepository

+ ProducerRepository storage.ProducerRepository

+ func NewBroadcastController(channelRepo storage.ChannelRepository, msgRepo storage.MessageRepository, ...) *BroadcastController

+ func (broadcastController *BroadcastController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (broadcastController *BroadcastController) GetPath() string

+ func (broadcastController *BroadcastController) Post(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ type ChannelController struct

+ BroadcastEndpoint EndpointController

+ ChannelRepo storage.ChannelRepository

+ ConsumersEndpoint EndpointController

+ MessagesEndpoint EndpointController

+ func NewChannelController(consumersController *ConsumersController, ...) *ChannelController

+ func (channelController *ChannelController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (channelController *ChannelController) Get(w http.ResponseWriter, r *http.Request, param httprouter.Params)

+ func (channelController *ChannelController) GetPath() string

+ func (channelController *ChannelController) Put(w http.ResponseWriter, r *http.Request, param httprouter.Params)

+ type ChannelModel struct

+ BroadcastURL string

+ ConsumersURL string

+ MessagesURL string

+ type ChannelsController struct

+ ChannelEndpoint EndpointController

+ ChannelRepo storage.ChannelRepository

+ func NewChannelsController(channelRepo storage.ChannelRepository, channelController *ChannelController) *ChannelsController

+ func (channelsController *ChannelsController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (channelsController *ChannelsController) Get(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

+ func (channelsController *ChannelsController) GetPath() string

+ type ConsumerController struct

+ ChannelRepo storage.ChannelRepository

+ ConsumerRepo storage.ConsumerRepository

+ DLQEndpoint EndpointController

+ func NewConsumerController(channelRepo storage.ChannelRepository, consumerRepo storage.ConsumerRepository, ...) *ConsumerController

+ func (controller *ConsumerController) Delete(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ func (controller *ConsumerController) FormatAsRelativeLink(params ...httprouter.Param) (result string)

+ func (controller *ConsumerController) Get(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ func (controller *ConsumerController) GetPath() string

+ func (controller *ConsumerController) Put(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ type ConsumerModel struct

+ CallbackURL string

+ DeadLetterQueueURL string

+ type ConsumersController struct

+ ConsumerEndpoint EndpointController

+ ConsumerRepo storage.ConsumerRepository

+ func NewConsumersController(consumerEndpoint *ConsumerController, consumerRepo storage.ConsumerRepository) *ConsumersController

+ func (controller *ConsumersController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (controller *ConsumersController) Get(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ func (controller *ConsumersController) GetPath() string

+ type Controllers struct

+ BroadcastController *BroadcastController

+ ChannelController *ChannelController

+ ChannelsController *ChannelsController

+ ConsumerController *ConsumerController

+ ConsumersController *ConsumersController

+ DLQController *DLQController

+ MessageController *MessageController

+ MessagesController *MessagesController

+ ProducerController *ProducerController

+ ProducersController *ProducersController

+ StatusController *StatusController

+ type DLQController struct

+ ConsumerRepo storage.ConsumerRepository

+ DeliveryJobRepo storage.DeliveryJobRepository

+ MessageController EndpointController

+ func NewDLQController(msgController *MessageController, djRepo storage.DeliveryJobRepository, ...) *DLQController

+ func (controller *DLQController) FormatAsRelativeLink(params ...httprouter.Param) (result string)

+ func (controller *DLQController) Get(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ func (controller *DLQController) GetPath() string

+ func (controller *DLQController) Post(w http.ResponseWriter, r *http.Request, params httprouter.Params)

+ type DLQList struct

+ DeadJobs []*DeadDeliveryJobModel

+ Pages map[string]string

+ type DeadDeliveryJobModel struct

+ MessageURL string

+ type Delete interface

+ Delete func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type DeliveryJobModel struct

+ ListenerEndpoint string

+ ListenerName string

+ Status string

+ StatusChangedAt time.Time

+ type EndpointController interface

+ FormatAsRelativeLink func(params ...httprouter.Param) string

+ GetPath func() string

+ type Get interface

+ Get func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type ListResult struct

+ Links map[string]string

+ Pages map[string]string

+ Result []string

+ type MessageController struct

+ DeliveryJobRepo storage.DeliveryJobRepository

+ MessageRepo storage.MessageRepository

+ func NewMessageController(msgRepo storage.MessageRepository, djRepo storage.DeliveryJobRepository) *MessageController

+ func (messageController *MessageController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (messageController *MessageController) Get(w http.ResponseWriter, r *http.Request, param httprouter.Params)

+ func (messageController *MessageController) GetPath() string

+ type MessageModel struct

+ ContentType string

+ DispatchedAt time.Time

+ Jobs []*DeliveryJobModel

+ Payload string

+ ProducedBy string

+ ReceivedAt time.Time

+ Status string

+ type MessagesController struct

+ MessageController EndpointController

+ MessageRepo storage.MessageRepository

+ func NewMessagesController(msgController *MessageController, msgRepo storage.MessageRepository) *MessagesController

+ func (messagesController *MessagesController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (messagesController *MessagesController) Get(w http.ResponseWriter, r *http.Request, param httprouter.Params)

+ func (messagesController *MessagesController) GetPath() string

+ type MsgStakeholder struct

+ ChangedAt time.Time

+ ID string

+ Name string

+ Token string

+ func (stakeholder *MsgStakeholder) GetLastUpdatedHTTPTimeString() string

+ type Post interface

+ Post func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type ProducerController struct

+ ProducerRepo storage.ProducerRepository

+ func NewProducerController(producerRepo storage.ProducerRepository) *ProducerController

+ func (prodController *ProducerController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (prodController *ProducerController) Get(w http.ResponseWriter, r *http.Request, param httprouter.Params)

+ func (prodController *ProducerController) GetPath() string

+ func (prodController *ProducerController) Put(w http.ResponseWriter, r *http.Request, param httprouter.Params)

+ type ProducersController struct

+ ProducerEndpoint EndpointController

+ ProducerRepo storage.ProducerRepository

+ func NewProducersController(producerRepo storage.ProducerRepository, ...) *ProducersController

+ func (prodController *ProducersController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (prodController *ProducersController) Get(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

+ func (prodController *ProducersController) GetPath() string

+ type Put interface

+ Put func(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type ServerLifecycleListener interface

+ ServerShutdownCompleted func()

+ ServerStartFailed func(err error)

+ StartingServer func()

+ type StatusController struct

+ func NewStatusController(appRepo storage.AppRepository) *StatusController

+ func (cont *StatusController) FormatAsRelativeLink(params ...httprouter.Param) string

+ func (cont *StatusController) Get(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

+ func (cont *StatusController) GetPath() string

v0.1.0-release-test-v3

Mar 30, 2021

v0.1.0-release-test-v2

Jan 26, 2021

v0.1.0-beta-3

Mar 22, 2021

v0.1.0-beta-2

Feb 9, 2021

v0.1.0-beta-1

Jan 21, 2021