Versions in this module Expand all Collapse all v0 v0.7.6 Oct 23, 2025 v0.7.5 Jun 30, 2025 Changes in this version + func GetSwagger() (swagger *openapi3.T, err error) + func NewExecuteFunctionRequest(server string, body ExecuteFunctionJSONRequestBody) (*http.Request, error) + func NewExecuteFunctionRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error) + func NewExecutionResultRequest(server string, body ExecutionResultJSONRequestBody) (*http.Request, error) + func NewExecutionResultRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error) + func NewHealthRequest(server string) (*http.Request, error) + func NewInstallFunctionRequest(server string, body InstallFunctionJSONRequestBody) (*http.Request, error) + func NewInstallFunctionRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error) + func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error) + func RegisterHandlers(router EchoRouter, si ServerInterface) + func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string) + type API struct + Log zerolog.Logger + Node Node + func New(log zerolog.Logger, node Node) *API + func (a *API) ExecuteFunction(ctx echo.Context) error + func (a *API) ExecutionResult(ctx echo.Context) error + func (a *API) Health(ctx echo.Context) error + func (a *API) InstallFunction(ctx echo.Context) error + type AggregatedResult = aggregate.Result + type AggregatedResults = aggregate.Results + type AttributeAttestors = execute.AttributeAttestors + type Client struct + Client HttpRequestDoer + RequestEditors []RequestEditorFn + Server string + func NewClient(server string, opts ...ClientOption) (*Client, error) + func (c *Client) ExecuteFunction(ctx context.Context, body ExecuteFunctionJSONRequestBody, ...) (*http.Response, error) + func (c *Client) ExecuteFunctionWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + func (c *Client) ExecutionResult(ctx context.Context, body ExecutionResultJSONRequestBody, ...) (*http.Response, error) + func (c *Client) ExecutionResultWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + func (c *Client) Health(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) InstallFunction(ctx context.Context, body InstallFunctionJSONRequestBody, ...) (*http.Response, error) + func (c *Client) InstallFunctionWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + type ClientInterface interface + ExecuteFunction func(ctx context.Context, body ExecuteFunctionJSONRequestBody, ...) (*http.Response, error) + ExecuteFunctionWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + ExecutionResult func(ctx context.Context, body ExecutionResultJSONRequestBody, ...) (*http.Response, error) + ExecutionResultWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + Health func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + InstallFunction func(ctx context.Context, body InstallFunctionJSONRequestBody, ...) (*http.Response, error) + InstallFunctionWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + type ClientOption func(*Client) error + func WithBaseURL(baseURL string) ClientOption + func WithHTTPClient(doer HttpRequestDoer) ClientOption + func WithRequestEditorFn(fn RequestEditorFn) ClientOption + type ClientWithResponses struct + func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error) + func (c *ClientWithResponses) ExecuteFunctionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*ExecuteFunctionResponse, error) + func (c *ClientWithResponses) ExecuteFunctionWithResponse(ctx context.Context, body ExecuteFunctionJSONRequestBody, ...) (*ExecuteFunctionResponse, error) + func (c *ClientWithResponses) ExecutionResultWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*ExecutionResultResponse, error) + func (c *ClientWithResponses) ExecutionResultWithResponse(ctx context.Context, body ExecutionResultJSONRequestBody, ...) (*ExecutionResultResponse, error) + func (c *ClientWithResponses) HealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthResponse, error) + func (c *ClientWithResponses) InstallFunctionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*InstallFunctionResponse, error) + func (c *ClientWithResponses) InstallFunctionWithResponse(ctx context.Context, body InstallFunctionJSONRequestBody, ...) (*InstallFunctionResponse, error) + type ClientWithResponsesInterface interface + ExecuteFunctionWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*ExecuteFunctionResponse, error) + ExecuteFunctionWithResponse func(ctx context.Context, body ExecuteFunctionJSONRequestBody, ...) (*ExecuteFunctionResponse, error) + ExecutionResultWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*ExecutionResultResponse, error) + ExecutionResultWithResponse func(ctx context.Context, body ExecutionResultJSONRequestBody, ...) (*ExecutionResultResponse, error) + HealthWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthResponse, error) + InstallFunctionWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*InstallFunctionResponse, error) + InstallFunctionWithResponse func(ctx context.Context, body InstallFunctionJSONRequestBody, ...) (*InstallFunctionResponse, error) + type EchoRouter interface + CONNECT func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + DELETE func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + GET func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + HEAD func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + OPTIONS func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + PATCH func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + POST func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + PUT func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + TRACE func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + type ExecuteFunctionJSONRequestBody = ExecutionRequest + type ExecuteFunctionResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *ExecutionResponse + func ParseExecuteFunctionResponse(rsp *http.Response) (*ExecuteFunctionResponse, error) + func (r ExecuteFunctionResponse) Status() string + func (r ExecuteFunctionResponse) StatusCode() int + type ExecutionConfig = execute.Config + type ExecutionParameter = execute.Parameter + type ExecutionRequest struct + Config ExecutionConfig + FunctionId string + Method string + Parameters []ExecutionParameter + Topic string + type ExecutionResponse struct + Cluster NodeCluster + Code string + Message string + RequestId string + Results AggregatedResults + type ExecutionResult = execute.RuntimeOutput + type ExecutionResultJSONRequestBody = FunctionResultRequest + type ExecutionResultResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *FunctionResultResponse + func ParseExecutionResultResponse(rsp *http.Response) (*ExecutionResultResponse, error) + func (r ExecutionResultResponse) Status() string + func (r ExecutionResultResponse) StatusCode() int + type FunctionInstallRequest struct + Cid string + Topic string + Uri string + func (r FunctionInstallRequest) Valid() error + type FunctionInstallResponse struct + Code string + type FunctionResultRequest struct + Id string + func (r FunctionResultRequest) Valid() error + type FunctionResultResponse = ExecutionResponse + type HealthResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *HealthStatus + func ParseHealthResponse(rsp *http.Response) (*HealthResponse, error) + func (r HealthResponse) Status() string + func (r HealthResponse) StatusCode() int + type HealthStatus struct + Code string + type HttpRequestDoer interface + Do func(req *http.Request) (*http.Response, error) + type InstallFunctionJSONRequestBody = FunctionInstallRequest + type InstallFunctionResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *FunctionInstallResponse + func ParseInstallFunctionResponse(rsp *http.Response) (*InstallFunctionResponse, error) + func (r InstallFunctionResponse) Status() string + func (r InstallFunctionResponse) StatusCode() int + type NamedValue = execute.EnvVar + type Node interface + ExecuteFunction func(ctx context.Context, req execute.Request, subgroup string) (code codes.Code, requestID string, results execute.ResultMap, ...) + ExecutionResult func(id string) (execute.ResultMap, bool) + PublishFunctionInstall func(ctx context.Context, uri string, cid string, subgroup string) error + type NodeAttributes = execute.Attributes + type NodeCluster = execute.Cluster + type RequestEditorFn func(ctx context.Context, req *http.Request) error + type ResultAggregation = execute.ResultAggregation + type RuntimeConfig = execute.BLSRuntimeConfig + type ServerInterface interface + ExecuteFunction func(ctx echo.Context) error + ExecutionResult func(ctx echo.Context) error + Health func(ctx echo.Context) error + InstallFunction func(ctx echo.Context) error + type ServerInterfaceWrapper struct + Handler ServerInterface + func (w *ServerInterfaceWrapper) ExecuteFunction(ctx echo.Context) error + func (w *ServerInterfaceWrapper) ExecutionResult(ctx echo.Context) error + func (w *ServerInterfaceWrapper) Health(ctx echo.Context) error + func (w *ServerInterfaceWrapper) InstallFunction(ctx echo.Context) error
Go to main page