httpserver

Documentation

Index

• func ConsoleRouter(logger zerolog.Logger) chi.Router
• func EventRouter(eventsClient EventsClient, logger zerolog.Logger) chi.Router
• func Healthcheck(natsClient NatsClient, endpoint string) func(http.Handler) http.Handler
• func Serve(addr string, hopsContent *hcl.BodyContent, natsClient NatsClient, ...) error
• func TaskRouter(taskHops taskReader, natsClient NatsClient, logger zerolog.Logger) chi.Router
• type Event
• type EventItem
• type EventLog
• type EventsClient
• type NatsClient

Functions

func ConsoleRouter

func ConsoleRouter(logger zerolog.Logger) chi.Router

The console router serves the single page app for the console. It will serve the index.html file for any path that does not exist, allowing client-side to handle routing

func EventRouter

func EventRouter(eventsClient EventsClient, logger zerolog.Logger) chi.Router

func Healthcheck

func Healthcheck(natsClient NatsClient, endpoint string) func(http.Handler) http.Handler

func Serve

func Serve(addr string, hopsContent *hcl.BodyContent, natsClient NatsClient, logger zerolog.Logger) error

func TaskRouter

func TaskRouter(taskHops taskReader, natsClient NatsClient, logger zerolog.Logger) chi.Router

Types

type Event

type Event interface{}

Event is arbitrary json struct of event

type EventItem

type EventItem struct {
	Event       Event     `json:"event"`
	SequenceId  string    `json:"sequence_id"`
	Timestamp   time.Time `json:"timestamp"`
	AppName     string    `json:"app_name"`
	Channel     string    `json:"channel"`
	Done        bool      `json:"done"`
	HandlerName string    `json:"handler_name"`
	MessageId   string    `json:"message_id"`
}

EventItem includes metadata for /events api endpoint

type EventLog

type EventLog struct {
	StartTimestamp time.Time   `json:"start_timestamp"`
	EndTimestamp   time.Time   `json:"end_timestamp"`
	EventItems     []EventItem `json:"event_items"`
}

EventLog is a list of events with search start and search end timestamps

type EventsClient

type EventsClient interface {
	GetEventHistory(ctx context.Context, start time.Time, sourceOnly bool) ([]*nats.MsgMeta, error)
}

type NatsClient

type NatsClient interface {
	Publish(context.Context, []byte, ...string) (*jetstream.PubAck, bool, error)
	CheckConnection() bool
	GetEventHistory(context.Context, time.Time, bool) ([]*nats.MsgMeta, error)
}