rhttp

package
v0.0.0-...-36d6306 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckOwnerHttp 

func CheckOwnerHttp(ctx context.Context, hs shttp.HTTPService, us suser.UserService, httpID idwrap.IDWrap) (bool, error)

func CreateService 

func CreateService(srv HttpServiceRPC, options []connect.HandlerOption) (*api.Service, error)

CreateService creates the HTTP service with Connect handler

Types

type AssertionResult 

type AssertionResult struct {
	AssertionID idwrap.IDWrap
	Expression  string
	Success     bool
	Error       error
	EvaluatedAt time.Time
}

evaluateAndStoreAssertions loads assertions for an HTTP entry, evaluates them against the response, and stores the results AssertionResult represents the result of an assertion evaluation

type HttpAssertEvent 

type HttpAssertEvent struct {
	Type       string
	IsDelta    bool
	Patch      patch.HTTPAssertPatch
	HttpAssert *httpv1.HttpAssert
}

HttpAssertEvent defines the event payload for HTTP assert streaming

type HttpAssertTopic 

type HttpAssertTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpAssertTopic defines the streaming topic for HTTP assert events

type HttpBodyFormEvent 

type HttpBodyFormEvent struct {
	Type         string
	IsDelta      bool
	Patch        patch.HTTPBodyFormPatch
	HttpBodyForm *httpv1.HttpBodyFormData
}

HttpBodyFormEvent defines the event payload for HTTP body form streaming

type HttpBodyFormTopic 

type HttpBodyFormTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpBodyFormTopic defines the streaming topic for HTTP body form events

type HttpBodyRawEvent 

type HttpBodyRawEvent struct {
	Type        string
	IsDelta     bool
	Patch       patch.HTTPBodyRawPatch
	HttpBodyRaw *httpv1.HttpBodyRaw
}

HttpBodyRawEvent defines the event payload for HTTP body raw streaming

type HttpBodyRawTopic 

type HttpBodyRawTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpBodyRawTopic defines the streaming topic for HTTP body raw events

type HttpBodyUrlEncodedEvent 

type HttpBodyUrlEncodedEvent struct {
	Type               string
	IsDelta            bool
	Patch              patch.HTTPBodyUrlEncodedPatch
	HttpBodyUrlEncoded *httpv1.HttpBodyUrlEncoded
}

HttpBodyUrlEncodedEvent defines the event payload for HTTP body URL encoded streaming

type HttpBodyUrlEncodedTopic 

type HttpBodyUrlEncodedTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpBodyUrlEncodedTopic defines the streaming topic for HTTP body URL encoded events

type HttpEvent 

type HttpEvent struct {
	Type    string
	IsDelta bool
	Patch   patch.HTTPDeltaPatch
	Http    *httpv1.Http
}

HttpEvent defines the event payload for HTTP streaming

type HttpHeaderEvent 

type HttpHeaderEvent struct {
	Type       string
	IsDelta    bool
	Patch      patch.HTTPHeaderPatch
	HttpHeader *httpv1.HttpHeader
}

HttpHeaderEvent defines the event payload for HTTP header streaming

type HttpHeaderTopic 

type HttpHeaderTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpHeaderTopic defines the streaming topic for HTTP header events

type HttpResponseAssertEvent 

type HttpResponseAssertEvent struct {
	Type               string
	HttpResponseAssert *httpv1.HttpResponseAssert
}

HttpResponseAssertEvent defines the event payload for HTTP response assert streaming

type HttpResponseAssertTopic 

type HttpResponseAssertTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpResponseAssertTopic defines the streaming topic for HTTP response assert events

type HttpResponseEvent 

type HttpResponseEvent struct {
	Type         string
	HttpResponse *httpv1.HttpResponse
}

HttpResponseEvent defines the event payload for HTTP response streaming

type HttpResponseHeaderEvent 

type HttpResponseHeaderEvent struct {
	Type               string
	HttpResponseHeader *httpv1.HttpResponseHeader
}

HttpResponseHeaderEvent defines the event payload for HTTP response header streaming

type HttpResponseHeaderTopic 

type HttpResponseHeaderTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpResponseHeaderTopic defines the streaming topic for HTTP response header events

type HttpResponseTopic 

type HttpResponseTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpResponseTopic defines the streaming topic for HTTP response events

