dependencies

Documentation

Index

• Variables
• func NewExecutors(logger *log.Logger) executors.ScheduledExecutor
• func NewHttpClient(params NewHttpClientParams) *httpclient.HttpClient
• type ErrorHandler
  • func (h *ErrorHandler) CatchError(runnable executors.Runnable, err error)
• type NewHttpClientParams
• type RejectionHandler
  • func (h *RejectionHandler) RejectExecution(runnable executors.Runnable, e executors.Executor) error

Variables

var Module = fx.Module("dependencies",
	fx.Provide(log.New),
	fx.Provide(db.NewEntClient),
	fx.Provide(NewHttpClient),
	fx.Provide(NewExecutors),
	fx.Invoke(func(lc fx.Lifecycle, executor executors.ScheduledExecutor) {
		lc.Append(fx.Hook{
			OnStop: func(ctx context.Context) error {
				return executor.Shutdown(ctx)
			},
		})
	}),
)

Functions

func NewExecutors

func NewExecutors(logger *log.Logger) executors.ScheduledExecutor

func NewHttpClient

func NewHttpClient(params NewHttpClientParams) *httpclient.HttpClient

Types

type ErrorHandler

type ErrorHandler struct{}

func (*ErrorHandler) CatchError

func (h *ErrorHandler) CatchError(runnable executors.Runnable, err error)

type NewHttpClientParams

type NewHttpClientParams struct {
	fx.In

	DisableSSLVerify bool `name:"disable_ssl_verify"`
}

type RejectionHandler

type RejectionHandler struct{}

func (*RejectionHandler) RejectExecution

func (h *RejectionHandler) RejectExecution(runnable executors.Runnable, e executors.Executor) error