MCPcopy Index your code
hub / github.com/FunctionStream/function-stream / GetStateExecute

Method GetStateExecute

admin/client/api_state.go:53–125  ·  view source on GitHub ↗

Execute executes the request @return string

(r ApiGetStateRequest)

Source from the content-addressed store, hash-verified

51//
52// @return string
53func (a *StateAPIService) GetStateExecute(r ApiGetStateRequest) (string, *http.Response, error) {
54 var (
55 localVarHTTPMethod = http.MethodGet
56 localVarPostBody interface{}
57 formFiles []formFile
58 localVarReturnValue string
59 )
60
61 localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "StateAPIService.GetState")
62 if err != nil {
63 return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
64 }
65
66 localVarPath := localBasePath + "/api/v1/state/{key}"
67 localVarPath = strings.Replace(localVarPath, "{"+"key"+"}", url.PathEscape(parameterValueToString(r.key, "key")), -1)
68
69 localVarHeaderParams := make(map[string]string)
70 localVarQueryParams := url.Values{}
71 localVarFormParams := url.Values{}
72
73 // to determine the Content-Type header
74 localVarHTTPContentTypes := []string{}
75
76 // set Content-Type header
77 localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
78 if localVarHTTPContentType != "" {
79 localVarHeaderParams["Content-Type"] = localVarHTTPContentType
80 }
81
82 // to determine the Accept header
83 localVarHTTPHeaderAccepts := []string{"*/*"}
84
85 // set Accept header
86 localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
87 if localVarHTTPHeaderAccept != "" {
88 localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
89 }
90 req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
91 if err != nil {
92 return localVarReturnValue, nil, err
93 }
94
95 localVarHTTPResponse, err := a.client.callAPI(req)
96 if err != nil || localVarHTTPResponse == nil {
97 return localVarReturnValue, localVarHTTPResponse, err
98 }
99
100 localVarBody, err := io.ReadAll(localVarHTTPResponse.Body)
101 localVarHTTPResponse.Body.Close()
102 localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody))
103 if err != nil {
104 return localVarReturnValue, localVarHTTPResponse, err
105 }
106
107 if localVarHTTPResponse.StatusCode >= 300 {
108 newErr := &GenericOpenAPIError{
109 body: localVarBody,
110 error: localVarHTTPResponse.Status,

Callers 1

ExecuteMethod · 0.80

Calls 10

parameterValueToStringFunction · 0.85
selectHeaderContentTypeFunction · 0.85
selectHeaderAcceptFunction · 0.85
ServerURLWithContextMethod · 0.80
ErrorMethod · 0.80
prepareRequestMethod · 0.80
callAPIMethod · 0.80
decodeMethod · 0.80
CloseMethod · 0.65
GetMethod · 0.45

Tested by

no test coverage detected