type HttpSearchParamEvent 

type HttpSearchParamEvent struct {
	Type            string
	IsDelta         bool
	Patch           patch.HTTPSearchParamPatch
	HttpSearchParam *httpv1.HttpSearchParam
}

HttpSearchParamEvent defines the event payload for HTTP search param streaming

type HttpSearchParamTopic 

type HttpSearchParamTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpSearchParamTopic defines the streaming topic for HTTP search param events

type HttpServiceRPC 

type HttpServiceRPC struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

HttpServiceRPC handles HTTP RPC operations with streaming support

func New 

func New(deps HttpServiceRPCDeps) HttpServiceRPC

New creates a new HttpServiceRPC instance

func (*HttpServiceRPC) HttpAssertCollection 

func (h *HttpServiceRPC) HttpAssertCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpAssertCollectionResponse], error)

func (*HttpServiceRPC) HttpAssertDelete 

func (h *HttpServiceRPC) HttpAssertDelete(ctx context.Context, req *connect.Request[apiv1.HttpAssertDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpAssertDeltaCollection 

func (h *HttpServiceRPC) HttpAssertDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpAssertDeltaCollectionResponse], error)

streamHttpHeaderDeltaSync streams HTTP header delta events to the client

func (*HttpServiceRPC) HttpAssertDeltaDelete 

func (h *HttpServiceRPC) HttpAssertDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpAssertDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpAssertDeltaInsert 

func (h *HttpServiceRPC) HttpAssertDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpAssertDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpAssertDeltaSync 

func (h *HttpServiceRPC) HttpAssertDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpAssertDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpAssertDeltaUpdate 

func (h *HttpServiceRPC) HttpAssertDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpAssertDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpAssertInsert 

func (h *HttpServiceRPC) HttpAssertInsert(ctx context.Context, req *connect.Request[apiv1.HttpAssertInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpAssertSync 

func (h *HttpServiceRPC) HttpAssertSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpAssertSyncResponse]) error

func (*HttpServiceRPC) HttpAssertUpdate 

func (h *HttpServiceRPC) HttpAssertUpdate(ctx context.Context, req *connect.Request[apiv1.HttpAssertUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyFormDataCollection 

func (h *HttpServiceRPC) HttpBodyFormDataCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpBodyFormDataCollectionResponse], error)

func (*HttpServiceRPC) HttpBodyFormDataDelete 

func (h *HttpServiceRPC) HttpBodyFormDataDelete(ctx context.Context, req *connect.Request[apiv1.HttpBodyFormDataDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyFormDataDeltaCollection 

func (h *HttpServiceRPC) HttpBodyFormDataDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpBodyFormDataDeltaCollectionResponse], error)

streamHttpBodyFormDeltaSync streams HTTP body form delta events to the client

func (*HttpServiceRPC) HttpBodyFormDataDeltaDelete 

func (h *HttpServiceRPC) HttpBodyFormDataDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpBodyFormDataDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyFormDataDeltaInsert 

func (h *HttpServiceRPC) HttpBodyFormDataDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpBodyFormDataDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyFormDataDeltaSync 

func (h *HttpServiceRPC) HttpBodyFormDataDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpBodyFormDataDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpBodyFormDataDeltaUpdate 

func (h *HttpServiceRPC) HttpBodyFormDataDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpBodyFormDataDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyFormDataInsert 

func (h *HttpServiceRPC) HttpBodyFormDataInsert(ctx context.Context, req *connect.Request[apiv1.HttpBodyFormDataInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyFormDataSync 

func (h *HttpServiceRPC) HttpBodyFormDataSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpBodyFormDataSyncResponse]) error

func (*HttpServiceRPC) HttpBodyFormDataUpdate 

func (h *HttpServiceRPC) HttpBodyFormDataUpdate(ctx context.Context, req *connect.Request[apiv1.HttpBodyFormDataUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyRawCollection 

func (h *HttpServiceRPC) HttpBodyRawCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpBodyRawCollectionResponse], error)

func (*HttpServiceRPC) HttpBodyRawDeltaCollection 

func (h *HttpServiceRPC) HttpBodyRawDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpBodyRawDeltaCollectionResponse], error)

streamHttpBodyUrlEncodedSync streams HTTP body URL encoded events to the client

