Documentation
¶
Index ¶
- func NewCronComponent(cron *gocron.Scheduler) *cronComponent
- func NewHealthzComponent(providers []healthz.Provider, config config.HealthzConfig) *healthzComponent
- func NewLifecycleComponent(startups []LifeCycleFunc, run LifeCycleFunc, cleanups []LifeCycleFunc) *lifecycleComponent
- func NewMetriczComponent(registry *prometheus.Registry, config config.MetricszConfig) *metriczComponent
- func NewQueueComponent(handlers []QueueHandler, options ...queueComponentOption) *queueComponent
- func WithHttpServer(httpServer *http.Server) httpComponentOption
- func WithQueueClose(close func(ctx context.Context) error) queueComponentOption
- func WithServerConfig(serverConfig *config.ServerConfig) httpComponentOption
- type GrpcComponent
- type HttpComponent
- type LifeCycleFunc
- type QueueHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCronComponent ¶
func NewHealthzComponent ¶
func NewHealthzComponent(providers []healthz.Provider, config config.HealthzConfig) *healthzComponent
func NewLifecycleComponent ¶
func NewLifecycleComponent(startups []LifeCycleFunc, run LifeCycleFunc, cleanups []LifeCycleFunc) *lifecycleComponent
func NewMetriczComponent ¶
func NewMetriczComponent(registry *prometheus.Registry, config config.MetricszConfig) *metriczComponent
func NewQueueComponent ¶
func NewQueueComponent(handlers []QueueHandler, options ...queueComponentOption) *queueComponent
func WithHttpServer ¶
func WithQueueClose ¶
func WithServerConfig ¶
func WithServerConfig(serverConfig *config.ServerConfig) httpComponentOption
Types ¶
type GrpcComponent ¶ added in v0.1.2
type GrpcComponent struct {
// contains filtered or unexported fields
}
func NewGrpcComponent ¶ added in v0.1.2
func NewGrpcComponent(server *grpc.Server, lis net.Listener) *GrpcComponent
func (*GrpcComponent) Close ¶ added in v0.1.2
func (gc *GrpcComponent) Close(ctx context.Context) error
func (*GrpcComponent) Run ¶ added in v0.1.2
func (gc *GrpcComponent) Run() error
func (*GrpcComponent) Startup ¶ added in v0.1.2
func (gc *GrpcComponent) Startup() error
type HttpComponent ¶
type HttpComponent struct {
// contains filtered or unexported fields
}
func NewHttpComponent ¶
func NewHttpComponent(handler http.Handler, options ...httpComponentOption) *HttpComponent
func (*HttpComponent) GetHandler ¶
func (hc *HttpComponent) GetHandler(t testing.TB) http.Handler
This is just for testing
func (*HttpComponent) Run ¶
func (hc *HttpComponent) Run() error
func (*HttpComponent) Startup ¶
func (hc *HttpComponent) Startup() error
type LifeCycleFunc ¶
type QueueHandler ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.