golaze

type App struct {
	*AppConfig
}

type AppConfig struct {
	Name        string
	Version     string
	LogLevel    zerolog.Level
	HealthCheck *HealthCheck
	WebApp      *WebApp
	Worker      *Worker
}

type AuthToken struct {
	Token string
}

type Event struct {
	Data interface{}
}

type EventBus struct {
	*EventBusConfig
}

type EventBusConfig struct {
	Subscribers map[string][]EventBusHandler
	Shutdown    chan bool
	// contains filtered or unexported fields
}

type EventBusHandler interface {
	Handle(event *Event) error
}

type HealthCheck struct {
	*HealthCheckConfig
}

type HealthCheckConfig struct {
	Port           string
	LivenessHooks  []func() error
	ReadinessHooks []func() error
	Router         *chi.Mux
}

type State struct {
	Data map[string]interface{}
	// contains filtered or unexported fields
}

type Task struct {
	*TaskConfig
}

type TaskConfig struct {
	Name          string
	Exec          func(state *State) error
	MaxRetries    int
	RetryInterval time.Duration
	Repeat        int // -1 for infinite, 0 for no repeat, > 0 for n times
	RepeatDelay   time.Duration
	Timeout       time.Duration
	RunHistory    []time.Time

	Done chan bool
}

type WebApp struct {
	*WebAppConfig
}

type WebAppConfig struct {
	Port   string
	Router *chi.Mux
}

type Worker struct {
	*WorkerConfig
}

type WorkerConfig struct {
	Tasks           []*Task
	Shutdown        chan bool
	State           *State
	ConcurrentTasks int
	// contains filtered or unexported fields
}