app

Documentation

Index

• func HTTPMetrics(appName string) echo.MiddlewareFunc
• type App
  • func New(appName string, cfg Config, nc *nats.Conn) *App
  • func (a *App) Run() error
  • func (a *App) Shutdown(timeout time.Duration)
• type Config
• type Message
• type QueueManager
  • func NewQueueManager(js nats.JetStreamContext) *QueueManager
  • func (m *QueueManager) Publish(service string, zenrpcRequest zenrpc.Request, headers http.Header) error

Functions

func HTTPMetrics

func HTTPMetrics(appName string) echo.MiddlewareFunc

HTTPMetrics is the middleware function that logs duration of responses.

Types

type App

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

func New

func New(appName string, cfg Config, nc *nats.Conn) *App

func (*App) Run

func (a *App) Run() error

Run is a function that runs application.

func (*App) Shutdown

func (a *App) Shutdown(timeout time.Duration)

Shutdown is a function that gracefully stops HTTP server.

type Config

type Config struct {
	Server struct {
		Host string
		Port int
	}
	NATS struct {
		URL string
	}
	Settings struct {
		RpcServices []string
	}
}

type Message

type Message struct {
	Request zenrpc.Request `json:"request"`
	Header  http.Header    `json:"header"`
}

type QueueManager

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

func NewQueueManager

func NewQueueManager(js nats.JetStreamContext) *QueueManager

NewQueueManager returns new QueueManager.

func (*QueueManager) Publish

func (m *QueueManager) Publish(service string, zenrpcRequest zenrpc.Request, headers http.Header) error

Publish prepare and publish message to NATs.