func (*HttpServiceRPC) HttpBodyRawDeltaDelete 

func (h *HttpServiceRPC) HttpBodyRawDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpBodyRawDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyRawDeltaInsert 

func (h *HttpServiceRPC) HttpBodyRawDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpBodyRawDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyRawDeltaSync 

func (h *HttpServiceRPC) HttpBodyRawDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpBodyRawDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpBodyRawDeltaUpdate 

func (h *HttpServiceRPC) HttpBodyRawDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpBodyRawDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyRawInsert 

func (h *HttpServiceRPC) HttpBodyRawInsert(ctx context.Context, req *connect.Request[apiv1.HttpBodyRawInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyRawSync 

func (h *HttpServiceRPC) HttpBodyRawSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpBodyRawSyncResponse]) error

func (*HttpServiceRPC) HttpBodyRawUpdate 

func (h *HttpServiceRPC) HttpBodyRawUpdate(ctx context.Context, req *connect.Request[apiv1.HttpBodyRawUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedCollection 

func (h *HttpServiceRPC) HttpBodyUrlEncodedCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpBodyUrlEncodedCollectionResponse], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedDelete 

func (h *HttpServiceRPC) HttpBodyUrlEncodedDelete(ctx context.Context, req *connect.Request[apiv1.HttpBodyUrlEncodedDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedDeltaCollection 

func (h *HttpServiceRPC) HttpBodyUrlEncodedDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpBodyUrlEncodedDeltaCollectionResponse], error)

HttpBodyUrlEncodedDeltaCollection returns all body URL encoded deltas

func (*HttpServiceRPC) HttpBodyUrlEncodedDeltaDelete 

func (h *HttpServiceRPC) HttpBodyUrlEncodedDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpBodyUrlEncodedDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedDeltaInsert 

func (h *HttpServiceRPC) HttpBodyUrlEncodedDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpBodyUrlEncodedDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedDeltaSync 

func (h *HttpServiceRPC) HttpBodyUrlEncodedDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpBodyUrlEncodedDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpBodyUrlEncodedDeltaUpdate 

func (h *HttpServiceRPC) HttpBodyUrlEncodedDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpBodyUrlEncodedDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedInsert 

func (h *HttpServiceRPC) HttpBodyUrlEncodedInsert(ctx context.Context, req *connect.Request[apiv1.HttpBodyUrlEncodedInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpBodyUrlEncodedSync 

func (h *HttpServiceRPC) HttpBodyUrlEncodedSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpBodyUrlEncodedSyncResponse]) error

func (*HttpServiceRPC) HttpBodyUrlEncodedUpdate 

func (h *HttpServiceRPC) HttpBodyUrlEncodedUpdate(ctx context.Context, req *connect.Request[apiv1.HttpBodyUrlEncodedUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpCollection 

func (h *HttpServiceRPC) HttpCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpCollectionResponse], error)

func (*HttpServiceRPC) HttpDelete 

func (h *HttpServiceRPC) HttpDelete(ctx context.Context, req *connect.Request[apiv1.HttpDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpDeltaCollection 

func (h *HttpServiceRPC) HttpDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpDeltaCollectionResponse], error)

func (*HttpServiceRPC) HttpDeltaDelete 

func (h *HttpServiceRPC) HttpDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpDeltaInsert 

func (h *HttpServiceRPC) HttpDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpDeltaSync 

func (h *HttpServiceRPC) HttpDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpDeltaUpdate 

func (h *HttpServiceRPC) HttpDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpDuplicate 

func (h *HttpServiceRPC) HttpDuplicate(ctx context.Context, req *connect.Request[apiv1.HttpDuplicateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpHeaderCollection 

func (h *HttpServiceRPC) HttpHeaderCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpHeaderCollectionResponse], error)

func (*HttpServiceRPC) HttpHeaderDelete 

func (h *HttpServiceRPC) HttpHeaderDelete(ctx context.Context, req *connect.Request[apiv1.HttpHeaderDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpHeaderDeltaCollection 

func (h *HttpServiceRPC) HttpHeaderDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpHeaderDeltaCollectionResponse], error)

func (*HttpServiceRPC) HttpHeaderDeltaDelete 

func (h *HttpServiceRPC) HttpHeaderDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpHeaderDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpHeaderDeltaInsert 

func (h *HttpServiceRPC) HttpHeaderDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpHeaderDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpHeaderDeltaSync 

func (h *HttpServiceRPC) HttpHeaderDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpHeaderDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpHeaderDeltaUpdate 

func (h *HttpServiceRPC) HttpHeaderDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpHeaderDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpHeaderInsert 

func (h *HttpServiceRPC) HttpHeaderInsert(ctx context.Context, req *connect.Request[apiv1.HttpHeaderInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpHeaderSync 

func (h *HttpServiceRPC) HttpHeaderSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpHeaderSyncResponse]) error

func (*HttpServiceRPC) HttpHeaderUpdate 

func (h *HttpServiceRPC) HttpHeaderUpdate(ctx context.Context, req *connect.Request[apiv1.HttpHeaderUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpInsert 

func (h *HttpServiceRPC) HttpInsert(ctx context.Context, req *connect.Request[apiv1.HttpInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpResponseAssertCollection 

func (h *HttpServiceRPC) HttpResponseAssertCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpResponseAssertCollectionResponse], error)

func (*HttpServiceRPC) HttpResponseAssertSync 

func (h *HttpServiceRPC) HttpResponseAssertSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpResponseAssertSyncResponse]) error

func (*HttpServiceRPC) HttpResponseCollection 

func (h *HttpServiceRPC) HttpResponseCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpResponseCollectionResponse], error)

