Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrFirehoseNamespaceNotFound = errors.New("could not find firehose namespace from resource output") ErrFirehoseNamespaceInvalid = errors.New("invalid firehose namespace from resource output") ErrFirehoseNotFound = errors.New("firehose not found") ErrEmptyConfigImage = errors.New("empty dlq job image") ErrEmptyConfigPrometheusHost = errors.New("empty prometheus host") )
Functions ¶
func Routes ¶
func Routes( entropyClient entropyv1beta1rpc.ResourceServiceClient, gcsClient gcs.BlobStorageClient, cfg DlqJobConfig, ) func(r chi.Router)
Types ¶
type DlqJobConfig ¶ added in v0.7.19
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func (*Handler) ListFirehoseDLQ ¶ added in v0.7.14
func (h *Handler) ListFirehoseDLQ(w http.ResponseWriter, r *http.Request)
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(client entropyv1beta1rpc.ResourceServiceClient, gcsClient gcs.BlobStorageClient, cfg DlqJobConfig) *Service
Click to show internal directories.
Click to hide internal directories.