benthos_components

type Api interface {
	CreateStream(ctx context.Context, address string, id string, config string) error
	GetStream(ctx context.Context, address, id string) (*BenthosStream, error)
	UpdateStream(ctx context.Context, address string, id string, config string) error
	DeleteStream(ctx context.Context, address string, id string) error
}

type BenthosStream struct {
	Active    bool           `json:"active"`
	Uptime    float64        `json:"uptime"`
	UptimeStr string         `json:"uptime_str"`
	Config    map[string]any `json:"config"`
}

type DefaultApi struct {
}

type ErrorResponse struct {
	LintErrors []string `json:"lint_errors,omitempty"`
}

type ServerMutator struct {
	// contains filtered or unexported fields
}

type StreamMutator struct {
	// contains filtered or unexported fields
}