hops

Mar 18, 2024

Changes in this version

+ const AutomationsHashKey

+ type AutomationsLoader struct

+ func NewAutomationsLoader(path string, tolerant bool, natsClient *nats.Client, logger zerolog.Logger) (*AutomationsLoader, error)

+ func (al *AutomationsLoader) Get(hash string) (*dsl.Automations, error)

+ func (al *AutomationsLoader) GetForSequence(ctx context.Context, sequenceID string, msgBundle nats.MessageBundle) (*dsl.Automations, error)

+ func (al *AutomationsLoader) GetFromCache(hash string) *dsl.Automations

+ func (al *AutomationsLoader) GetFromStore(hash string) (*dsl.Automations, error)

+ func (al *AutomationsLoader) GetOrSetHashForSequence(ctx context.Context, sequenceID string, msgBundle nats.MessageBundle) (string, error)

+ func (al *AutomationsLoader) Reload(ctx context.Context, tolerant bool) error

+ func (al *AutomationsLoader) Save() error

+ func (al *AutomationsLoader) SaveInCache(a *dsl.Automations, ttl time.Duration)

+ func (al *AutomationsLoader) SaveInStore(a *dsl.Automations) error

Feb 5, 2024

Changes in this version

type RunnerConf

+ Local bool

Jan 12, 2024

Changes in this version

+ type ErrFailedHopsParse struct

+ func (e ErrFailedHopsParse) Error() string

Jan 10, 2024

Changes in this version

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

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

+ func Healthcheck(natsClient *nats.Client, endpoint string) func(http.Handler) http.Handler

+ type DirNotifier struct

+ func NewDirNotifier(path string) (*DirNotifier, error)

+ func (d *DirNotifier) Close() error

+ func (d *DirNotifier) Notifier() reload.Notifier

+ type Event interface

+ type EventItem struct

+ AppName string

+ Channel string

+ Done bool

+ Event Event

+ HandlerName string

+ MessageId string

+ 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, sourceOnly bool) ([]*nats.MsgMeta, error)

+ type HTTPAppConf struct

+ Serve bool

+ type HTTPServer struct

+ func NewHTTPServer(addr string, hopsFileLoader *HopsFileLoader, natsClient *nats.Client, ...) (*HTTPServer, error)

+ func (h *HTTPServer) Reload(ctx context.Context) error

+ func (h *HTTPServer) Serve() error

+ func (h *HTTPServer) Shutdown(ctx context.Context) error

+ type HTTPServerConf struct

+ Address string

+ Serve bool

+ type HopsFileLoader struct

+ func NewHopsFileLoader(path string) (*HopsFileLoader, error)

+ func (h *HopsFileLoader) Get() (*dsl.HopsFiles, error)

+ func (h *HopsFileLoader) Reload(ctx context.Context) error

type HopsServer

+ Watch bool

+ type K8sAppConf struct

+ KubeConfig string

+ PortForward bool

+ Serve bool

type Runner

+ func NewRunner(natsClient *nats.Client, hopsFileLoader *HopsFileLoader, logger zerolog.Logger) (*Runner, error)

+ func (r *Runner) Reload(ctx context.Context) error

+ func (r *Runner) Run(ctx context.Context, fromConsumer string) error

+ func (r *Runner) SequenceCallback(ctx context.Context, sequenceId string, msgBundle nats.MessageBundle) error

+ type RunnerConf struct

+ Serve bool

+ type Schedule struct

+ Config dsl.ScheduleAST

+ CronSchedule cron.Schedule

+ func NewSchedule(config dsl.ScheduleAST, natsClient *nats.Client, logger zerolog.Logger) (*Schedule, error)

+ func (s *Schedule) Run()

Dec 13, 2023

Changes in this version

+ type HTTPApp struct

+ Serve bool

Dec 10, 2023

Changes in this version

+ const ServeConsoleOpt

+ const ServeK8sAppOpt

+ const ServeRunnerOpt

+ type Console struct

+ Address string

+ Serve bool

+ type HopsServer struct

+ HopsPath string

+ KeyFilePath string

+ Logger zerolog.Logger

+ ReplayEvent string

+ func (h *HopsServer) Start(ctx context.Context) error

+ type K8sApp struct

+ KubeConfig string

+ PortForward bool

+ Serve bool

+ type Runner struct

+ Serve bool