callbacks

package

v1.1.1 Latest Latest Go to latest Published: Jul 11, 2024 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

View Source

const (
	RetryCount   = 5
	RetryWaitMin = 1 * time.Second
	RetryWaitMax = 30 * time.Second

	RequestTimeout = 10 * time.Second
)

Configuration

This section is empty.

func Dispatch(req *Request)

Dispatch creates a new http client instance and makes a request to the callback URL.

Each dispatch will spawn a new goroutine. This is a naive implementation and might need to be moved to a worker pool.

type Callback interface {
	Validate() error
	Encode() string
}

Callback interface provides a Validate and an Encode method.

type OnRecordingReady struct {
	SignedParameters string `json:"signed_parameters" form:"signed_parameters"`
}

OnRecordingReady is a callback request with a `signed_parameters` payload.

func (r *OnRecordingReady) Encode() string

Encode encodes the callback request as Form-Encoded data.

func (r *OnRecordingReady) Validate() error

Validate checks an OnRecordingReady request

type Request struct {
	// The callback URL
	URL string

	// Callback is any type of payload
	Callback Callback
}

Request describes a callback invocation.

func NewRequest(url string, cb Callback) *Request

NewRequest creates a new request.