func (*HttpServiceRPC) HttpResponseHeaderCollection 

func (h *HttpServiceRPC) HttpResponseHeaderCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpResponseHeaderCollectionResponse], error)

func (*HttpServiceRPC) HttpResponseHeaderSync 

func (h *HttpServiceRPC) HttpResponseHeaderSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpResponseHeaderSyncResponse]) error

func (*HttpServiceRPC) HttpResponseSync 

func (h *HttpServiceRPC) HttpResponseSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpResponseSyncResponse]) error

func (*HttpServiceRPC) HttpRun 

func (h *HttpServiceRPC) HttpRun(ctx context.Context, req *connect.Request[apiv1.HttpRunRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSearchParamCollection 

func (h *HttpServiceRPC) HttpSearchParamCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpSearchParamCollectionResponse], error)

func (*HttpServiceRPC) HttpSearchParamDelete 

func (h *HttpServiceRPC) HttpSearchParamDelete(ctx context.Context, req *connect.Request[apiv1.HttpSearchParamDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSearchParamDeltaCollection 

func (h *HttpServiceRPC) HttpSearchParamDeltaCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpSearchParamDeltaCollectionResponse], error)

func (*HttpServiceRPC) HttpSearchParamDeltaDelete 

func (h *HttpServiceRPC) HttpSearchParamDeltaDelete(ctx context.Context, req *connect.Request[apiv1.HttpSearchParamDeltaDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSearchParamDeltaInsert 

func (h *HttpServiceRPC) HttpSearchParamDeltaInsert(ctx context.Context, req *connect.Request[apiv1.HttpSearchParamDeltaInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSearchParamDeltaSync 

func (h *HttpServiceRPC) HttpSearchParamDeltaSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[apiv1.HttpSearchParamDeltaSyncResponse]) error

func (*HttpServiceRPC) HttpSearchParamDeltaUpdate 

func (h *HttpServiceRPC) HttpSearchParamDeltaUpdate(ctx context.Context, req *connect.Request[apiv1.HttpSearchParamDeltaUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSearchParamInsert 

func (h *HttpServiceRPC) HttpSearchParamInsert(ctx context.Context, req *connect.Request[apiv1.HttpSearchParamInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSearchParamSync 

func (h *HttpServiceRPC) HttpSearchParamSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpSearchParamSyncResponse]) error

func (*HttpServiceRPC) HttpSearchParamUpdate 

func (h *HttpServiceRPC) HttpSearchParamUpdate(ctx context.Context, req *connect.Request[apiv1.HttpSearchParamUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpSync 

func (h *HttpServiceRPC) HttpSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpSyncResponse]) error

func (*HttpServiceRPC) HttpUpdate 

func (h *HttpServiceRPC) HttpUpdate(ctx context.Context, req *connect.Request[apiv1.HttpUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*HttpServiceRPC) HttpVersionCollection 

func (h *HttpServiceRPC) HttpVersionCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[apiv1.HttpVersionCollectionResponse], error)

func (*HttpServiceRPC) HttpVersionSync 

func (h *HttpServiceRPC) HttpVersionSync(ctx context.Context, req *connect.Request[emptypb.Empty], stream *connect.ServerStream[httpv1.HttpVersionSyncResponse]) error

func (*HttpServiceRPC) MutationPublisher 

func (s *HttpServiceRPC) MutationPublisher() mutation.Publisher

MutationPublisher returns a unified publisher for HTTP-related mutation events. Exported so other services (e.g. the workspace importer) can dispatch HTTP sync events through the same machinery.

type HttpServiceRPCDeps 

type HttpServiceRPCDeps struct {
	DB        *sql.DB
	Readers   HttpServiceRPCReaders
	Services  HttpServiceRPCServices
	Resolver  resolver.RequestResolver
	Streamers *HttpStreamers
}

func (*HttpServiceRPCDeps) Validate 

func (d *HttpServiceRPCDeps) Validate() error

type HttpServiceRPCReaders 

type HttpServiceRPCReaders struct {
	Http      *shttp.Reader
	User      *sworkspace.UserReader
	Workspace *sworkspace.WorkspaceReader
}

func (*HttpServiceRPCReaders) Validate 

func (r *HttpServiceRPCReaders) Validate() error

type HttpServiceRPCServices 

type HttpServiceRPCServices struct {
	Http               shttp.HTTPService
	User               suser.UserService
	Workspace          sworkspace.WorkspaceService
	WorkspaceUser      sworkspace.UserService
	Env                senv.EnvService
	Variable           senv.VariableService
	HttpBodyRaw        *shttp.HttpBodyRawService
	HttpHeader         shttp.HttpHeaderService
	HttpSearchParam    *shttp.HttpSearchParamService
	HttpBodyForm       *shttp.HttpBodyFormService
	HttpBodyUrlEncoded *shttp.HttpBodyUrlEncodedService
	HttpAssert         *shttp.HttpAssertService
	HttpResponse       shttp.HttpResponseService
	File               *sfile.FileService
}

func (*HttpServiceRPCServices) Validate 

func (s *HttpServiceRPCServices) Validate() error

type HttpStreamers 

type HttpStreamers struct {
	Http               eventstream.SyncStreamer[HttpTopic, HttpEvent]
	HttpHeader         eventstream.SyncStreamer[HttpHeaderTopic, HttpHeaderEvent]
	HttpSearchParam    eventstream.SyncStreamer[HttpSearchParamTopic, HttpSearchParamEvent]
	HttpBodyForm       eventstream.SyncStreamer[HttpBodyFormTopic, HttpBodyFormEvent]
	HttpBodyUrlEncoded eventstream.SyncStreamer[HttpBodyUrlEncodedTopic, HttpBodyUrlEncodedEvent]
	HttpAssert         eventstream.SyncStreamer[HttpAssertTopic, HttpAssertEvent]
	HttpVersion        eventstream.SyncStreamer[HttpVersionTopic, HttpVersionEvent]
	HttpResponse       eventstream.SyncStreamer[HttpResponseTopic, HttpResponseEvent]
	HttpResponseHeader eventstream.SyncStreamer[HttpResponseHeaderTopic, HttpResponseHeaderEvent]
	HttpResponseAssert eventstream.SyncStreamer[HttpResponseAssertTopic, HttpResponseAssertEvent]
	HttpBodyRaw        eventstream.SyncStreamer[HttpBodyRawTopic, HttpBodyRawEvent]
	Log                eventstream.SyncStreamer[rlog.LogTopic, rlog.LogEvent]
	File               eventstream.SyncStreamer[rfile.FileTopic, rfile.FileEvent]
}

HttpStreamers groups all event streams used by the HTTP service

type HttpTopic 

type HttpTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpTopic defines the streaming topic for HTTP events

type HttpVersionEvent 

type HttpVersionEvent struct {
	Type        string
	HttpVersion *httpv1.HttpVersion
}

HttpVersionEvent defines the event payload for HTTP version streaming

type HttpVersionTopic 

type HttpVersionTopic struct {
	WorkspaceID idwrap.IDWrap
}

HttpVersionTopic defines the streaming topic for HTTP version events

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.