service

Documentation

Index

• func NewServer() *gin.Engine
• type AmqpDispatcher
  • func NewAmqpDispatcher(publishChanel queuePublishableChanel, queueName string, mandatorySend bool) *AmqpDispatcher
  • func (q *AmqpDispatcher) DispatchMessage(message interface{}) (err error)
• type Handlers
  • func NewHandlers(dispatch queueDispatcher) *Handlers
  • func (h *Handlers) AddAlertCommand(ctx *gin.Context)
  • func (h *Handlers) AddPositionCommand(ctx *gin.Context)
  • func (h *Handlers) AddTelemetryCommand(ctx *gin.Context)
• type Repository
  • func NewRepository() (*Repository, error)
  • func (r *Repository) UpdateLastAlertEvent(event common.AlertSignalledEvent) (err error)
  • func (r *Repository) UpdateLastPositionEvent(event common.PositionChangedEvent) (err error)
  • func (r *Repository) UpdateLastTelemetryEvent(event common.TelemetryUpdatedEvent) (err error)

Functions

func NewServer

func NewServer() *gin.Engine

Types

type AmqpDispatcher

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

func NewAmqpDispatcher

func NewAmqpDispatcher(publishChanel queuePublishableChanel, queueName string, mandatorySend bool) *AmqpDispatcher

func (*AmqpDispatcher) DispatchMessage

func (q *AmqpDispatcher) DispatchMessage(message interface{}) (err error)

type Handlers

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

func NewHandlers

func NewHandlers(dispatch queueDispatcher) *Handlers

func (*Handlers) AddAlertCommand

func (h *Handlers) AddAlertCommand(ctx *gin.Context)

func (*Handlers) AddPositionCommand

func (h *Handlers) AddPositionCommand(ctx *gin.Context)

func (*Handlers) AddTelemetryCommand

func (h *Handlers) AddTelemetryCommand(ctx *gin.Context)

type Repository

type Repository struct {
	Client *mongo.Client
}

func NewRepository

func NewRepository() (*Repository, error)

func (*Repository) UpdateLastAlertEvent

func (r *Repository) UpdateLastAlertEvent(event common.AlertSignalledEvent) (err error)

func (*Repository) UpdateLastPositionEvent

func (r *Repository) UpdateLastPositionEvent(event common.PositionChangedEvent) (err error)

func (*Repository) UpdateLastTelemetryEvent

func (r *Repository) UpdateLastTelemetryEvent(event common.TelemetryUpdatedEvent) (err error)