http

type Decoder interface {
	// Handles reports whether Decode handles an event, by its X-GitHub-Event name.
	Handles(event string) bool
	// Decode turns a delivery into an event. It returns no event, and the reason, for deliveries
	// Octomaton ignores, and an error for payloads it cannot parse.
	Decode(event, delivery string, body []byte) (ci.Event, string, error)
}

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

type EventHandler interface {
	Handle(ctx context.Context, ev ci.Event) error
}

type Forwarder interface {
	Forward(header http.Header, body []byte)
}

type Handler struct {
	Secret  []byte
	Decoder Decoder
	Events  EventHandler
	Pool    *Pool
	Dedupe  *Dedupe
	Metrics *metrics.Metrics
	Logger  *slog.Logger
	// Relay, when set, receives verified push and ping deliveries.
	Relay Forwarder
}

type Job struct {
	// Name describes the job in logs.
	Name string
	Run  func(ctx context.Context)
}

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

type Readiness struct {
	// Ping checks that the Kubernetes API server answers.
	Ping func(ctx context.Context) error
	// Leading reports whether this replica is the elected leader.
	Leading func() bool
	// Synced reports whether the leader's PipelineRun informer has synced.
	Synced func() bool
	// TTL is how long a Ping result is reused, so that frequent probes do not load the API server.
	TTL time.Duration
	// contains filtered or unexported fields
}

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