httpserver

Dec 1, 2023

Changes in this version

type EventItem

+ AppName string

+ Channel string

+ Done bool

+ HandlerName string

+ MessageId string

Nov 28, 2023

Changes in this version

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

+ type Event map[string](interface{})

+ type EventItem struct

+ Event Event

+ SequenceId string

+ Timestamp time.Time

+ type EventLog struct

+ EndTimestamp time.Time

+ EventItems []EventItem

+ StartTimestamp time.Time

+ type EventsClient interface

+ GetEventHistory func(ctx context.Context, start time.Time) ([]*nats.MsgMeta, error)

type NatsClient

+ GetEventHistory func(context.Context, time.Time) ([]*nats.MsgMeta, error)

Nov 14, 2023

Changes in this version

+ type NatsClient interface

+ CheckConnection func() bool

+ Publish func(context.Context, []byte, ...string) (*jetstream.PubAck, bool, error)

Oct 21, 2023

Changes in this version

+ func ConsoleRouter(logger zerolog.Logger) chi.Router

+ func Healthcheck(natsConnection *nats.Conn, endpoint string) func(http.Handler) http.Handler

+ func Serve(appdirs setup.AppDirs, addr string, hopsFilePath string, ...) error

+ func TaskRouter(taskHops taskReader, lease leasePublisher, logger zerolog.Logger) chi.Router