Documentation
¶
Index ¶
- type App
- func (app *App) HandleIngest(w http.ResponseWriter, r *http.Request)
- func (app *App) HandleMetrics(w http.ResponseWriter, r *http.Request)
- func (app *App) HandleTransform(w http.ResponseWriter, r *http.Request)
- func (app *App) WriteJSONErr(w http.ResponseWriter, statusCode int, reqID string, err error)
- func (app *App) WriteJSONResponse(w http.ResponseWriter, statusCode int, resp any)
- type AppOpt
- func WithInhooksConfigService(inhooksConfigSvc services.InhooksConfigService) AppOpt
- func WithLogger(logger *zap.Logger) AppOpt
- func WithMessageBuilder(messageBuilder services.MessageBuilder) AppOpt
- func WithMessageEnqueuer(messageEnqueuer services.MessageEnqueuer) AppOpt
- func WithMessageTransformer(messageTransformer services.MessageTransformer) AppOpt
- func WithMessageVerifier(messageVerifier services.MessageVerifier) AppOpt
- type JSONErr
- type JSONOK
- type TransformRequest
- type TransformResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
func (*App) HandleIngest ¶
func (app *App) HandleIngest(w http.ResponseWriter, r *http.Request)
func (*App) HandleMetrics ¶ added in v0.1.8
func (app *App) HandleMetrics(w http.ResponseWriter, r *http.Request)
func (*App) HandleTransform ¶ added in v0.1.9
func (app *App) HandleTransform(w http.ResponseWriter, r *http.Request)
func (*App) WriteJSONErr ¶
func (*App) WriteJSONResponse ¶
func (app *App) WriteJSONResponse(w http.ResponseWriter, statusCode int, resp any)
type AppOpt ¶
type AppOpt func(app *App)
func WithInhooksConfigService ¶
func WithInhooksConfigService(inhooksConfigSvc services.InhooksConfigService) AppOpt
func WithLogger ¶
func WithMessageBuilder ¶
func WithMessageBuilder(messageBuilder services.MessageBuilder) AppOpt
func WithMessageEnqueuer ¶
func WithMessageEnqueuer(messageEnqueuer services.MessageEnqueuer) AppOpt
func WithMessageTransformer ¶ added in v0.1.9
func WithMessageTransformer(messageTransformer services.MessageTransformer) AppOpt
func WithMessageVerifier ¶ added in v0.1.6
func WithMessageVerifier(messageVerifier services.MessageVerifier) AppOpt
type TransformRequest ¶ added in v0.1.9
type TransformRequest struct {
Body string `json:"body"`
Headers map[string][]string `json:"headers"`
TransformDefinition *models.TransformDefinition `json:"transformDefinition"`
}
type TransformResponse ¶ added in v0.1.9
Click to show internal directories.
Click to hide internal directories.