summaryrefslogtreecommitdiff
path: root/internal/transport
diff options
context:
space:
mode:
authorLibravatar tobi <31960611+tsmethurst@users.noreply.github.com>2023-11-27 15:02:52 +0100
committerLibravatar GitHub <noreply@github.com>2023-11-27 14:02:52 +0000
commit5eddef6c9b66fd35dc9473578d4e1a3b1b8d7b08 (patch)
treeee67f8a683a351580bc0b6365067001c34ff1cc1 /internal/transport
parent[performance] http response encoding / writing improvements (#2374) (diff)
downloadgotosocial-5eddef6c9b66fd35dc9473578d4e1a3b1b8d7b08.tar.xz
[feature] Add `/api/v1/admin/debug/apurl` endpoint (#2359)
Diffstat (limited to 'internal/transport')
-rw-r--r--internal/transport/transport.go10
1 files changed, 8 insertions, 2 deletions
diff --git a/internal/transport/transport.go b/internal/transport/transport.go
index fc85e5141..ac56c73cb 100644
--- a/internal/transport/transport.go
+++ b/internal/transport/transport.go
@@ -46,6 +46,10 @@ type Transport interface {
POST functions
*/
+ // POST will perform given the http request using
+ // transport client, retrying on certain preset errors.
+ POST(*http.Request, []byte) (*http.Response, error)
+
// Deliver sends an ActivityStreams object.
Deliver(ctx context.Context, b []byte, to *url.URL) error
@@ -56,6 +60,10 @@ type Transport interface {
GET functions
*/
+ // GET will perform the given http request using
+ // transport client, retrying on certain preset errors.
+ GET(*http.Request) (*http.Response, error)
+
// Dereference fetches the ActivityStreams object located at this IRI with a GET request.
Dereference(ctx context.Context, iri *url.URL) ([]byte, error)
@@ -81,7 +89,6 @@ type transport struct {
signerMu sync.Mutex
}
-// GET will perform given http request using transport client, retrying on certain preset errors.
func (t *transport) GET(r *http.Request) (*http.Response, error) {
if r.Method != http.MethodGet {
return nil, errors.New("must be GET request")
@@ -93,7 +100,6 @@ func (t *transport) GET(r *http.Request) (*http.Response, error) {
return t.controller.client.DoSigned(r, t.signGET())
}
-// POST will perform given http request using transport client, retrying on certain preset errors.
func (t *transport) POST(r *http.Request, body []byte) (*http.Response, error) {
if r.Method != http.MethodPost {
return nil, errors.New("must be POST request")