cloudrelay

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

type Delivery struct {
	// ID tells this delivery apart from every other, across repeats.
	ID       string
	Hook     string
	Received time.Time
	Header   http.Header
	Body     []byte
}

type Handler struct {
	// Delivery takes a webhook and reports what became of it. The relay
	// sends a webhook again on the next connection until it hears an
	// outcome, so the same delivery can arrive more than once.
	Delivery func(ctx context.Context, d Delivery) Outcome
	// Hooked receives the relay's answer to each set of hooks.
	Hooked func(h Hooked)
	// Missed receives, for each hook, how many webhooks the relay dropped
	// since it last told this server. Each count is told once.
	Missed func(missed []Missed)
	// Call serves the calls Dagu Cloud sends through the relay, each with its
	// assertion in AssertionHeader. A call the relay cancels has its
	// request's context canceled.
	Call http.Handler
}

type Hello struct {
	Name    string
	Version string
	// Instance names the process opening a connection for calls, which the
	// relay keeps beside the connections of the server's other processes. It
	// is empty for the scheduler's connection.
	Instance string
}

type Hook struct {
	ID    string
	Token string
	// Handshake names that sender: HandshakeSlack, or empty for none.
	Handshake string
}

type Hooked struct {
	URL string
	// Error is "too_many_hooks" when the set is larger than the ticket allows.
	Error string
}

type Missed struct {
	Hook    string `json:"hook"`
	Expired int    `json:"expired"`
	Refused int    `json:"refused"`
}

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

type Ticket struct {
	Token string `json:"token"`
	// URL is the relay's WebSocket endpoint.
	URL string `json:"url"`
	// MaxHooks is the most public webhook URLs the server's plan allows.
	MaxHooks int `json:"max_hooks"`
}

type TicketRefusedError struct {
	StatusCode int
	Message    string
}