Versions in this module Expand all Collapse all v0 v0.1.0 Jul 2, 2024 Changes in this version + func Call[I, O any](runner *Runner, fn *dispatch.Function[I, O], input I) (O, error) + func KeyPair() (signingKey, verificationKey string) + func NewServer(handler dispatchserver.Handler) *httptest.Server + func SigningKey(signingKey string) dispatchserver.EndpointClientOption + type CallRecorder struct + func (r *CallRecorder) Assert(t *testing.T, want ...DispatchRequest) + func (r *CallRecorder) Handle(ctx context.Context, header http.Header, calls []dispatchproto.Call) ([]dispatchproto.ID, error) + type DispatchRequest struct + Calls []dispatchproto.Call + Header http.Header + type EndpointServer struct + func NewEndpoint(opts ...dispatch.Option) (*dispatch.Dispatch, *EndpointServer, error) + func (e *EndpointServer) Client(opts ...dispatchserver.EndpointClientOption) (*dispatchserver.EndpointClient, error) + func (e *EndpointServer) Close() + func (e *EndpointServer) URL() string + type Runner struct + func NewRunner(functions ...dispatch.AnyFunction) *Runner + func (r *Runner) Register(fn dispatch.AnyFunction) + func (r *Runner) RegisterPrimitive(name string, fn dispatchproto.Function) + func (r *Runner) Run(req dispatchproto.Request) dispatchproto.Response + func (r Runner) RoundTrip(req dispatchproto.Request) dispatchproto.Response
Go to main page