inbox

Documentation

Index

• func AddToQueue(req apmodels.InboxRequest)
• func InitInboxWorkerPool()
• func Verify(request *http.Request) (bool, error)
• type Job

Functions

func AddToQueue

func AddToQueue(req apmodels.InboxRequest)

AddToQueue will queue up an outbound http request.

func InitInboxWorkerPool

func InitInboxWorkerPool()

InitInboxWorkerPool starts n go routines that await ActivityPub jobs.

func Verify

func Verify(request *http.Request) (bool, error)

Verify will Verify the http signature of an inbound request as well as check it against the list of blocked domains. nolint: cyclop

Types

type Job

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

Job struct bundling the ActivityPub and the payload in one struct.