new /agent/status api endpoint (#967)

This commit is contained in:
Michael Quigley 2025-05-30 11:46:37 -04:00
parent 4491231e77
commit 2cecf14143
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
91 changed files with 3328 additions and 326 deletions

View File

@ -9,6 +9,7 @@ import (
"fmt" "fmt"
"github.com/go-openapi/runtime" "github.com/go-openapi/runtime"
httptransport "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt" "github.com/go-openapi/strfmt"
) )
@ -17,6 +18,31 @@ func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientServi
return &Client{transport: transport, formats: formats} return &Client{transport: transport, formats: formats}
} }
// New creates a new account API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
return &Client{transport: transport, formats: strfmt.Default}
}
// New creates a new account API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
return &Client{transport: transport, formats: strfmt.Default}
}
/* /*
Client for account API Client for account API
*/ */
@ -25,9 +51,53 @@ type Client struct {
formats strfmt.Registry formats strfmt.Registry
} }
// ClientOption is the option for Client methods // ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation) type ClientOption func(*runtime.ClientOperation)
// This client is generated with a few options you might find useful for your swagger spec.
//
// Feel free to add you own set of options.
// WithContentType allows the client to force the Content-Type header
// to negotiate a specific Consumer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithContentType(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{mime}
}
}
// WithContentTypeApplicationJSON sets the Content-Type header to "application/json".
func WithContentTypeApplicationJSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/json"}
}
// WithContentTypeApplicationZrokV1JSON sets the Content-Type header to "application/zrok.v1+json".
func WithContentTypeApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/zrok.v1+json"}
}
// WithAccept allows the client to force the Accept header
// to negotiate a specific Producer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithAccept(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{mime}
}
}
// WithAcceptApplicationJSON sets the Accept header to "application/json".
func WithAcceptApplicationJSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/json"}
}
// WithAcceptApplicationZrokV1JSON sets the Accept header to "application/zrok.v1+json".
func WithAcceptApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/zrok.v1+json"}
}
// ClientService is the interface for Client methods // ClientService is the interface for Client methods
type ClientService interface { type ClientService interface {
ChangePassword(params *ChangePasswordParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ChangePasswordOK, error) ChangePassword(params *ChangePasswordParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ChangePasswordOK, error)

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -273,11 +274,13 @@ func (o *ChangePasswordUnprocessableEntity) Code() int {
} }
func (o *ChangePasswordUnprocessableEntity) Error() string { func (o *ChangePasswordUnprocessableEntity) Error() string {
return fmt.Sprintf("[POST /changePassword][%d] changePasswordUnprocessableEntity %+v", 422, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /changePassword][%d] changePasswordUnprocessableEntity %s", 422, payload)
} }
func (o *ChangePasswordUnprocessableEntity) String() string { func (o *ChangePasswordUnprocessableEntity) String() string {
return fmt.Sprintf("[POST /changePassword][%d] changePasswordUnprocessableEntity %+v", 422, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /changePassword][%d] changePasswordUnprocessableEntity %s", 422, payload)
} }
func (o *ChangePasswordUnprocessableEntity) GetPayload() rest_model_zrok.ErrorMessage { func (o *ChangePasswordUnprocessableEntity) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -155,11 +156,13 @@ func (o *InviteBadRequest) Code() int {
} }
func (o *InviteBadRequest) Error() string { func (o *InviteBadRequest) Error() string {
return fmt.Sprintf("[POST /invite][%d] inviteBadRequest %+v", 400, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /invite][%d] inviteBadRequest %s", 400, payload)
} }
func (o *InviteBadRequest) String() string { func (o *InviteBadRequest) String() string {
return fmt.Sprintf("[POST /invite][%d] inviteBadRequest %+v", 400, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /invite][%d] inviteBadRequest %s", 400, payload)
} }
func (o *InviteBadRequest) GetPayload() rest_model_zrok.ErrorMessage { func (o *InviteBadRequest) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -85,11 +86,13 @@ func (o *LoginOK) Code() int {
} }
func (o *LoginOK) Error() string { func (o *LoginOK) Error() string {
return fmt.Sprintf("[POST /login][%d] loginOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /login][%d] loginOK %s", 200, payload)
} }
func (o *LoginOK) String() string { func (o *LoginOK) String() string {
return fmt.Sprintf("[POST /login][%d] loginOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /login][%d] loginOK %s", 200, payload)
} }
func (o *LoginOK) GetPayload() string { func (o *LoginOK) GetPayload() string {

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *RegenerateAccountTokenOK) Code() int {
} }
func (o *RegenerateAccountTokenOK) Error() string { func (o *RegenerateAccountTokenOK) Error() string {
return fmt.Sprintf("[POST /regenerateAccountToken][%d] regenerateAccountTokenOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /regenerateAccountToken][%d] regenerateAccountTokenOK %s", 200, payload)
} }
func (o *RegenerateAccountTokenOK) String() string { func (o *RegenerateAccountTokenOK) String() string {
return fmt.Sprintf("[POST /regenerateAccountToken][%d] regenerateAccountTokenOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /regenerateAccountToken][%d] regenerateAccountTokenOK %s", 200, payload)
} }
func (o *RegenerateAccountTokenOK) GetPayload() *RegenerateAccountTokenOKBody { func (o *RegenerateAccountTokenOK) GetPayload() *RegenerateAccountTokenOKBody {

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -99,11 +100,13 @@ func (o *RegisterOK) Code() int {
} }
func (o *RegisterOK) Error() string { func (o *RegisterOK) Error() string {
return fmt.Sprintf("[POST /register][%d] registerOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /register][%d] registerOK %s", 200, payload)
} }
func (o *RegisterOK) String() string { func (o *RegisterOK) String() string {
return fmt.Sprintf("[POST /register][%d] registerOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /register][%d] registerOK %s", 200, payload)
} }
func (o *RegisterOK) GetPayload() *RegisterOKBody { func (o *RegisterOK) GetPayload() *RegisterOKBody {
@ -223,11 +226,13 @@ func (o *RegisterUnprocessableEntity) Code() int {
} }
func (o *RegisterUnprocessableEntity) Error() string { func (o *RegisterUnprocessableEntity) Error() string {
return fmt.Sprintf("[POST /register][%d] registerUnprocessableEntity %+v", 422, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /register][%d] registerUnprocessableEntity %s", 422, payload)
} }
func (o *RegisterUnprocessableEntity) String() string { func (o *RegisterUnprocessableEntity) String() string {
return fmt.Sprintf("[POST /register][%d] registerUnprocessableEntity %+v", 422, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /register][%d] registerUnprocessableEntity %s", 422, payload)
} }
func (o *RegisterUnprocessableEntity) GetPayload() rest_model_zrok.ErrorMessage { func (o *RegisterUnprocessableEntity) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -211,11 +212,13 @@ func (o *ResetPasswordUnprocessableEntity) Code() int {
} }
func (o *ResetPasswordUnprocessableEntity) Error() string { func (o *ResetPasswordUnprocessableEntity) Error() string {
return fmt.Sprintf("[POST /resetPassword][%d] resetPasswordUnprocessableEntity %+v", 422, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /resetPassword][%d] resetPasswordUnprocessableEntity %s", 422, payload)
} }
func (o *ResetPasswordUnprocessableEntity) String() string { func (o *ResetPasswordUnprocessableEntity) String() string {
return fmt.Sprintf("[POST /resetPassword][%d] resetPasswordUnprocessableEntity %+v", 422, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /resetPassword][%d] resetPasswordUnprocessableEntity %s", 422, payload)
} }
func (o *ResetPasswordUnprocessableEntity) GetPayload() rest_model_zrok.ErrorMessage { func (o *ResetPasswordUnprocessableEntity) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -7,6 +7,7 @@ package account
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *VerifyOK) Code() int {
} }
func (o *VerifyOK) Error() string { func (o *VerifyOK) Error() string {
return fmt.Sprintf("[POST /verify][%d] verifyOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /verify][%d] verifyOK %s", 200, payload)
} }
func (o *VerifyOK) String() string { func (o *VerifyOK) String() string {
return fmt.Sprintf("[POST /verify][%d] verifyOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /verify][%d] verifyOK %s", 200, payload)
} }
func (o *VerifyOK) GetPayload() *VerifyOKBody { func (o *VerifyOK) GetPayload() *VerifyOKBody {

View File

@ -9,6 +9,7 @@ import (
"fmt" "fmt"
"github.com/go-openapi/runtime" "github.com/go-openapi/runtime"
httptransport "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt" "github.com/go-openapi/strfmt"
) )
@ -17,6 +18,31 @@ func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientServi
return &Client{transport: transport, formats: formats} return &Client{transport: transport, formats: formats}
} }
// New creates a new admin API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
return &Client{transport: transport, formats: strfmt.Default}
}
// New creates a new admin API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
return &Client{transport: transport, formats: strfmt.Default}
}
/* /*
Client for admin API Client for admin API
*/ */
@ -25,9 +51,53 @@ type Client struct {
formats strfmt.Registry formats strfmt.Registry
} }
// ClientOption is the option for Client methods // ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation) type ClientOption func(*runtime.ClientOperation)
// This client is generated with a few options you might find useful for your swagger spec.
//
// Feel free to add you own set of options.
// WithContentType allows the client to force the Content-Type header
// to negotiate a specific Consumer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithContentType(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{mime}
}
}
// WithContentTypeApplicationJSON sets the Content-Type header to "application/json".
func WithContentTypeApplicationJSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/json"}
}
// WithContentTypeApplicationZrokV1JSON sets the Content-Type header to "application/zrok.v1+json".
func WithContentTypeApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/zrok.v1+json"}
}
// WithAccept allows the client to force the Accept header
// to negotiate a specific Producer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithAccept(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{mime}
}
}
// WithAcceptApplicationJSON sets the Accept header to "application/json".
func WithAcceptApplicationJSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/json"}
}
// WithAcceptApplicationZrokV1JSON sets the Accept header to "application/zrok.v1+json".
func WithAcceptApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/zrok.v1+json"}
}
// ClientService is the interface for Client methods // ClientService is the interface for Client methods
type ClientService interface { type ClientService interface {
AddOrganizationMember(params *AddOrganizationMemberParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*AddOrganizationMemberCreated, error) AddOrganizationMember(params *AddOrganizationMemberParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*AddOrganizationMemberCreated, error)

View File

@ -7,6 +7,7 @@ package admin
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *CreateAccountCreated) Code() int {
} }
func (o *CreateAccountCreated) Error() string { func (o *CreateAccountCreated) Error() string {
return fmt.Sprintf("[POST /account][%d] createAccountCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /account][%d] createAccountCreated %s", 201, payload)
} }
func (o *CreateAccountCreated) String() string { func (o *CreateAccountCreated) String() string {
return fmt.Sprintf("[POST /account][%d] createAccountCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /account][%d] createAccountCreated %s", 201, payload)
} }
func (o *CreateAccountCreated) GetPayload() *CreateAccountCreatedBody { func (o *CreateAccountCreated) GetPayload() *CreateAccountCreatedBody {

View File

@ -106,11 +106,13 @@ func (o *CreateFrontendCreated) Code() int {
} }
func (o *CreateFrontendCreated) Error() string { func (o *CreateFrontendCreated) Error() string {
return fmt.Sprintf("[POST /frontend][%d] createFrontendCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /frontend][%d] createFrontendCreated %s", 201, payload)
} }
func (o *CreateFrontendCreated) String() string { func (o *CreateFrontendCreated) String() string {
return fmt.Sprintf("[POST /frontend][%d] createFrontendCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /frontend][%d] createFrontendCreated %s", 201, payload)
} }
func (o *CreateFrontendCreated) GetPayload() *CreateFrontendCreatedBody { func (o *CreateFrontendCreated) GetPayload() *CreateFrontendCreatedBody {
@ -360,7 +362,7 @@ swagger:model CreateFrontendBody
type CreateFrontendBody struct { type CreateFrontendBody struct {
// permission mode // permission mode
// Enum: [open closed] // Enum: ["open","closed"]
PermissionMode string `json:"permissionMode,omitempty"` PermissionMode string `json:"permissionMode,omitempty"`
// public name // public name

View File

@ -7,6 +7,7 @@ package admin
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *CreateIdentityCreated) Code() int {
} }
func (o *CreateIdentityCreated) Error() string { func (o *CreateIdentityCreated) Error() string {
return fmt.Sprintf("[POST /identity][%d] createIdentityCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /identity][%d] createIdentityCreated %s", 201, payload)
} }
func (o *CreateIdentityCreated) String() string { func (o *CreateIdentityCreated) String() string {
return fmt.Sprintf("[POST /identity][%d] createIdentityCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /identity][%d] createIdentityCreated %s", 201, payload)
} }
func (o *CreateIdentityCreated) GetPayload() *CreateIdentityCreatedBody { func (o *CreateIdentityCreated) GetPayload() *CreateIdentityCreatedBody {

View File

@ -7,6 +7,7 @@ package admin
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *CreateOrganizationCreated) Code() int {
} }
func (o *CreateOrganizationCreated) Error() string { func (o *CreateOrganizationCreated) Error() string {
return fmt.Sprintf("[POST /organization][%d] createOrganizationCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /organization][%d] createOrganizationCreated %s", 201, payload)
} }
func (o *CreateOrganizationCreated) String() string { func (o *CreateOrganizationCreated) String() string {
return fmt.Sprintf("[POST /organization][%d] createOrganizationCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /organization][%d] createOrganizationCreated %s", 201, payload)
} }
func (o *CreateOrganizationCreated) GetPayload() *CreateOrganizationCreatedBody { func (o *CreateOrganizationCreated) GetPayload() *CreateOrganizationCreatedBody {

View File

@ -7,6 +7,7 @@ package admin
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *ListFrontendsOK) Code() int {
} }
func (o *ListFrontendsOK) Error() string { func (o *ListFrontendsOK) Error() string {
return fmt.Sprintf("[GET /frontends][%d] listFrontendsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /frontends][%d] listFrontendsOK %s", 200, payload)
} }
func (o *ListFrontendsOK) String() string { func (o *ListFrontendsOK) String() string {
return fmt.Sprintf("[GET /frontends][%d] listFrontendsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /frontends][%d] listFrontendsOK %s", 200, payload)
} }
func (o *ListFrontendsOK) GetPayload() []*ListFrontendsOKBodyItems0 { func (o *ListFrontendsOK) GetPayload() []*ListFrontendsOKBodyItems0 {

View File

@ -7,6 +7,7 @@ package admin
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
"strconv" "strconv"
@ -99,11 +100,13 @@ func (o *ListOrganizationMembersOK) Code() int {
} }
func (o *ListOrganizationMembersOK) Error() string { func (o *ListOrganizationMembersOK) Error() string {
return fmt.Sprintf("[POST /organization/list][%d] listOrganizationMembersOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /organization/list][%d] listOrganizationMembersOK %s", 200, payload)
} }
func (o *ListOrganizationMembersOK) String() string { func (o *ListOrganizationMembersOK) String() string {
return fmt.Sprintf("[POST /organization/list][%d] listOrganizationMembersOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /organization/list][%d] listOrganizationMembersOK %s", 200, payload)
} }
func (o *ListOrganizationMembersOK) GetPayload() *ListOrganizationMembersOKBody { func (o *ListOrganizationMembersOK) GetPayload() *ListOrganizationMembersOKBody {

View File

@ -7,6 +7,7 @@ package admin
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
"strconv" "strconv"
@ -93,11 +94,13 @@ func (o *ListOrganizationsOK) Code() int {
} }
func (o *ListOrganizationsOK) Error() string { func (o *ListOrganizationsOK) Error() string {
return fmt.Sprintf("[GET /organizations][%d] listOrganizationsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /organizations][%d] listOrganizationsOK %s", 200, payload)
} }
func (o *ListOrganizationsOK) String() string { func (o *ListOrganizationsOK) String() string {
return fmt.Sprintf("[GET /organizations][%d] listOrganizationsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /organizations][%d] listOrganizationsOK %s", 200, payload)
} }
func (o *ListOrganizationsOK) GetPayload() *ListOrganizationsOKBody { func (o *ListOrganizationsOK) GetPayload() *ListOrganizationsOKBody {

View File

@ -0,0 +1,150 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the swagger generate command
import (
"fmt"
"github.com/go-openapi/runtime"
httptransport "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt"
)
// New creates a new agent API client.
func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
return &Client{transport: transport, formats: formats}
}
// New creates a new agent API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
return &Client{transport: transport, formats: strfmt.Default}
}
// New creates a new agent API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
return &Client{transport: transport, formats: strfmt.Default}
}
/*
Client for agent API
*/
type Client struct {
transport runtime.ClientTransport
formats strfmt.Registry
}
// ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation)
// This client is generated with a few options you might find useful for your swagger spec.
//
// Feel free to add you own set of options.
// WithContentType allows the client to force the Content-Type header
// to negotiate a specific Consumer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithContentType(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{mime}
}
}
// WithContentTypeApplicationJSON sets the Content-Type header to "application/json".
func WithContentTypeApplicationJSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/json"}
}
// WithContentTypeApplicationZrokV1JSON sets the Content-Type header to "application/zrok.v1+json".
func WithContentTypeApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/zrok.v1+json"}
}
// WithAccept allows the client to force the Accept header
// to negotiate a specific Producer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithAccept(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{mime}
}
}
// WithAcceptApplicationJSON sets the Accept header to "application/json".
func WithAcceptApplicationJSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/json"}
}
// WithAcceptApplicationZrokV1JSON sets the Accept header to "application/zrok.v1+json".
func WithAcceptApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/zrok.v1+json"}
}
// ClientService is the interface for Client methods
type ClientService interface {
AgentStatus(params *AgentStatusParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*AgentStatusOK, error)
SetTransport(transport runtime.ClientTransport)
}
/*
AgentStatus agent status API
*/
func (a *Client) AgentStatus(params *AgentStatusParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*AgentStatusOK, error) {
// TODO: Validate the params before sending
if params == nil {
params = NewAgentStatusParams()
}
op := &runtime.ClientOperation{
ID: "agentStatus",
Method: "POST",
PathPattern: "/agent/status",
ProducesMediaTypes: []string{"application/zrok.v1+json"},
ConsumesMediaTypes: []string{"application/zrok.v1+json"},
Schemes: []string{"http"},
Params: params,
Reader: &AgentStatusReader{formats: a.formats},
AuthInfo: authInfo,
Context: params.Context,
Client: params.HTTPClient,
}
for _, opt := range opts {
opt(op)
}
result, err := a.transport.Submit(op)
if err != nil {
return nil, err
}
success, ok := result.(*AgentStatusOK)
if ok {
return success, nil
}
// unexpected success response
// safeguard: normally, absent a default response, unknown success responses return an error above: so this is a codegen issue
msg := fmt.Sprintf("unexpected success response for agentStatus: API contract not enforced by server. Client expected to get an error, but got: %T", result)
panic(msg)
}
// SetTransport changes the transport on the client
func (a *Client) SetTransport(transport runtime.ClientTransport) {
a.transport = transport
}

View File

@ -0,0 +1,146 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the swagger generate command
import (
"context"
"net/http"
"time"
"github.com/go-openapi/errors"
"github.com/go-openapi/runtime"
cr "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt"
)
// NewAgentStatusParams creates a new AgentStatusParams object,
// with the default timeout for this client.
//
// Default values are not hydrated, since defaults are normally applied by the API server side.
//
// To enforce default values in parameter, use SetDefaults or WithDefaults.
func NewAgentStatusParams() *AgentStatusParams {
return &AgentStatusParams{
timeout: cr.DefaultTimeout,
}
}
// NewAgentStatusParamsWithTimeout creates a new AgentStatusParams object
// with the ability to set a timeout on a request.
func NewAgentStatusParamsWithTimeout(timeout time.Duration) *AgentStatusParams {
return &AgentStatusParams{
timeout: timeout,
}
}
// NewAgentStatusParamsWithContext creates a new AgentStatusParams object
// with the ability to set a context for a request.
func NewAgentStatusParamsWithContext(ctx context.Context) *AgentStatusParams {
return &AgentStatusParams{
Context: ctx,
}
}
// NewAgentStatusParamsWithHTTPClient creates a new AgentStatusParams object
// with the ability to set a custom HTTPClient for a request.
func NewAgentStatusParamsWithHTTPClient(client *http.Client) *AgentStatusParams {
return &AgentStatusParams{
HTTPClient: client,
}
}
/*
AgentStatusParams contains all the parameters to send to the API endpoint
for the agent status operation.
Typically these are written to a http.Request.
*/
type AgentStatusParams struct {
// Body.
Body AgentStatusBody
timeout time.Duration
Context context.Context
HTTPClient *http.Client
}
// WithDefaults hydrates default values in the agent status params (not the query body).
//
// All values with no default are reset to their zero value.
func (o *AgentStatusParams) WithDefaults() *AgentStatusParams {
o.SetDefaults()
return o
}
// SetDefaults hydrates default values in the agent status params (not the query body).
//
// All values with no default are reset to their zero value.
func (o *AgentStatusParams) SetDefaults() {
// no default values defined for this parameter
}
// WithTimeout adds the timeout to the agent status params
func (o *AgentStatusParams) WithTimeout(timeout time.Duration) *AgentStatusParams {
o.SetTimeout(timeout)
return o
}
// SetTimeout adds the timeout to the agent status params
func (o *AgentStatusParams) SetTimeout(timeout time.Duration) {
o.timeout = timeout
}
// WithContext adds the context to the agent status params
func (o *AgentStatusParams) WithContext(ctx context.Context) *AgentStatusParams {
o.SetContext(ctx)
return o
}
// SetContext adds the context to the agent status params
func (o *AgentStatusParams) SetContext(ctx context.Context) {
o.Context = ctx
}
// WithHTTPClient adds the HTTPClient to the agent status params
func (o *AgentStatusParams) WithHTTPClient(client *http.Client) *AgentStatusParams {
o.SetHTTPClient(client)
return o
}
// SetHTTPClient adds the HTTPClient to the agent status params
func (o *AgentStatusParams) SetHTTPClient(client *http.Client) {
o.HTTPClient = client
}
// WithBody adds the body to the agent status params
func (o *AgentStatusParams) WithBody(body AgentStatusBody) *AgentStatusParams {
o.SetBody(body)
return o
}
// SetBody adds the body to the agent status params
func (o *AgentStatusParams) SetBody(body AgentStatusBody) {
o.Body = body
}
// WriteToRequest writes these params to a swagger request
func (o *AgentStatusParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error {
if err := r.SetTimeout(o.timeout); err != nil {
return err
}
var res []error
if err := r.SetBodyParam(o.Body); err != nil {
return err
}
if len(res) > 0 {
return errors.CompositeValidationError(res...)
}
return nil
}

View File

@ -0,0 +1,379 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the swagger generate command
import (
"context"
"encoding/json"
"fmt"
"io"
"strconv"
"github.com/go-openapi/errors"
"github.com/go-openapi/runtime"
"github.com/go-openapi/strfmt"
"github.com/go-openapi/swag"
"github.com/openziti/zrok/rest_model_zrok"
)
// AgentStatusReader is a Reader for the AgentStatus structure.
type AgentStatusReader struct {
formats strfmt.Registry
}
// ReadResponse reads a server response into the received o.
func (o *AgentStatusReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error) {
switch response.Code() {
case 200:
result := NewAgentStatusOK()
if err := result.readResponse(response, consumer, o.formats); err != nil {
return nil, err
}
return result, nil
case 401:
result := NewAgentStatusUnauthorized()
if err := result.readResponse(response, consumer, o.formats); err != nil {
return nil, err
}
return nil, result
case 500:
result := NewAgentStatusInternalServerError()
if err := result.readResponse(response, consumer, o.formats); err != nil {
return nil, err
}
return nil, result
default:
return nil, runtime.NewAPIError("[POST /agent/status] agentStatus", response, response.Code())
}
}
// NewAgentStatusOK creates a AgentStatusOK with default headers values
func NewAgentStatusOK() *AgentStatusOK {
return &AgentStatusOK{}
}
/*
AgentStatusOK describes a response with status code 200, with default header values.
ok
*/
type AgentStatusOK struct {
Payload *AgentStatusOKBody
}
// IsSuccess returns true when this agent status o k response has a 2xx status code
func (o *AgentStatusOK) IsSuccess() bool {
return true
}
// IsRedirect returns true when this agent status o k response has a 3xx status code
func (o *AgentStatusOK) IsRedirect() bool {
return false
}
// IsClientError returns true when this agent status o k response has a 4xx status code
func (o *AgentStatusOK) IsClientError() bool {
return false
}
// IsServerError returns true when this agent status o k response has a 5xx status code
func (o *AgentStatusOK) IsServerError() bool {
return false
}
// IsCode returns true when this agent status o k response a status code equal to that given
func (o *AgentStatusOK) IsCode(code int) bool {
return code == 200
}
// Code gets the status code for the agent status o k response
func (o *AgentStatusOK) Code() int {
return 200
}
func (o *AgentStatusOK) Error() string {
payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /agent/status][%d] agentStatusOK %s", 200, payload)
}
func (o *AgentStatusOK) String() string {
payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /agent/status][%d] agentStatusOK %s", 200, payload)
}
func (o *AgentStatusOK) GetPayload() *AgentStatusOKBody {
return o.Payload
}
func (o *AgentStatusOK) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error {
o.Payload = new(AgentStatusOKBody)
// response payload
if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF {
return err
}
return nil
}
// NewAgentStatusUnauthorized creates a AgentStatusUnauthorized with default headers values
func NewAgentStatusUnauthorized() *AgentStatusUnauthorized {
return &AgentStatusUnauthorized{}
}
/*
AgentStatusUnauthorized describes a response with status code 401, with default header values.
unauthorized
*/
type AgentStatusUnauthorized struct {
}
// IsSuccess returns true when this agent status unauthorized response has a 2xx status code
func (o *AgentStatusUnauthorized) IsSuccess() bool {
return false
}
// IsRedirect returns true when this agent status unauthorized response has a 3xx status code
func (o *AgentStatusUnauthorized) IsRedirect() bool {
return false
}
// IsClientError returns true when this agent status unauthorized response has a 4xx status code
func (o *AgentStatusUnauthorized) IsClientError() bool {
return true
}
// IsServerError returns true when this agent status unauthorized response has a 5xx status code
func (o *AgentStatusUnauthorized) IsServerError() bool {
return false
}
// IsCode returns true when this agent status unauthorized response a status code equal to that given
func (o *AgentStatusUnauthorized) IsCode(code int) bool {
return code == 401
}
// Code gets the status code for the agent status unauthorized response
func (o *AgentStatusUnauthorized) Code() int {
return 401
}
func (o *AgentStatusUnauthorized) Error() string {
return fmt.Sprintf("[POST /agent/status][%d] agentStatusUnauthorized", 401)
}
func (o *AgentStatusUnauthorized) String() string {
return fmt.Sprintf("[POST /agent/status][%d] agentStatusUnauthorized", 401)
}
func (o *AgentStatusUnauthorized) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error {
return nil
}
// NewAgentStatusInternalServerError creates a AgentStatusInternalServerError with default headers values
func NewAgentStatusInternalServerError() *AgentStatusInternalServerError {
return &AgentStatusInternalServerError{}
}
/*
AgentStatusInternalServerError describes a response with status code 500, with default header values.
internal server error
*/
type AgentStatusInternalServerError struct {
}
// IsSuccess returns true when this agent status internal server error response has a 2xx status code
func (o *AgentStatusInternalServerError) IsSuccess() bool {
return false
}
// IsRedirect returns true when this agent status internal server error response has a 3xx status code
func (o *AgentStatusInternalServerError) IsRedirect() bool {
return false
}
// IsClientError returns true when this agent status internal server error response has a 4xx status code
func (o *AgentStatusInternalServerError) IsClientError() bool {
return false
}
// IsServerError returns true when this agent status internal server error response has a 5xx status code
func (o *AgentStatusInternalServerError) IsServerError() bool {
return true
}
// IsCode returns true when this agent status internal server error response a status code equal to that given
func (o *AgentStatusInternalServerError) IsCode(code int) bool {
return code == 500
}
// Code gets the status code for the agent status internal server error response
func (o *AgentStatusInternalServerError) Code() int {
return 500
}
func (o *AgentStatusInternalServerError) Error() string {
return fmt.Sprintf("[POST /agent/status][%d] agentStatusInternalServerError", 500)
}
func (o *AgentStatusInternalServerError) String() string {
return fmt.Sprintf("[POST /agent/status][%d] agentStatusInternalServerError", 500)
}
func (o *AgentStatusInternalServerError) readResponse(response runtime.ClientResponse, consumer runtime.Consumer, formats strfmt.Registry) error {
return nil
}
/*
AgentStatusBody agent status body
swagger:model AgentStatusBody
*/
type AgentStatusBody struct {
// env z Id
EnvZID string `json:"envZId,omitempty"`
}
// Validate validates this agent status body
func (o *AgentStatusBody) Validate(formats strfmt.Registry) error {
return nil
}
// ContextValidate validates this agent status body based on context it is used
func (o *AgentStatusBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error {
return nil
}
// MarshalBinary interface implementation
func (o *AgentStatusBody) MarshalBinary() ([]byte, error) {
if o == nil {
return nil, nil
}
return swag.WriteJSON(o)
}
// UnmarshalBinary interface implementation
func (o *AgentStatusBody) UnmarshalBinary(b []byte) error {
var res AgentStatusBody
if err := swag.ReadJSON(b, &res); err != nil {
return err
}
*o = res
return nil
}
/*
AgentStatusOKBody agent status o k body
swagger:model AgentStatusOKBody
*/
type AgentStatusOKBody struct {
// shares
Shares []*rest_model_zrok.Share `json:"shares"`
}
// Validate validates this agent status o k body
func (o *AgentStatusOKBody) Validate(formats strfmt.Registry) error {
var res []error
if err := o.validateShares(formats); err != nil {
res = append(res, err)
}
if len(res) > 0 {
return errors.CompositeValidationError(res...)
}
return nil
}
func (o *AgentStatusOKBody) validateShares(formats strfmt.Registry) error {
if swag.IsZero(o.Shares) { // not required
return nil
}
for i := 0; i < len(o.Shares); i++ {
if swag.IsZero(o.Shares[i]) { // not required
continue
}
if o.Shares[i] != nil {
if err := o.Shares[i].Validate(formats); err != nil {
if ve, ok := err.(*errors.Validation); ok {
return ve.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
} else if ce, ok := err.(*errors.CompositeError); ok {
return ce.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
}
return err
}
}
}
return nil
}
// ContextValidate validate this agent status o k body based on the context it is used
func (o *AgentStatusOKBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error {
var res []error
if err := o.contextValidateShares(ctx, formats); err != nil {
res = append(res, err)
}
if len(res) > 0 {
return errors.CompositeValidationError(res...)
}
return nil
}
func (o *AgentStatusOKBody) contextValidateShares(ctx context.Context, formats strfmt.Registry) error {
for i := 0; i < len(o.Shares); i++ {
if o.Shares[i] != nil {
if swag.IsZero(o.Shares[i]) { // not required
return nil
}
if err := o.Shares[i].ContextValidate(ctx, formats); err != nil {
if ve, ok := err.(*errors.Validation); ok {
return ve.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
} else if ce, ok := err.(*errors.CompositeError); ok {
return ce.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
}
return err
}
}
}
return nil
}
// MarshalBinary interface implementation
func (o *AgentStatusOKBody) MarshalBinary() ([]byte, error) {
if o == nil {
return nil, nil
}
return swag.WriteJSON(o)
}
// UnmarshalBinary interface implementation
func (o *AgentStatusOKBody) UnmarshalBinary(b []byte) error {
var res AgentStatusOKBody
if err := swag.ReadJSON(b, &res); err != nil {
return err
}
*o = res
return nil
}

View File

@ -7,6 +7,7 @@ package environment
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *EnableCreated) Code() int {
} }
func (o *EnableCreated) Error() string { func (o *EnableCreated) Error() string {
return fmt.Sprintf("[POST /enable][%d] enableCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /enable][%d] enableCreated %s", 201, payload)
} }
func (o *EnableCreated) String() string { func (o *EnableCreated) String() string {
return fmt.Sprintf("[POST /enable][%d] enableCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /enable][%d] enableCreated %s", 201, payload)
} }
func (o *EnableCreated) GetPayload() *EnableCreatedBody { func (o *EnableCreated) GetPayload() *EnableCreatedBody {

View File

@ -9,6 +9,7 @@ import (
"fmt" "fmt"
"github.com/go-openapi/runtime" "github.com/go-openapi/runtime"
httptransport "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt" "github.com/go-openapi/strfmt"
) )
@ -17,6 +18,31 @@ func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientServi
return &Client{transport: transport, formats: formats} return &Client{transport: transport, formats: formats}
} }
// New creates a new environment API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
return &Client{transport: transport, formats: strfmt.Default}
}
// New creates a new environment API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
return &Client{transport: transport, formats: strfmt.Default}
}
/* /*
Client for environment API Client for environment API
*/ */
@ -25,9 +51,53 @@ type Client struct {
formats strfmt.Registry formats strfmt.Registry
} }
// ClientOption is the option for Client methods // ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation) type ClientOption func(*runtime.ClientOperation)
// This client is generated with a few options you might find useful for your swagger spec.
//
// Feel free to add you own set of options.
// WithContentType allows the client to force the Content-Type header
// to negotiate a specific Consumer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithContentType(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{mime}
}
}
// WithContentTypeApplicationJSON sets the Content-Type header to "application/json".
func WithContentTypeApplicationJSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/json"}
}
// WithContentTypeApplicationZrokV1JSON sets the Content-Type header to "application/zrok.v1+json".
func WithContentTypeApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/zrok.v1+json"}
}
// WithAccept allows the client to force the Accept header
// to negotiate a specific Producer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithAccept(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{mime}
}
}
// WithAcceptApplicationJSON sets the Accept header to "application/json".
func WithAcceptApplicationJSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/json"}
}
// WithAcceptApplicationZrokV1JSON sets the Accept header to "application/zrok.v1+json".
func WithAcceptApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/zrok.v1+json"}
}
// ClientService is the interface for Client methods // ClientService is the interface for Client methods
type ClientService interface { type ClientService interface {
Disable(params *DisableParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DisableOK, error) Disable(params *DisableParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DisableOK, error)

View File

@ -7,6 +7,7 @@ package metadata
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -141,11 +142,13 @@ func (o *ClientVersionCheckBadRequest) Code() int {
} }
func (o *ClientVersionCheckBadRequest) Error() string { func (o *ClientVersionCheckBadRequest) Error() string {
return fmt.Sprintf("[POST /clientVersionCheck][%d] clientVersionCheckBadRequest %+v", 400, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /clientVersionCheck][%d] clientVersionCheckBadRequest %s", 400, payload)
} }
func (o *ClientVersionCheckBadRequest) String() string { func (o *ClientVersionCheckBadRequest) String() string {
return fmt.Sprintf("[POST /clientVersionCheck][%d] clientVersionCheckBadRequest %+v", 400, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /clientVersionCheck][%d] clientVersionCheckBadRequest %s", 400, payload)
} }
func (o *ClientVersionCheckBadRequest) GetPayload() string { func (o *ClientVersionCheckBadRequest) GetPayload() string {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -79,11 +80,13 @@ func (o *ConfigurationOK) Code() int {
} }
func (o *ConfigurationOK) Error() string { func (o *ConfigurationOK) Error() string {
return fmt.Sprintf("[GET /configuration][%d] configurationOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /configuration][%d] configurationOK %s", 200, payload)
} }
func (o *ConfigurationOK) String() string { func (o *ConfigurationOK) String() string {
return fmt.Sprintf("[GET /configuration][%d] configurationOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /configuration][%d] configurationOK %s", 200, payload)
} }
func (o *ConfigurationOK) GetPayload() *rest_model_zrok.Configuration { func (o *ConfigurationOK) GetPayload() *rest_model_zrok.Configuration {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -85,11 +86,13 @@ func (o *GetAccountDetailOK) Code() int {
} }
func (o *GetAccountDetailOK) Error() string { func (o *GetAccountDetailOK) Error() string {
return fmt.Sprintf("[GET /detail/account][%d] getAccountDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/account][%d] getAccountDetailOK %s", 200, payload)
} }
func (o *GetAccountDetailOK) String() string { func (o *GetAccountDetailOK) String() string {
return fmt.Sprintf("[GET /detail/account][%d] getAccountDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/account][%d] getAccountDetailOK %s", 200, payload)
} }
func (o *GetAccountDetailOK) GetPayload() rest_model_zrok.Environments { func (o *GetAccountDetailOK) GetPayload() rest_model_zrok.Environments {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *GetAccountMetricsOK) Code() int {
} }
func (o *GetAccountMetricsOK) Error() string { func (o *GetAccountMetricsOK) Error() string {
return fmt.Sprintf("[GET /metrics/account][%d] getAccountMetricsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /metrics/account][%d] getAccountMetricsOK %s", 200, payload)
} }
func (o *GetAccountMetricsOK) String() string { func (o *GetAccountMetricsOK) String() string {
return fmt.Sprintf("[GET /metrics/account][%d] getAccountMetricsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /metrics/account][%d] getAccountMetricsOK %s", 200, payload)
} }
func (o *GetAccountMetricsOK) GetPayload() *rest_model_zrok.Metrics { func (o *GetAccountMetricsOK) GetPayload() *rest_model_zrok.Metrics {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *GetEnvironmentDetailOK) Code() int {
} }
func (o *GetEnvironmentDetailOK) Error() string { func (o *GetEnvironmentDetailOK) Error() string {
return fmt.Sprintf("[GET /detail/environment/{envZId}][%d] getEnvironmentDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/environment/{envZId}][%d] getEnvironmentDetailOK %s", 200, payload)
} }
func (o *GetEnvironmentDetailOK) String() string { func (o *GetEnvironmentDetailOK) String() string {
return fmt.Sprintf("[GET /detail/environment/{envZId}][%d] getEnvironmentDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/environment/{envZId}][%d] getEnvironmentDetailOK %s", 200, payload)
} }
func (o *GetEnvironmentDetailOK) GetPayload() *rest_model_zrok.EnvironmentAndResources { func (o *GetEnvironmentDetailOK) GetPayload() *rest_model_zrok.EnvironmentAndResources {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *GetEnvironmentMetricsOK) Code() int {
} }
func (o *GetEnvironmentMetricsOK) Error() string { func (o *GetEnvironmentMetricsOK) Error() string {
return fmt.Sprintf("[GET /metrics/environment/{envId}][%d] getEnvironmentMetricsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /metrics/environment/{envId}][%d] getEnvironmentMetricsOK %s", 200, payload)
} }
func (o *GetEnvironmentMetricsOK) String() string { func (o *GetEnvironmentMetricsOK) String() string {
return fmt.Sprintf("[GET /metrics/environment/{envId}][%d] getEnvironmentMetricsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /metrics/environment/{envId}][%d] getEnvironmentMetricsOK %s", 200, payload)
} }
func (o *GetEnvironmentMetricsOK) GetPayload() *rest_model_zrok.Metrics { func (o *GetEnvironmentMetricsOK) GetPayload() *rest_model_zrok.Metrics {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *GetFrontendDetailOK) Code() int {
} }
func (o *GetFrontendDetailOK) Error() string { func (o *GetFrontendDetailOK) Error() string {
return fmt.Sprintf("[GET /detail/frontend/{frontendId}][%d] getFrontendDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/frontend/{frontendId}][%d] getFrontendDetailOK %s", 200, payload)
} }
func (o *GetFrontendDetailOK) String() string { func (o *GetFrontendDetailOK) String() string {
return fmt.Sprintf("[GET /detail/frontend/{frontendId}][%d] getFrontendDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/frontend/{frontendId}][%d] getFrontendDetailOK %s", 200, payload)
} }
func (o *GetFrontendDetailOK) GetPayload() *rest_model_zrok.Frontend { func (o *GetFrontendDetailOK) GetPayload() *rest_model_zrok.Frontend {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *GetShareDetailOK) Code() int {
} }
func (o *GetShareDetailOK) Error() string { func (o *GetShareDetailOK) Error() string {
return fmt.Sprintf("[GET /detail/share/{shareToken}][%d] getShareDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/share/{shareToken}][%d] getShareDetailOK %s", 200, payload)
} }
func (o *GetShareDetailOK) String() string { func (o *GetShareDetailOK) String() string {
return fmt.Sprintf("[GET /detail/share/{shareToken}][%d] getShareDetailOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /detail/share/{shareToken}][%d] getShareDetailOK %s", 200, payload)
} }
func (o *GetShareDetailOK) GetPayload() *rest_model_zrok.Share { func (o *GetShareDetailOK) GetPayload() *rest_model_zrok.Share {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *GetShareMetricsOK) Code() int {
} }
func (o *GetShareMetricsOK) Error() string { func (o *GetShareMetricsOK) Error() string {
return fmt.Sprintf("[GET /metrics/share/{shareToken}][%d] getShareMetricsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /metrics/share/{shareToken}][%d] getShareMetricsOK %s", 200, payload)
} }
func (o *GetShareMetricsOK) String() string { func (o *GetShareMetricsOK) String() string {
return fmt.Sprintf("[GET /metrics/share/{shareToken}][%d] getShareMetricsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /metrics/share/{shareToken}][%d] getShareMetricsOK %s", 200, payload)
} }
func (o *GetShareMetricsOK) GetPayload() *rest_model_zrok.Metrics { func (o *GetShareMetricsOK) GetPayload() *rest_model_zrok.Metrics {

View File

@ -7,6 +7,7 @@ package metadata
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
"strconv" "strconv"
@ -95,11 +96,13 @@ func (o *GetSparklinesOK) Code() int {
} }
func (o *GetSparklinesOK) Error() string { func (o *GetSparklinesOK) Error() string {
return fmt.Sprintf("[POST /sparklines][%d] getSparklinesOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /sparklines][%d] getSparklinesOK %s", 200, payload)
} }
func (o *GetSparklinesOK) String() string { func (o *GetSparklinesOK) String() string {
return fmt.Sprintf("[POST /sparklines][%d] getSparklinesOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /sparklines][%d] getSparklinesOK %s", 200, payload)
} }
func (o *GetSparklinesOK) GetPayload() *GetSparklinesOKBody { func (o *GetSparklinesOK) GetPayload() *GetSparklinesOKBody {

View File

@ -7,6 +7,7 @@ package metadata
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
"strconv" "strconv"
@ -87,11 +88,13 @@ func (o *ListMembershipsOK) Code() int {
} }
func (o *ListMembershipsOK) Error() string { func (o *ListMembershipsOK) Error() string {
return fmt.Sprintf("[GET /memberships][%d] listMembershipsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /memberships][%d] listMembershipsOK %s", 200, payload)
} }
func (o *ListMembershipsOK) String() string { func (o *ListMembershipsOK) String() string {
return fmt.Sprintf("[GET /memberships][%d] listMembershipsOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /memberships][%d] listMembershipsOK %s", 200, payload)
} }
func (o *ListMembershipsOK) GetPayload() *ListMembershipsOKBody { func (o *ListMembershipsOK) GetPayload() *ListMembershipsOKBody {

View File

@ -7,6 +7,7 @@ package metadata
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
"strconv" "strconv"
@ -93,11 +94,13 @@ func (o *ListOrgMembersOK) Code() int {
} }
func (o *ListOrgMembersOK) Error() string { func (o *ListOrgMembersOK) Error() string {
return fmt.Sprintf("[GET /members/{organizationToken}][%d] listOrgMembersOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /members/{organizationToken}][%d] listOrgMembersOK %s", 200, payload)
} }
func (o *ListOrgMembersOK) String() string { func (o *ListOrgMembersOK) String() string {
return fmt.Sprintf("[GET /members/{organizationToken}][%d] listOrgMembersOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /members/{organizationToken}][%d] listOrgMembersOK %s", 200, payload)
} }
func (o *ListOrgMembersOK) GetPayload() *ListOrgMembersOKBody { func (o *ListOrgMembersOK) GetPayload() *ListOrgMembersOKBody {

View File

@ -9,6 +9,7 @@ import (
"fmt" "fmt"
"github.com/go-openapi/runtime" "github.com/go-openapi/runtime"
httptransport "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt" "github.com/go-openapi/strfmt"
) )
@ -17,6 +18,31 @@ func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientServi
return &Client{transport: transport, formats: formats} return &Client{transport: transport, formats: formats}
} }
// New creates a new metadata API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
return &Client{transport: transport, formats: strfmt.Default}
}
// New creates a new metadata API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
return &Client{transport: transport, formats: strfmt.Default}
}
/* /*
Client for metadata API Client for metadata API
*/ */
@ -25,9 +51,53 @@ type Client struct {
formats strfmt.Registry formats strfmt.Registry
} }
// ClientOption is the option for Client methods // ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation) type ClientOption func(*runtime.ClientOperation)
// This client is generated with a few options you might find useful for your swagger spec.
//
// Feel free to add you own set of options.
// WithContentType allows the client to force the Content-Type header
// to negotiate a specific Consumer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithContentType(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{mime}
}
}
// WithContentTypeApplicationJSON sets the Content-Type header to "application/json".
func WithContentTypeApplicationJSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/json"}
}
// WithContentTypeApplicationZrokV1JSON sets the Content-Type header to "application/zrok.v1+json".
func WithContentTypeApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/zrok.v1+json"}
}
// WithAccept allows the client to force the Accept header
// to negotiate a specific Producer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithAccept(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{mime}
}
}
// WithAcceptApplicationJSON sets the Accept header to "application/json".
func WithAcceptApplicationJSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/json"}
}
// WithAcceptApplicationZrokV1JSON sets the Accept header to "application/zrok.v1+json".
func WithAcceptApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/zrok.v1+json"}
}
// ClientService is the interface for Client methods // ClientService is the interface for Client methods
type ClientService interface { type ClientService interface {
ClientVersionCheck(params *ClientVersionCheckParams, opts ...ClientOption) (*ClientVersionCheckOK, error) ClientVersionCheck(params *ClientVersionCheckParams, opts ...ClientOption) (*ClientVersionCheckOK, error)

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -91,11 +92,13 @@ func (o *OrgAccountOverviewOK) Code() int {
} }
func (o *OrgAccountOverviewOK) Error() string { func (o *OrgAccountOverviewOK) Error() string {
return fmt.Sprintf("[GET /overview/{organizationToken}/{accountEmail}][%d] orgAccountOverviewOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /overview/{organizationToken}/{accountEmail}][%d] orgAccountOverviewOK %s", 200, payload)
} }
func (o *OrgAccountOverviewOK) String() string { func (o *OrgAccountOverviewOK) String() string {
return fmt.Sprintf("[GET /overview/{organizationToken}/{accountEmail}][%d] orgAccountOverviewOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /overview/{organizationToken}/{accountEmail}][%d] orgAccountOverviewOK %s", 200, payload)
} }
func (o *OrgAccountOverviewOK) GetPayload() *rest_model_zrok.Overview { func (o *OrgAccountOverviewOK) GetPayload() *rest_model_zrok.Overview {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -85,11 +86,13 @@ func (o *OverviewOK) Code() int {
} }
func (o *OverviewOK) Error() string { func (o *OverviewOK) Error() string {
return fmt.Sprintf("[GET /overview][%d] overviewOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /overview][%d] overviewOK %s", 200, payload)
} }
func (o *OverviewOK) String() string { func (o *OverviewOK) String() string {
return fmt.Sprintf("[GET /overview][%d] overviewOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /overview][%d] overviewOK %s", 200, payload)
} }
func (o *OverviewOK) GetPayload() *rest_model_zrok.Overview { func (o *OverviewOK) GetPayload() *rest_model_zrok.Overview {
@ -153,11 +156,13 @@ func (o *OverviewInternalServerError) Code() int {
} }
func (o *OverviewInternalServerError) Error() string { func (o *OverviewInternalServerError) Error() string {
return fmt.Sprintf("[GET /overview][%d] overviewInternalServerError %+v", 500, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /overview][%d] overviewInternalServerError %s", 500, payload)
} }
func (o *OverviewInternalServerError) String() string { func (o *OverviewInternalServerError) String() string {
return fmt.Sprintf("[GET /overview][%d] overviewInternalServerError %+v", 500, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /overview][%d] overviewInternalServerError %s", 500, payload)
} }
func (o *OverviewInternalServerError) GetPayload() rest_model_zrok.ErrorMessage { func (o *OverviewInternalServerError) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -7,6 +7,7 @@ package metadata
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -79,11 +80,13 @@ func (o *VersionInventoryOK) Code() int {
} }
func (o *VersionInventoryOK) Error() string { func (o *VersionInventoryOK) Error() string {
return fmt.Sprintf("[GET /versions][%d] versionInventoryOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /versions][%d] versionInventoryOK %s", 200, payload)
} }
func (o *VersionInventoryOK) String() string { func (o *VersionInventoryOK) String() string {
return fmt.Sprintf("[GET /versions][%d] versionInventoryOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /versions][%d] versionInventoryOK %s", 200, payload)
} }
func (o *VersionInventoryOK) GetPayload() *VersionInventoryOKBody { func (o *VersionInventoryOK) GetPayload() *VersionInventoryOKBody {

View File

@ -6,6 +6,7 @@ package metadata
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -79,11 +80,13 @@ func (o *VersionOK) Code() int {
} }
func (o *VersionOK) Error() string { func (o *VersionOK) Error() string {
return fmt.Sprintf("[GET /version][%d] versionOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /version][%d] versionOK %s", 200, payload)
} }
func (o *VersionOK) String() string { func (o *VersionOK) String() string {
return fmt.Sprintf("[GET /version][%d] versionOK %+v", 200, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[GET /version][%d] versionOK %s", 200, payload)
} }
func (o *VersionOK) GetPayload() rest_model_zrok.Version { func (o *VersionOK) GetPayload() rest_model_zrok.Version {

View File

@ -7,6 +7,7 @@ package share
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -97,11 +98,13 @@ func (o *AccessCreated) Code() int {
} }
func (o *AccessCreated) Error() string { func (o *AccessCreated) Error() string {
return fmt.Sprintf("[POST /access][%d] accessCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /access][%d] accessCreated %s", 201, payload)
} }
func (o *AccessCreated) String() string { func (o *AccessCreated) String() string {
return fmt.Sprintf("[POST /access][%d] accessCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /access][%d] accessCreated %s", 201, payload)
} }
func (o *AccessCreated) GetPayload() *AccessCreatedBody { func (o *AccessCreated) GetPayload() *AccessCreatedBody {

View File

@ -9,6 +9,7 @@ import (
"fmt" "fmt"
"github.com/go-openapi/runtime" "github.com/go-openapi/runtime"
httptransport "github.com/go-openapi/runtime/client"
"github.com/go-openapi/strfmt" "github.com/go-openapi/strfmt"
) )
@ -17,6 +18,31 @@ func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientServi
return &Client{transport: transport, formats: formats} return &Client{transport: transport, formats: formats}
} }
// New creates a new share API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
return &Client{transport: transport, formats: strfmt.Default}
}
// New creates a new share API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
transport := httptransport.New(host, basePath, []string{scheme})
transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
return &Client{transport: transport, formats: strfmt.Default}
}
/* /*
Client for share API Client for share API
*/ */
@ -25,9 +51,53 @@ type Client struct {
formats strfmt.Registry formats strfmt.Registry
} }
// ClientOption is the option for Client methods // ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation) type ClientOption func(*runtime.ClientOperation)
// This client is generated with a few options you might find useful for your swagger spec.
//
// Feel free to add you own set of options.
// WithContentType allows the client to force the Content-Type header
// to negotiate a specific Consumer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithContentType(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{mime}
}
}
// WithContentTypeApplicationJSON sets the Content-Type header to "application/json".
func WithContentTypeApplicationJSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/json"}
}
// WithContentTypeApplicationZrokV1JSON sets the Content-Type header to "application/zrok.v1+json".
func WithContentTypeApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ConsumesMediaTypes = []string{"application/zrok.v1+json"}
}
// WithAccept allows the client to force the Accept header
// to negotiate a specific Producer from the server.
//
// You may use this option to set arbitrary extensions to your MIME media type.
func WithAccept(mime string) ClientOption {
return func(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{mime}
}
}
// WithAcceptApplicationJSON sets the Accept header to "application/json".
func WithAcceptApplicationJSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/json"}
}
// WithAcceptApplicationZrokV1JSON sets the Accept header to "application/zrok.v1+json".
func WithAcceptApplicationZrokV1JSON(r *runtime.ClientOperation) {
r.ProducesMediaTypes = []string{"application/zrok.v1+json"}
}
// ClientService is the interface for Client methods // ClientService is the interface for Client methods
type ClientService interface { type ClientService interface {
Access(params *AccessParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*AccessCreated, error) Access(params *AccessParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*AccessCreated, error)

View File

@ -6,6 +6,7 @@ package share
// Editing this file might prove futile when you re-run the swagger generate command // Editing this file might prove futile when you re-run the swagger generate command
import ( import (
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -109,11 +110,13 @@ func (o *ShareCreated) Code() int {
} }
func (o *ShareCreated) Error() string { func (o *ShareCreated) Error() string {
return fmt.Sprintf("[POST /share][%d] shareCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /share][%d] shareCreated %s", 201, payload)
} }
func (o *ShareCreated) String() string { func (o *ShareCreated) String() string {
return fmt.Sprintf("[POST /share][%d] shareCreated %+v", 201, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /share][%d] shareCreated %s", 201, payload)
} }
func (o *ShareCreated) GetPayload() *rest_model_zrok.ShareResponse { func (o *ShareCreated) GetPayload() *rest_model_zrok.ShareResponse {
@ -401,11 +404,13 @@ func (o *ShareInternalServerError) Code() int {
} }
func (o *ShareInternalServerError) Error() string { func (o *ShareInternalServerError) Error() string {
return fmt.Sprintf("[POST /share][%d] shareInternalServerError %+v", 500, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /share][%d] shareInternalServerError %s", 500, payload)
} }
func (o *ShareInternalServerError) String() string { func (o *ShareInternalServerError) String() string {
return fmt.Sprintf("[POST /share][%d] shareInternalServerError %+v", 500, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[POST /share][%d] shareInternalServerError %s", 500, payload)
} }
func (o *ShareInternalServerError) GetPayload() rest_model_zrok.ErrorMessage { func (o *ShareInternalServerError) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -7,6 +7,7 @@ package share
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io" "io"
@ -267,11 +268,13 @@ func (o *UnshareInternalServerError) Code() int {
} }
func (o *UnshareInternalServerError) Error() string { func (o *UnshareInternalServerError) Error() string {
return fmt.Sprintf("[DELETE /unshare][%d] unshareInternalServerError %+v", 500, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[DELETE /unshare][%d] unshareInternalServerError %s", 500, payload)
} }
func (o *UnshareInternalServerError) String() string { func (o *UnshareInternalServerError) String() string {
return fmt.Sprintf("[DELETE /unshare][%d] unshareInternalServerError %+v", 500, o.Payload) payload, _ := json.Marshal(o.Payload)
return fmt.Sprintf("[DELETE /unshare][%d] unshareInternalServerError %s", 500, payload)
} }
func (o *UnshareInternalServerError) GetPayload() rest_model_zrok.ErrorMessage { func (o *UnshareInternalServerError) GetPayload() rest_model_zrok.ErrorMessage {

View File

@ -12,6 +12,7 @@ import (
"github.com/openziti/zrok/rest_client_zrok/account" "github.com/openziti/zrok/rest_client_zrok/account"
"github.com/openziti/zrok/rest_client_zrok/admin" "github.com/openziti/zrok/rest_client_zrok/admin"
"github.com/openziti/zrok/rest_client_zrok/agent"
"github.com/openziti/zrok/rest_client_zrok/environment" "github.com/openziti/zrok/rest_client_zrok/environment"
"github.com/openziti/zrok/rest_client_zrok/metadata" "github.com/openziti/zrok/rest_client_zrok/metadata"
"github.com/openziti/zrok/rest_client_zrok/share" "github.com/openziti/zrok/rest_client_zrok/share"
@ -61,6 +62,7 @@ func New(transport runtime.ClientTransport, formats strfmt.Registry) *Zrok {
cli.Transport = transport cli.Transport = transport
cli.Account = account.New(transport, formats) cli.Account = account.New(transport, formats)
cli.Admin = admin.New(transport, formats) cli.Admin = admin.New(transport, formats)
cli.Agent = agent.New(transport, formats)
cli.Environment = environment.New(transport, formats) cli.Environment = environment.New(transport, formats)
cli.Metadata = metadata.New(transport, formats) cli.Metadata = metadata.New(transport, formats)
cli.Share = share.New(transport, formats) cli.Share = share.New(transport, formats)
@ -112,6 +114,8 @@ type Zrok struct {
Admin admin.ClientService Admin admin.ClientService
Agent agent.ClientService
Environment environment.ClientService Environment environment.ClientService
Metadata metadata.ClientService Metadata metadata.ClientService
@ -126,6 +130,7 @@ func (c *Zrok) SetTransport(transport runtime.ClientTransport) {
c.Transport = transport c.Transport = transport
c.Account.SetTransport(transport) c.Account.SetTransport(transport)
c.Admin.SetTransport(transport) c.Admin.SetTransport(transport)
c.Agent.SetTransport(transport)
c.Environment.SetTransport(transport) c.Environment.SetTransport(transport)
c.Metadata.SetTransport(transport) c.Metadata.SetTransport(transport)
c.Share.SetTransport(transport) c.Share.SetTransport(transport)

View File

@ -31,7 +31,7 @@ type ShareRequest struct {
AuthUsers []*AuthUser `json:"authUsers"` AuthUsers []*AuthUser `json:"authUsers"`
// backend mode // backend mode
// Enum: [proxy web tcpTunnel udpTunnel caddy drive socks vpn] // Enum: ["proxy","web","tcpTunnel","udpTunnel","caddy","drive","socks","vpn"]
BackendMode string `json:"backendMode,omitempty"` BackendMode string `json:"backendMode,omitempty"`
// backend proxy endpoint // backend proxy endpoint
@ -50,18 +50,18 @@ type ShareRequest struct {
OauthEmailDomains []string `json:"oauthEmailDomains"` OauthEmailDomains []string `json:"oauthEmailDomains"`
// oauth provider // oauth provider
// Enum: [github google] // Enum: ["github","google"]
OauthProvider string `json:"oauthProvider,omitempty"` OauthProvider string `json:"oauthProvider,omitempty"`
// permission mode // permission mode
// Enum: [open closed] // Enum: ["open","closed"]
PermissionMode string `json:"permissionMode,omitempty"` PermissionMode string `json:"permissionMode,omitempty"`
// reserved // reserved
Reserved bool `json:"reserved,omitempty"` Reserved bool `json:"reserved,omitempty"`
// share mode // share mode
// Enum: [public private] // Enum: ["public","private"]
ShareMode string `json:"shareMode,omitempty"` ShareMode string `json:"shareMode,omitempty"`
// unique name // unique name

View File

@ -185,6 +185,53 @@ func init() {
} }
} }
}, },
"/agent/status": {
"post": {
"security": [
{
"key": []
}
],
"tags": [
"agent"
],
"operationId": "agentStatus",
"parameters": [
{
"name": "body",
"in": "body",
"schema": {
"properties": {
"envZId": {
"type": "string"
}
}
}
}
],
"responses": {
"200": {
"description": "ok",
"schema": {
"properties": {
"shares": {
"type": "array",
"items": {
"$ref": "#/definitions/share"
}
}
}
}
},
"401": {
"description": "unauthorized"
},
"500": {
"description": "internal server error"
}
}
}
},
"/changePassword": { "/changePassword": {
"post": { "post": {
"security": [ "security": [
@ -2496,6 +2543,53 @@ func init() {
} }
} }
}, },
"/agent/status": {
"post": {
"security": [
{
"key": []
}
],
"tags": [
"agent"
],
"operationId": "agentStatus",
"parameters": [
{
"name": "body",
"in": "body",
"schema": {
"properties": {
"envZId": {
"type": "string"
}
}
}
}
],
"responses": {
"200": {
"description": "ok",
"schema": {
"properties": {
"shares": {
"type": "array",
"items": {
"$ref": "#/definitions/share"
}
}
}
}
},
"401": {
"description": "unauthorized"
},
"500": {
"description": "internal server error"
}
}
}
},
"/changePassword": { "/changePassword": {
"post": { "post": {
"security": [ "security": [

View File

@ -82,7 +82,7 @@ func (o *CreateFrontend) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
type CreateFrontendBody struct { type CreateFrontendBody struct {
// permission mode // permission mode
// Enum: [open closed] // Enum: ["open","closed"]
PermissionMode string `json:"permissionMode,omitempty"` PermissionMode string `json:"permissionMode,omitempty"`
// public name // public name

View File

@ -0,0 +1,219 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the generate command
import (
"context"
"net/http"
"strconv"
"github.com/go-openapi/errors"
"github.com/go-openapi/runtime/middleware"
"github.com/go-openapi/strfmt"
"github.com/go-openapi/swag"
"github.com/openziti/zrok/rest_model_zrok"
)
// AgentStatusHandlerFunc turns a function with the right signature into a agent status handler
type AgentStatusHandlerFunc func(AgentStatusParams, *rest_model_zrok.Principal) middleware.Responder
// Handle executing the request and returning a response
func (fn AgentStatusHandlerFunc) Handle(params AgentStatusParams, principal *rest_model_zrok.Principal) middleware.Responder {
return fn(params, principal)
}
// AgentStatusHandler interface for that can handle valid agent status params
type AgentStatusHandler interface {
Handle(AgentStatusParams, *rest_model_zrok.Principal) middleware.Responder
}
// NewAgentStatus creates a new http.Handler for the agent status operation
func NewAgentStatus(ctx *middleware.Context, handler AgentStatusHandler) *AgentStatus {
return &AgentStatus{Context: ctx, Handler: handler}
}
/*
AgentStatus swagger:route POST /agent/status agent agentStatus
AgentStatus agent status API
*/
type AgentStatus struct {
Context *middleware.Context
Handler AgentStatusHandler
}
func (o *AgentStatus) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
route, rCtx, _ := o.Context.RouteInfo(r)
if rCtx != nil {
*r = *rCtx
}
var Params = NewAgentStatusParams()
uprinc, aCtx, err := o.Context.Authorize(r, route)
if err != nil {
o.Context.Respond(rw, r, route.Produces, route, err)
return
}
if aCtx != nil {
*r = *aCtx
}
var principal *rest_model_zrok.Principal
if uprinc != nil {
principal = uprinc.(*rest_model_zrok.Principal) // this is really a rest_model_zrok.Principal, I promise
}
if err := o.Context.BindValidRequest(r, route, &Params); err != nil { // bind params
o.Context.Respond(rw, r, route.Produces, route, err)
return
}
res := o.Handler.Handle(Params, principal) // actually handle the request
o.Context.Respond(rw, r, route.Produces, route, res)
}
// AgentStatusBody agent status body
//
// swagger:model AgentStatusBody
type AgentStatusBody struct {
// env z Id
EnvZID string `json:"envZId,omitempty"`
}
// Validate validates this agent status body
func (o *AgentStatusBody) Validate(formats strfmt.Registry) error {
return nil
}
// ContextValidate validates this agent status body based on context it is used
func (o *AgentStatusBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error {
return nil
}
// MarshalBinary interface implementation
func (o *AgentStatusBody) MarshalBinary() ([]byte, error) {
if o == nil {
return nil, nil
}
return swag.WriteJSON(o)
}
// UnmarshalBinary interface implementation
func (o *AgentStatusBody) UnmarshalBinary(b []byte) error {
var res AgentStatusBody
if err := swag.ReadJSON(b, &res); err != nil {
return err
}
*o = res
return nil
}
// AgentStatusOKBody agent status o k body
//
// swagger:model AgentStatusOKBody
type AgentStatusOKBody struct {
// shares
Shares []*rest_model_zrok.Share `json:"shares"`
}
// Validate validates this agent status o k body
func (o *AgentStatusOKBody) Validate(formats strfmt.Registry) error {
var res []error
if err := o.validateShares(formats); err != nil {
res = append(res, err)
}
if len(res) > 0 {
return errors.CompositeValidationError(res...)
}
return nil
}
func (o *AgentStatusOKBody) validateShares(formats strfmt.Registry) error {
if swag.IsZero(o.Shares) { // not required
return nil
}
for i := 0; i < len(o.Shares); i++ {
if swag.IsZero(o.Shares[i]) { // not required
continue
}
if o.Shares[i] != nil {
if err := o.Shares[i].Validate(formats); err != nil {
if ve, ok := err.(*errors.Validation); ok {
return ve.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
} else if ce, ok := err.(*errors.CompositeError); ok {
return ce.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
}
return err
}
}
}
return nil
}
// ContextValidate validate this agent status o k body based on the context it is used
func (o *AgentStatusOKBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error {
var res []error
if err := o.contextValidateShares(ctx, formats); err != nil {
res = append(res, err)
}
if len(res) > 0 {
return errors.CompositeValidationError(res...)
}
return nil
}
func (o *AgentStatusOKBody) contextValidateShares(ctx context.Context, formats strfmt.Registry) error {
for i := 0; i < len(o.Shares); i++ {
if o.Shares[i] != nil {
if swag.IsZero(o.Shares[i]) { // not required
return nil
}
if err := o.Shares[i].ContextValidate(ctx, formats); err != nil {
if ve, ok := err.(*errors.Validation); ok {
return ve.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
} else if ce, ok := err.(*errors.CompositeError); ok {
return ce.ValidateName("agentStatusOK" + "." + "shares" + "." + strconv.Itoa(i))
}
return err
}
}
}
return nil
}
// MarshalBinary interface implementation
func (o *AgentStatusOKBody) MarshalBinary() ([]byte, error) {
if o == nil {
return nil, nil
}
return swag.WriteJSON(o)
}
// UnmarshalBinary interface implementation
func (o *AgentStatusOKBody) UnmarshalBinary(b []byte) error {
var res AgentStatusOKBody
if err := swag.ReadJSON(b, &res); err != nil {
return err
}
*o = res
return nil
}

View File

@ -0,0 +1,74 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the swagger generate command
import (
"net/http"
"github.com/go-openapi/errors"
"github.com/go-openapi/runtime"
"github.com/go-openapi/runtime/middleware"
"github.com/go-openapi/validate"
)
// NewAgentStatusParams creates a new AgentStatusParams object
//
// There are no default values defined in the spec.
func NewAgentStatusParams() AgentStatusParams {
return AgentStatusParams{}
}
// AgentStatusParams contains all the bound params for the agent status operation
// typically these are obtained from a http.Request
//
// swagger:parameters agentStatus
type AgentStatusParams struct {
// HTTP Request Object
HTTPRequest *http.Request `json:"-"`
/*
In: body
*/
Body AgentStatusBody
}
// BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface
// for simple values it will use straight method calls.
//
// To ensure default values, the struct must have been initialized with NewAgentStatusParams() beforehand.
func (o *AgentStatusParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error {
var res []error
o.HTTPRequest = r
if runtime.HasBody(r) {
defer r.Body.Close()
var body AgentStatusBody
if err := route.Consumer.Consume(r.Body, &body); err != nil {
res = append(res, errors.NewParseError("body", "body", "", err))
} else {
// validate body object
if err := body.Validate(route.Formats); err != nil {
res = append(res, err)
}
ctx := validate.WithOperationRequest(r.Context())
if err := body.ContextValidate(ctx, route.Formats); err != nil {
res = append(res, err)
}
if len(res) == 0 {
o.Body = body
}
}
}
if len(res) > 0 {
return errors.CompositeValidationError(res...)
}
return nil
}

View File

@ -0,0 +1,107 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the swagger generate command
import (
"net/http"
"github.com/go-openapi/runtime"
)
// AgentStatusOKCode is the HTTP code returned for type AgentStatusOK
const AgentStatusOKCode int = 200
/*
AgentStatusOK ok
swagger:response agentStatusOK
*/
type AgentStatusOK struct {
/*
In: Body
*/
Payload *AgentStatusOKBody `json:"body,omitempty"`
}
// NewAgentStatusOK creates AgentStatusOK with default headers values
func NewAgentStatusOK() *AgentStatusOK {
return &AgentStatusOK{}
}
// WithPayload adds the payload to the agent status o k response
func (o *AgentStatusOK) WithPayload(payload *AgentStatusOKBody) *AgentStatusOK {
o.Payload = payload
return o
}
// SetPayload sets the payload to the agent status o k response
func (o *AgentStatusOK) SetPayload(payload *AgentStatusOKBody) {
o.Payload = payload
}
// WriteResponse to the client
func (o *AgentStatusOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) {
rw.WriteHeader(200)
if o.Payload != nil {
payload := o.Payload
if err := producer.Produce(rw, payload); err != nil {
panic(err) // let the recovery middleware deal with this
}
}
}
// AgentStatusUnauthorizedCode is the HTTP code returned for type AgentStatusUnauthorized
const AgentStatusUnauthorizedCode int = 401
/*
AgentStatusUnauthorized unauthorized
swagger:response agentStatusUnauthorized
*/
type AgentStatusUnauthorized struct {
}
// NewAgentStatusUnauthorized creates AgentStatusUnauthorized with default headers values
func NewAgentStatusUnauthorized() *AgentStatusUnauthorized {
return &AgentStatusUnauthorized{}
}
// WriteResponse to the client
func (o *AgentStatusUnauthorized) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) {
rw.Header().Del(runtime.HeaderContentType) //Remove Content-Type on empty responses
rw.WriteHeader(401)
}
// AgentStatusInternalServerErrorCode is the HTTP code returned for type AgentStatusInternalServerError
const AgentStatusInternalServerErrorCode int = 500
/*
AgentStatusInternalServerError internal server error
swagger:response agentStatusInternalServerError
*/
type AgentStatusInternalServerError struct {
}
// NewAgentStatusInternalServerError creates AgentStatusInternalServerError with default headers values
func NewAgentStatusInternalServerError() *AgentStatusInternalServerError {
return &AgentStatusInternalServerError{}
}
// WriteResponse to the client
func (o *AgentStatusInternalServerError) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) {
rw.Header().Del(runtime.HeaderContentType) //Remove Content-Type on empty responses
rw.WriteHeader(500)
}

View File

@ -0,0 +1,87 @@
// Code generated by go-swagger; DO NOT EDIT.
package agent
// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the generate command
import (
"errors"
"net/url"
golangswaggerpaths "path"
)
// AgentStatusURL generates an URL for the agent status operation
type AgentStatusURL struct {
_basePath string
}
// WithBasePath sets the base path for this url builder, only required when it's different from the
// base path specified in the swagger spec.
// When the value of the base path is an empty string
func (o *AgentStatusURL) WithBasePath(bp string) *AgentStatusURL {
o.SetBasePath(bp)
return o
}
// SetBasePath sets the base path for this url builder, only required when it's different from the
// base path specified in the swagger spec.
// When the value of the base path is an empty string
func (o *AgentStatusURL) SetBasePath(bp string) {
o._basePath = bp
}
// Build a url path and query string
func (o *AgentStatusURL) Build() (*url.URL, error) {
var _result url.URL
var _path = "/agent/status"
_basePath := o._basePath
if _basePath == "" {
_basePath = "/api/v1"
}
_result.Path = golangswaggerpaths.Join(_basePath, _path)
return &_result, nil
}
// Must is a helper function to panic when the url builder returns an error
func (o *AgentStatusURL) Must(u *url.URL, err error) *url.URL {
if err != nil {
panic(err)
}
if u == nil {
panic("url can't be nil")
}
return u
}
// String returns the string representation of the path with query string
func (o *AgentStatusURL) String() string {
return o.Must(o.Build()).String()
}
// BuildFull builds a full url with scheme, host, path and query string
func (o *AgentStatusURL) BuildFull(scheme, host string) (*url.URL, error) {
if scheme == "" {
return nil, errors.New("scheme is required for a full url on AgentStatusURL")
}
if host == "" {
return nil, errors.New("host is required for a full url on AgentStatusURL")
}
base, err := o.Build()
if err != nil {
return nil, err
}
base.Scheme = scheme
base.Host = host
return base, nil
}
// StringFull returns the string representation of a complete url
func (o *AgentStatusURL) StringFull(scheme, host string) string {
return o.Must(o.BuildFull(scheme, host)).String()
}

View File

@ -22,6 +22,7 @@ import (
"github.com/openziti/zrok/rest_model_zrok" "github.com/openziti/zrok/rest_model_zrok"
"github.com/openziti/zrok/rest_server_zrok/operations/account" "github.com/openziti/zrok/rest_server_zrok/operations/account"
"github.com/openziti/zrok/rest_server_zrok/operations/admin" "github.com/openziti/zrok/rest_server_zrok/operations/admin"
"github.com/openziti/zrok/rest_server_zrok/operations/agent"
"github.com/openziti/zrok/rest_server_zrok/operations/environment" "github.com/openziti/zrok/rest_server_zrok/operations/environment"
"github.com/openziti/zrok/rest_server_zrok/operations/metadata" "github.com/openziti/zrok/rest_server_zrok/operations/metadata"
"github.com/openziti/zrok/rest_server_zrok/operations/share" "github.com/openziti/zrok/rest_server_zrok/operations/share"
@ -55,6 +56,9 @@ func NewZrokAPI(spec *loads.Document) *ZrokAPI {
AdminAddOrganizationMemberHandler: admin.AddOrganizationMemberHandlerFunc(func(params admin.AddOrganizationMemberParams, principal *rest_model_zrok.Principal) middleware.Responder { AdminAddOrganizationMemberHandler: admin.AddOrganizationMemberHandlerFunc(func(params admin.AddOrganizationMemberParams, principal *rest_model_zrok.Principal) middleware.Responder {
return middleware.NotImplemented("operation admin.AddOrganizationMember has not yet been implemented") return middleware.NotImplemented("operation admin.AddOrganizationMember has not yet been implemented")
}), }),
AgentAgentStatusHandler: agent.AgentStatusHandlerFunc(func(params agent.AgentStatusParams, principal *rest_model_zrok.Principal) middleware.Responder {
return middleware.NotImplemented("operation agent.AgentStatus has not yet been implemented")
}),
AccountChangePasswordHandler: account.ChangePasswordHandlerFunc(func(params account.ChangePasswordParams, principal *rest_model_zrok.Principal) middleware.Responder { AccountChangePasswordHandler: account.ChangePasswordHandlerFunc(func(params account.ChangePasswordParams, principal *rest_model_zrok.Principal) middleware.Responder {
return middleware.NotImplemented("operation account.ChangePassword has not yet been implemented") return middleware.NotImplemented("operation account.ChangePassword has not yet been implemented")
}), }),
@ -241,6 +245,8 @@ type ZrokAPI struct {
ShareAccessHandler share.AccessHandler ShareAccessHandler share.AccessHandler
// AdminAddOrganizationMemberHandler sets the operation handler for the add organization member operation // AdminAddOrganizationMemberHandler sets the operation handler for the add organization member operation
AdminAddOrganizationMemberHandler admin.AddOrganizationMemberHandler AdminAddOrganizationMemberHandler admin.AddOrganizationMemberHandler
// AgentAgentStatusHandler sets the operation handler for the agent status operation
AgentAgentStatusHandler agent.AgentStatusHandler
// AccountChangePasswordHandler sets the operation handler for the change password operation // AccountChangePasswordHandler sets the operation handler for the change password operation
AccountChangePasswordHandler account.ChangePasswordHandler AccountChangePasswordHandler account.ChangePasswordHandler
// MetadataClientVersionCheckHandler sets the operation handler for the client version check operation // MetadataClientVersionCheckHandler sets the operation handler for the client version check operation
@ -416,6 +422,9 @@ func (o *ZrokAPI) Validate() error {
if o.AdminAddOrganizationMemberHandler == nil { if o.AdminAddOrganizationMemberHandler == nil {
unregistered = append(unregistered, "admin.AddOrganizationMemberHandler") unregistered = append(unregistered, "admin.AddOrganizationMemberHandler")
} }
if o.AgentAgentStatusHandler == nil {
unregistered = append(unregistered, "agent.AgentStatusHandler")
}
if o.AccountChangePasswordHandler == nil { if o.AccountChangePasswordHandler == nil {
unregistered = append(unregistered, "account.ChangePasswordHandler") unregistered = append(unregistered, "account.ChangePasswordHandler")
} }
@ -658,6 +667,10 @@ func (o *ZrokAPI) initHandlerCache() {
if o.handlers["POST"] == nil { if o.handlers["POST"] == nil {
o.handlers["POST"] = make(map[string]http.Handler) o.handlers["POST"] = make(map[string]http.Handler)
} }
o.handlers["POST"]["/agent/status"] = agent.NewAgentStatus(o.context, o.AgentAgentStatusHandler)
if o.handlers["POST"] == nil {
o.handlers["POST"] = make(map[string]http.Handler)
}
o.handlers["POST"]["/changePassword"] = account.NewChangePassword(o.context, o.AccountChangePasswordHandler) o.handlers["POST"]["/changePassword"] = account.NewChangePassword(o.context, o.AccountChangePasswordHandler)
if o.handlers["POST"] == nil { if o.handlers["POST"] == nil {
o.handlers["POST"] = make(map[string]http.Handler) o.handlers["POST"] = make(map[string]http.Handler)

View File

@ -80,7 +80,7 @@ type Server struct {
ListenLimit int `long:"listen-limit" description:"limit the number of outstanding requests"` ListenLimit int `long:"listen-limit" description:"limit the number of outstanding requests"`
KeepAlive time.Duration `long:"keep-alive" description:"sets the TCP keep-alive timeouts on accepted connections. It prunes dead TCP connections ( e.g. closing laptop mid-download)" default:"3m"` KeepAlive time.Duration `long:"keep-alive" description:"sets the TCP keep-alive timeouts on accepted connections. It prunes dead TCP connections ( e.g. closing laptop mid-download)" default:"3m"`
ReadTimeout time.Duration `long:"read-timeout" description:"maximum duration before timing out read of the request" default:"30s"` ReadTimeout time.Duration `long:"read-timeout" description:"maximum duration before timing out read of the request" default:"30s"`
WriteTimeout time.Duration `long:"write-timeout" description:"maximum duration before timing out write of the response" default:"60s"` WriteTimeout time.Duration `long:"write-timeout" description:"maximum duration before timing out write of the response" default:"30s"`
httpServerL net.Listener httpServerL net.Listener
TLSHost string `long:"tls-host" description:"the IP to listen on for tls, when not specified it's the same as --host" env:"TLS_HOST"` TLSHost string `long:"tls-host" description:"the IP to listen on for tls, when not specified it's the same as --host" env:"TLS_HOST"`

View File

@ -1,6 +1,7 @@
.openapi-generator-ignore .openapi-generator-ignore
apis/AccountApi.ts apis/AccountApi.ts
apis/AdminApi.ts apis/AdminApi.ts
apis/AgentApi.ts
apis/EnvironmentApi.ts apis/EnvironmentApi.ts
apis/MetadataApi.ts apis/MetadataApi.ts
apis/ShareApi.ts apis/ShareApi.ts
@ -9,6 +10,8 @@ index.ts
models/Access201Response.ts models/Access201Response.ts
models/AccessRequest.ts models/AccessRequest.ts
models/AddOrganizationMemberRequest.ts models/AddOrganizationMemberRequest.ts
models/AgentStatus200Response.ts
models/AgentStatusRequest.ts
models/AuthUser.ts models/AuthUser.ts
models/ChangePasswordRequest.ts models/ChangePasswordRequest.ts
models/ClientVersionCheckRequest.ts models/ClientVersionCheckRequest.ts

View File

@ -0,0 +1,68 @@
/* tslint:disable */
/* eslint-disable */
/**
* zrok
* zrok client access
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import * as runtime from '../runtime';
import type {
AgentStatus200Response,
AgentStatusRequest,
} from '../models/index';
import {
AgentStatus200ResponseFromJSON,
AgentStatus200ResponseToJSON,
AgentStatusRequestFromJSON,
AgentStatusRequestToJSON,
} from '../models/index';
export interface AgentStatusOperationRequest {
body?: AgentStatusRequest;
}
/**
*
*/
export class AgentApi extends runtime.BaseAPI {
/**
*/
async agentStatusRaw(requestParameters: AgentStatusOperationRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<runtime.ApiResponse<AgentStatus200Response>> {
const queryParameters: any = {};
const headerParameters: runtime.HTTPHeaders = {};
headerParameters['Content-Type'] = 'application/zrok.v1+json';
if (this.configuration && this.configuration.apiKey) {
headerParameters["x-token"] = await this.configuration.apiKey("x-token"); // key authentication
}
const response = await this.request({
path: `/agent/status`,
method: 'POST',
headers: headerParameters,
query: queryParameters,
body: AgentStatusRequestToJSON(requestParameters['body']),
}, initOverrides);
return new runtime.JSONApiResponse(response, (jsonValue) => AgentStatus200ResponseFromJSON(jsonValue));
}
/**
*/
async agentStatus(requestParameters: AgentStatusOperationRequest = {}, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<AgentStatus200Response> {
const response = await this.agentStatusRaw(requestParameters, initOverrides);
return await response.value();
}
}

View File

@ -2,6 +2,7 @@
/* eslint-disable */ /* eslint-disable */
export * from './AccountApi'; export * from './AccountApi';
export * from './AdminApi'; export * from './AdminApi';
export * from './AgentApi';
export * from './EnvironmentApi'; export * from './EnvironmentApi';
export * from './MetadataApi'; export * from './MetadataApi';
export * from './ShareApi'; export * from './ShareApi';

View File

@ -0,0 +1,73 @@
/* tslint:disable */
/* eslint-disable */
/**
* zrok
* zrok client access
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import { mapValues } from '../runtime';
import type { Share } from './Share';
import {
ShareFromJSON,
ShareFromJSONTyped,
ShareToJSON,
ShareToJSONTyped,
} from './Share';
/**
*
* @export
* @interface AgentStatus200Response
*/
export interface AgentStatus200Response {
/**
*
* @type {Array<Share>}
* @memberof AgentStatus200Response
*/
shares?: Array<Share>;
}
/**
* Check if a given object implements the AgentStatus200Response interface.
*/
export function instanceOfAgentStatus200Response(value: object): value is AgentStatus200Response {
return true;
}
export function AgentStatus200ResponseFromJSON(json: any): AgentStatus200Response {
return AgentStatus200ResponseFromJSONTyped(json, false);
}
export function AgentStatus200ResponseFromJSONTyped(json: any, ignoreDiscriminator: boolean): AgentStatus200Response {
if (json == null) {
return json;
}
return {
'shares': json['shares'] == null ? undefined : ((json['shares'] as Array<any>).map(ShareFromJSON)),
};
}
export function AgentStatus200ResponseToJSON(json: any): AgentStatus200Response {
return AgentStatus200ResponseToJSONTyped(json, false);
}
export function AgentStatus200ResponseToJSONTyped(value?: AgentStatus200Response | null, ignoreDiscriminator: boolean = false): any {
if (value == null) {
return value;
}
return {
'shares': value['shares'] == null ? undefined : ((value['shares'] as Array<any>).map(ShareToJSON)),
};
}

View File

@ -0,0 +1,65 @@
/* tslint:disable */
/* eslint-disable */
/**
* zrok
* zrok client access
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import { mapValues } from '../runtime';
/**
*
* @export
* @interface AgentStatusRequest
*/
export interface AgentStatusRequest {
/**
*
* @type {string}
* @memberof AgentStatusRequest
*/
envZId?: string;
}
/**
* Check if a given object implements the AgentStatusRequest interface.
*/
export function instanceOfAgentStatusRequest(value: object): value is AgentStatusRequest {
return true;
}
export function AgentStatusRequestFromJSON(json: any): AgentStatusRequest {
return AgentStatusRequestFromJSONTyped(json, false);
}
export function AgentStatusRequestFromJSONTyped(json: any, ignoreDiscriminator: boolean): AgentStatusRequest {
if (json == null) {
return json;
}
return {
'envZId': json['envZId'] == null ? undefined : json['envZId'],
};
}
export function AgentStatusRequestToJSON(json: any): AgentStatusRequest {
return AgentStatusRequestToJSONTyped(json, false);
}
export function AgentStatusRequestToJSONTyped(value?: AgentStatusRequest | null, ignoreDiscriminator: boolean = false): any {
if (value == null) {
return value;
}
return {
'envZId': value['envZId'],
};
}

View File

@ -3,6 +3,8 @@
export * from './Access201Response'; export * from './Access201Response';
export * from './AccessRequest'; export * from './AccessRequest';
export * from './AddOrganizationMemberRequest'; export * from './AddOrganizationMemberRequest';
export * from './AgentStatus200Response';
export * from './AgentStatusRequest';
export * from './AuthUser'; export * from './AuthUser';
export * from './ChangePasswordRequest'; export * from './ChangePasswordRequest';
export * from './ClientVersionCheckRequest'; export * from './ClientVersionCheckRequest';

View File

@ -5,6 +5,9 @@ docs/AccessRequest.md
docs/AccountApi.md docs/AccountApi.md
docs/AddOrganizationMemberRequest.md docs/AddOrganizationMemberRequest.md
docs/AdminApi.md docs/AdminApi.md
docs/AgentApi.md
docs/AgentStatus200Response.md
docs/AgentStatusRequest.md
docs/AuthUser.md docs/AuthUser.md
docs/ChangePasswordRequest.md docs/ChangePasswordRequest.md
docs/ClientVersionCheckRequest.md docs/ClientVersionCheckRequest.md
@ -64,6 +67,9 @@ test/test_access_request.py
test/test_account_api.py test/test_account_api.py
test/test_add_organization_member_request.py test/test_add_organization_member_request.py
test/test_admin_api.py test/test_admin_api.py
test/test_agent_api.py
test/test_agent_status200_response.py
test/test_agent_status_request.py
test/test_auth_user.py test/test_auth_user.py
test/test_change_password_request.py test/test_change_password_request.py
test/test_client_version_check_request.py test/test_client_version_check_request.py
@ -119,6 +125,7 @@ zrok_api/__init__.py
zrok_api/api/__init__.py zrok_api/api/__init__.py
zrok_api/api/account_api.py zrok_api/api/account_api.py
zrok_api/api/admin_api.py zrok_api/api/admin_api.py
zrok_api/api/agent_api.py
zrok_api/api/environment_api.py zrok_api/api/environment_api.py
zrok_api/api/metadata_api.py zrok_api/api/metadata_api.py
zrok_api/api/share_api.py zrok_api/api/share_api.py
@ -130,6 +137,8 @@ zrok_api/models/__init__.py
zrok_api/models/access201_response.py zrok_api/models/access201_response.py
zrok_api/models/access_request.py zrok_api/models/access_request.py
zrok_api/models/add_organization_member_request.py zrok_api/models/add_organization_member_request.py
zrok_api/models/agent_status200_response.py
zrok_api/models/agent_status_request.py
zrok_api/models/auth_user.py zrok_api/models/auth_user.py
zrok_api/models/change_password_request.py zrok_api/models/change_password_request.py
zrok_api/models/client_version_check_request.py zrok_api/models/client_version_check_request.py

View File

@ -114,6 +114,7 @@ Class | Method | HTTP request | Description
*AdminApi* | [**list_organizations**](docs/AdminApi.md#list_organizations) | **GET** /organizations | *AdminApi* | [**list_organizations**](docs/AdminApi.md#list_organizations) | **GET** /organizations |
*AdminApi* | [**remove_organization_member**](docs/AdminApi.md#remove_organization_member) | **POST** /organization/remove | *AdminApi* | [**remove_organization_member**](docs/AdminApi.md#remove_organization_member) | **POST** /organization/remove |
*AdminApi* | [**update_frontend**](docs/AdminApi.md#update_frontend) | **PATCH** /frontend | *AdminApi* | [**update_frontend**](docs/AdminApi.md#update_frontend) | **PATCH** /frontend |
*AgentApi* | [**agent_status**](docs/AgentApi.md#agent_status) | **POST** /agent/status |
*EnvironmentApi* | [**disable**](docs/EnvironmentApi.md#disable) | **POST** /disable | *EnvironmentApi* | [**disable**](docs/EnvironmentApi.md#disable) | **POST** /disable |
*EnvironmentApi* | [**enable**](docs/EnvironmentApi.md#enable) | **POST** /enable | *EnvironmentApi* | [**enable**](docs/EnvironmentApi.md#enable) | **POST** /enable |
*MetadataApi* | [**client_version_check**](docs/MetadataApi.md#client_version_check) | **POST** /clientVersionCheck | *MetadataApi* | [**client_version_check**](docs/MetadataApi.md#client_version_check) | **POST** /clientVersionCheck |
@ -145,6 +146,8 @@ Class | Method | HTTP request | Description
- [Access201Response](docs/Access201Response.md) - [Access201Response](docs/Access201Response.md)
- [AccessRequest](docs/AccessRequest.md) - [AccessRequest](docs/AccessRequest.md)
- [AddOrganizationMemberRequest](docs/AddOrganizationMemberRequest.md) - [AddOrganizationMemberRequest](docs/AddOrganizationMemberRequest.md)
- [AgentStatus200Response](docs/AgentStatus200Response.md)
- [AgentStatusRequest](docs/AgentStatusRequest.md)
- [AuthUser](docs/AuthUser.md) - [AuthUser](docs/AuthUser.md)
- [ChangePasswordRequest](docs/ChangePasswordRequest.md) - [ChangePasswordRequest](docs/ChangePasswordRequest.md)
- [ClientVersionCheckRequest](docs/ClientVersionCheckRequest.md) - [ClientVersionCheckRequest](docs/ClientVersionCheckRequest.md)

View File

@ -0,0 +1,86 @@
# zrok_api.AgentApi
All URIs are relative to */api/v1*
Method | HTTP request | Description
------------- | ------------- | -------------
[**agent_status**](AgentApi.md#agent_status) | **POST** /agent/status |
# **agent_status**
> AgentStatus200Response agent_status(body=body)
### Example
* Api Key Authentication (key):
```python
import zrok_api
from zrok_api.models.agent_status200_response import AgentStatus200Response
from zrok_api.models.agent_status_request import AgentStatusRequest
from zrok_api.rest import ApiException
from pprint import pprint
# Defining the host is optional and defaults to /api/v1
# See configuration.py for a list of all supported configuration parameters.
configuration = zrok_api.Configuration(
host = "/api/v1"
)
# The client must configure the authentication and authorization parameters
# in accordance with the API server security policy.
# Examples for each auth method are provided below, use the example that
# satisfies your auth use case.
# Configure API key authorization: key
configuration.api_key['key'] = os.environ["API_KEY"]
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# configuration.api_key_prefix['key'] = 'Bearer'
# Enter a context with an instance of the API client
with zrok_api.ApiClient(configuration) as api_client:
# Create an instance of the API class
api_instance = zrok_api.AgentApi(api_client)
body = zrok_api.AgentStatusRequest() # AgentStatusRequest | (optional)
try:
api_response = api_instance.agent_status(body=body)
print("The response of AgentApi->agent_status:\n")
pprint(api_response)
except Exception as e:
print("Exception when calling AgentApi->agent_status: %s\n" % e)
```
### Parameters
Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
**body** | [**AgentStatusRequest**](AgentStatusRequest.md)| | [optional]
### Return type
[**AgentStatus200Response**](AgentStatus200Response.md)
### Authorization
[key](../README.md#key)
### HTTP request headers
- **Content-Type**: application/zrok.v1+json
- **Accept**: application/zrok.v1+json
### HTTP response details
| Status code | Description | Response headers |
|-------------|-------------|------------------|
**200** | ok | - |
**401** | unauthorized | - |
**500** | internal server error | - |
[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)

View File

@ -0,0 +1,29 @@
# AgentStatus200Response
## Properties
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**shares** | [**List[Share]**](Share.md) | | [optional]
## Example
```python
from zrok_api.models.agent_status200_response import AgentStatus200Response
# TODO update the JSON string below
json = "{}"
# create an instance of AgentStatus200Response from a JSON string
agent_status200_response_instance = AgentStatus200Response.from_json(json)
# print the JSON string representation of the object
print(AgentStatus200Response.to_json())
# convert the object into a dict
agent_status200_response_dict = agent_status200_response_instance.to_dict()
# create an instance of AgentStatus200Response from a dict
agent_status200_response_from_dict = AgentStatus200Response.from_dict(agent_status200_response_dict)
```
[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)

View File

@ -0,0 +1,29 @@
# AgentStatusRequest
## Properties
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**env_zid** | **str** | | [optional]
## Example
```python
from zrok_api.models.agent_status_request import AgentStatusRequest
# TODO update the JSON string below
json = "{}"
# create an instance of AgentStatusRequest from a JSON string
agent_status_request_instance = AgentStatusRequest.from_json(json)
# print the JSON string representation of the object
print(AgentStatusRequest.to_json())
# convert the object into a dict
agent_status_request_dict = agent_status_request_instance.to_dict()
# create an instance of AgentStatusRequest from a dict
agent_status_request_from_dict = AgentStatusRequest.from_dict(agent_status_request_dict)
```
[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)

View File

@ -0,0 +1,37 @@
# coding: utf-8
"""
zrok
zrok client access
The version of the OpenAPI document: 1.0.0
Generated by OpenAPI Generator (https://openapi-generator.tech)
Do not edit the class manually.
""" # noqa: E501
import unittest
from zrok_api.api.agent_api import AgentApi
class TestAgentApi(unittest.TestCase):
"""AgentApi unit test stubs"""
def setUp(self) -> None:
self.api = AgentApi()
def tearDown(self) -> None:
pass
def test_agent_status(self) -> None:
"""Test case for agent_status
"""
pass
if __name__ == '__main__':
unittest.main()

View File

@ -0,0 +1,69 @@
# coding: utf-8
"""
zrok
zrok client access
The version of the OpenAPI document: 1.0.0
Generated by OpenAPI Generator (https://openapi-generator.tech)
Do not edit the class manually.
""" # noqa: E501
import unittest
from zrok_api.models.agent_status200_response import AgentStatus200Response
class TestAgentStatus200Response(unittest.TestCase):
"""AgentStatus200Response unit test stubs"""
def setUp(self):
pass
def tearDown(self):
pass
def make_instance(self, include_optional) -> AgentStatus200Response:
"""Test AgentStatus200Response
include_optional is a boolean, when False only required
params are included, when True both required and
optional params are included """
# uncomment below to create an instance of `AgentStatus200Response`
"""
model = AgentStatus200Response()
if include_optional:
return AgentStatus200Response(
shares = [
zrok_api.models.share.share(
share_token = '',
z_id = '',
share_mode = '',
backend_mode = '',
frontend_selection = '',
frontend_endpoint = '',
backend_proxy_endpoint = '',
reserved = True,
activity = [
zrok_api.models.spark_data_sample.sparkDataSample(
rx = 1.337,
tx = 1.337, )
],
limited = True,
created_at = 56,
updated_at = 56, )
]
)
else:
return AgentStatus200Response(
)
"""
def testAgentStatus200Response(self):
"""Test AgentStatus200Response"""
# inst_req_only = self.make_instance(include_optional=False)
# inst_req_and_optional = self.make_instance(include_optional=True)
if __name__ == '__main__':
unittest.main()

View File

@ -0,0 +1,51 @@
# coding: utf-8
"""
zrok
zrok client access
The version of the OpenAPI document: 1.0.0
Generated by OpenAPI Generator (https://openapi-generator.tech)
Do not edit the class manually.
""" # noqa: E501
import unittest
from zrok_api.models.agent_status_request import AgentStatusRequest
class TestAgentStatusRequest(unittest.TestCase):
"""AgentStatusRequest unit test stubs"""
def setUp(self):
pass
def tearDown(self):
pass
def make_instance(self, include_optional) -> AgentStatusRequest:
"""Test AgentStatusRequest
include_optional is a boolean, when False only required
params are included, when True both required and
optional params are included """
# uncomment below to create an instance of `AgentStatusRequest`
"""
model = AgentStatusRequest()
if include_optional:
return AgentStatusRequest(
env_zid = ''
)
else:
return AgentStatusRequest(
)
"""
def testAgentStatusRequest(self):
"""Test AgentStatusRequest"""
# inst_req_only = self.make_instance(include_optional=False)
# inst_req_and_optional = self.make_instance(include_optional=True)
if __name__ == '__main__':
unittest.main()

View File

@ -19,6 +19,7 @@ __version__ = "1.0.0"
# import apis into sdk package # import apis into sdk package
from zrok_api.api.account_api import AccountApi from zrok_api.api.account_api import AccountApi
from zrok_api.api.admin_api import AdminApi from zrok_api.api.admin_api import AdminApi
from zrok_api.api.agent_api import AgentApi
from zrok_api.api.environment_api import EnvironmentApi from zrok_api.api.environment_api import EnvironmentApi
from zrok_api.api.metadata_api import MetadataApi from zrok_api.api.metadata_api import MetadataApi
from zrok_api.api.share_api import ShareApi from zrok_api.api.share_api import ShareApi
@ -38,6 +39,8 @@ from zrok_api.exceptions import ApiException
from zrok_api.models.access201_response import Access201Response from zrok_api.models.access201_response import Access201Response
from zrok_api.models.access_request import AccessRequest from zrok_api.models.access_request import AccessRequest
from zrok_api.models.add_organization_member_request import AddOrganizationMemberRequest from zrok_api.models.add_organization_member_request import AddOrganizationMemberRequest
from zrok_api.models.agent_status200_response import AgentStatus200Response
from zrok_api.models.agent_status_request import AgentStatusRequest
from zrok_api.models.auth_user import AuthUser from zrok_api.models.auth_user import AuthUser
from zrok_api.models.change_password_request import ChangePasswordRequest from zrok_api.models.change_password_request import ChangePasswordRequest
from zrok_api.models.client_version_check_request import ClientVersionCheckRequest from zrok_api.models.client_version_check_request import ClientVersionCheckRequest

View File

@ -3,6 +3,7 @@
# import apis into api package # import apis into api package
from zrok_api.api.account_api import AccountApi from zrok_api.api.account_api import AccountApi
from zrok_api.api.admin_api import AdminApi from zrok_api.api.admin_api import AdminApi
from zrok_api.api.agent_api import AgentApi
from zrok_api.api.environment_api import EnvironmentApi from zrok_api.api.environment_api import EnvironmentApi
from zrok_api.api.metadata_api import MetadataApi from zrok_api.api.metadata_api import MetadataApi
from zrok_api.api.share_api import ShareApi from zrok_api.api.share_api import ShareApi

View File

@ -0,0 +1,315 @@
# coding: utf-8
"""
zrok
zrok client access
The version of the OpenAPI document: 1.0.0
Generated by OpenAPI Generator (https://openapi-generator.tech)
Do not edit the class manually.
""" # noqa: E501
import warnings
from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt
from typing import Any, Dict, List, Optional, Tuple, Union
from typing_extensions import Annotated
from typing import Optional
from zrok_api.models.agent_status200_response import AgentStatus200Response
from zrok_api.models.agent_status_request import AgentStatusRequest
from zrok_api.api_client import ApiClient, RequestSerialized
from zrok_api.api_response import ApiResponse
from zrok_api.rest import RESTResponseType
class AgentApi:
"""NOTE: This class is auto generated by OpenAPI Generator
Ref: https://openapi-generator.tech
Do not edit the class manually.
"""
def __init__(self, api_client=None) -> None:
if api_client is None:
api_client = ApiClient.get_default()
self.api_client = api_client
@validate_call
def agent_status(
self,
body: Optional[AgentStatusRequest] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Tuple[
Annotated[StrictFloat, Field(gt=0)],
Annotated[StrictFloat, Field(gt=0)]
]
] = None,
_request_auth: Optional[Dict[StrictStr, Any]] = None,
_content_type: Optional[StrictStr] = None,
_headers: Optional[Dict[StrictStr, Any]] = None,
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
) -> AgentStatus200Response:
"""agent_status
:param body:
:type body: AgentStatusRequest
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
(connection, read) timeouts.
:type _request_timeout: int, tuple(int, int), optional
:param _request_auth: set to override the auth_settings for an a single
request; this effectively ignores the
authentication in the spec for a single request.
:type _request_auth: dict, optional
:param _content_type: force content-type for the request.
:type _content_type: str, Optional
:param _headers: set to override the headers for a single
request; this effectively ignores the headers
in the spec for a single request.
:type _headers: dict, optional
:param _host_index: set to override the host_index for a single
request; this effectively ignores the host_index
in the spec for a single request.
:type _host_index: int, optional
:return: Returns the result object.
""" # noqa: E501
_param = self._agent_status_serialize(
body=body,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
_host_index=_host_index
)
_response_types_map: Dict[str, Optional[str]] = {
'200': "AgentStatus200Response",
'401': None,
'500': None,
}
response_data = self.api_client.call_api(
*_param,
_request_timeout=_request_timeout
)
response_data.read()
return self.api_client.response_deserialize(
response_data=response_data,
response_types_map=_response_types_map,
).data
@validate_call
def agent_status_with_http_info(
self,
body: Optional[AgentStatusRequest] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Tuple[
Annotated[StrictFloat, Field(gt=0)],
Annotated[StrictFloat, Field(gt=0)]
]
] = None,
_request_auth: Optional[Dict[StrictStr, Any]] = None,
_content_type: Optional[StrictStr] = None,
_headers: Optional[Dict[StrictStr, Any]] = None,
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
) -> ApiResponse[AgentStatus200Response]:
"""agent_status
:param body:
:type body: AgentStatusRequest
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
(connection, read) timeouts.
:type _request_timeout: int, tuple(int, int), optional
:param _request_auth: set to override the auth_settings for an a single
request; this effectively ignores the
authentication in the spec for a single request.
:type _request_auth: dict, optional
:param _content_type: force content-type for the request.
:type _content_type: str, Optional
:param _headers: set to override the headers for a single
request; this effectively ignores the headers
in the spec for a single request.
:type _headers: dict, optional
:param _host_index: set to override the host_index for a single
request; this effectively ignores the host_index
in the spec for a single request.
:type _host_index: int, optional
:return: Returns the result object.
""" # noqa: E501
_param = self._agent_status_serialize(
body=body,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
_host_index=_host_index
)
_response_types_map: Dict[str, Optional[str]] = {
'200': "AgentStatus200Response",
'401': None,
'500': None,
}
response_data = self.api_client.call_api(
*_param,
_request_timeout=_request_timeout
)
response_data.read()
return self.api_client.response_deserialize(
response_data=response_data,
response_types_map=_response_types_map,
)
@validate_call
def agent_status_without_preload_content(
self,
body: Optional[AgentStatusRequest] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Tuple[
Annotated[StrictFloat, Field(gt=0)],
Annotated[StrictFloat, Field(gt=0)]
]
] = None,
_request_auth: Optional[Dict[StrictStr, Any]] = None,
_content_type: Optional[StrictStr] = None,
_headers: Optional[Dict[StrictStr, Any]] = None,
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
) -> RESTResponseType:
"""agent_status
:param body:
:type body: AgentStatusRequest
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
(connection, read) timeouts.
:type _request_timeout: int, tuple(int, int), optional
:param _request_auth: set to override the auth_settings for an a single
request; this effectively ignores the
authentication in the spec for a single request.
:type _request_auth: dict, optional
:param _content_type: force content-type for the request.
:type _content_type: str, Optional
:param _headers: set to override the headers for a single
request; this effectively ignores the headers
in the spec for a single request.
:type _headers: dict, optional
:param _host_index: set to override the host_index for a single
request; this effectively ignores the host_index
in the spec for a single request.
:type _host_index: int, optional
:return: Returns the result object.
""" # noqa: E501
_param = self._agent_status_serialize(
body=body,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
_host_index=_host_index
)
_response_types_map: Dict[str, Optional[str]] = {
'200': "AgentStatus200Response",
'401': None,
'500': None,
}
response_data = self.api_client.call_api(
*_param,
_request_timeout=_request_timeout
)
return response_data.response
def _agent_status_serialize(
self,
body,
_request_auth,
_content_type,
_headers,
_host_index,
) -> RequestSerialized:
_host = None
_collection_formats: Dict[str, str] = {
}
_path_params: Dict[str, str] = {}
_query_params: List[Tuple[str, str]] = []
_header_params: Dict[str, Optional[str]] = _headers or {}
_form_params: List[Tuple[str, str]] = []
_files: Dict[
str, Union[str, bytes, List[str], List[bytes], List[Tuple[str, bytes]]]
] = {}
_body_params: Optional[bytes] = None
# process the path parameters
# process the query parameters
# process the header parameters
# process the form parameters
# process the body parameter
if body is not None:
_body_params = body
# set the HTTP header `Accept`
if 'Accept' not in _header_params:
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/zrok.v1+json'
]
)
# set the HTTP header `Content-Type`
if _content_type:
_header_params['Content-Type'] = _content_type
else:
_default_content_type = (
self.api_client.select_header_content_type(
[
'application/zrok.v1+json'
]
)
)
if _default_content_type is not None:
_header_params['Content-Type'] = _default_content_type
# authentication setting
_auth_settings: List[str] = [
'key'
]
return self.api_client.param_serialize(
method='POST',
resource_path='/agent/status',
path_params=_path_params,
query_params=_query_params,
header_params=_header_params,
body=_body_params,
post_params=_form_params,
files=_files,
auth_settings=_auth_settings,
collection_formats=_collection_formats,
_host=_host,
_request_auth=_request_auth
)

View File

@ -17,6 +17,8 @@
from zrok_api.models.access201_response import Access201Response from zrok_api.models.access201_response import Access201Response
from zrok_api.models.access_request import AccessRequest from zrok_api.models.access_request import AccessRequest
from zrok_api.models.add_organization_member_request import AddOrganizationMemberRequest from zrok_api.models.add_organization_member_request import AddOrganizationMemberRequest
from zrok_api.models.agent_status200_response import AgentStatus200Response
from zrok_api.models.agent_status_request import AgentStatusRequest
from zrok_api.models.auth_user import AuthUser from zrok_api.models.auth_user import AuthUser
from zrok_api.models.change_password_request import ChangePasswordRequest from zrok_api.models.change_password_request import ChangePasswordRequest
from zrok_api.models.client_version_check_request import ClientVersionCheckRequest from zrok_api.models.client_version_check_request import ClientVersionCheckRequest

View File

@ -0,0 +1,95 @@
# coding: utf-8
"""
zrok
zrok client access
The version of the OpenAPI document: 1.0.0
Generated by OpenAPI Generator (https://openapi-generator.tech)
Do not edit the class manually.
""" # noqa: E501
from __future__ import annotations
import pprint
import re # noqa: F401
import json
from pydantic import BaseModel, ConfigDict
from typing import Any, ClassVar, Dict, List, Optional
from zrok_api.models.share import Share
from typing import Optional, Set
from typing_extensions import Self
class AgentStatus200Response(BaseModel):
"""
AgentStatus200Response
""" # noqa: E501
shares: Optional[List[Share]] = None
__properties: ClassVar[List[str]] = ["shares"]
model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
protected_namespaces=(),
)
def to_str(self) -> str:
"""Returns the string representation of the model using alias"""
return pprint.pformat(self.model_dump(by_alias=True))
def to_json(self) -> str:
"""Returns the JSON representation of the model using alias"""
# TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead
return json.dumps(self.to_dict())
@classmethod
def from_json(cls, json_str: str) -> Optional[Self]:
"""Create an instance of AgentStatus200Response from a JSON string"""
return cls.from_dict(json.loads(json_str))
def to_dict(self) -> Dict[str, Any]:
"""Return the dictionary representation of the model using alias.
This has the following differences from calling pydantic's
`self.model_dump(by_alias=True)`:
* `None` is only added to the output dict for nullable fields that
were set at model initialization. Other fields with value `None`
are ignored.
"""
excluded_fields: Set[str] = set([
])
_dict = self.model_dump(
by_alias=True,
exclude=excluded_fields,
exclude_none=True,
)
# override the default output from pydantic by calling `to_dict()` of each item in shares (list)
_items = []
if self.shares:
for _item_shares in self.shares:
if _item_shares:
_items.append(_item_shares.to_dict())
_dict['shares'] = _items
return _dict
@classmethod
def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
"""Create an instance of AgentStatus200Response from a dict"""
if obj is None:
return None
if not isinstance(obj, dict):
return cls.model_validate(obj)
_obj = cls.model_validate({
"shares": [Share.from_dict(_item) for _item in obj["shares"]] if obj.get("shares") is not None else None
})
return _obj

View File

@ -0,0 +1,87 @@
# coding: utf-8
"""
zrok
zrok client access
The version of the OpenAPI document: 1.0.0
Generated by OpenAPI Generator (https://openapi-generator.tech)
Do not edit the class manually.
""" # noqa: E501
from __future__ import annotations
import pprint
import re # noqa: F401
import json
from pydantic import BaseModel, ConfigDict, Field, StrictStr
from typing import Any, ClassVar, Dict, List, Optional
from typing import Optional, Set
from typing_extensions import Self
class AgentStatusRequest(BaseModel):
"""
AgentStatusRequest
""" # noqa: E501
env_zid: Optional[StrictStr] = Field(default=None, alias="envZId")
__properties: ClassVar[List[str]] = ["envZId"]
model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
protected_namespaces=(),
)
def to_str(self) -> str:
"""Returns the string representation of the model using alias"""
return pprint.pformat(self.model_dump(by_alias=True))
def to_json(self) -> str:
"""Returns the JSON representation of the model using alias"""
# TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead
return json.dumps(self.to_dict())
@classmethod
def from_json(cls, json_str: str) -> Optional[Self]:
"""Create an instance of AgentStatusRequest from a JSON string"""
return cls.from_dict(json.loads(json_str))
def to_dict(self) -> Dict[str, Any]:
"""Return the dictionary representation of the model using alias.
This has the following differences from calling pydantic's
`self.model_dump(by_alias=True)`:
* `None` is only added to the output dict for nullable fields that
were set at model initialization. Other fields with value `None`
are ignored.
"""
excluded_fields: Set[str] = set([
])
_dict = self.model_dump(
by_alias=True,
exclude=excluded_fields,
exclude_none=True,
)
return _dict
@classmethod
def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
"""Create an instance of AgentStatusRequest from a dict"""
if obj is None:
return None
if not isinstance(obj, dict):
return cls.model_validate(obj)
_obj = cls.model_validate({
"envZId": obj.get("envZId")
})
return _obj

View File

@ -613,6 +613,37 @@ paths:
500: 500:
description: internal server error description: internal server error
#
# agent
#
/agent/status:
post:
tags:
- agent
security:
- key: []
operationId: agentStatus
parameters:
- name: body
in: body
schema:
properties:
envZId:
type: string
responses:
200:
description: ok
schema:
properties:
shares:
type: array
items:
$ref: "#/definitions/share"
401:
description: unauthorized
500:
description: internal server error
# #
# environment # environment
# #

View File

@ -1,6 +1,7 @@
.openapi-generator-ignore .openapi-generator-ignore
apis/AccountApi.ts apis/AccountApi.ts
apis/AdminApi.ts apis/AdminApi.ts
apis/AgentApi.ts
apis/EnvironmentApi.ts apis/EnvironmentApi.ts
apis/MetadataApi.ts apis/MetadataApi.ts
apis/ShareApi.ts apis/ShareApi.ts
@ -9,6 +10,8 @@ index.ts
models/Access201Response.ts models/Access201Response.ts
models/AccessRequest.ts models/AccessRequest.ts
models/AddOrganizationMemberRequest.ts models/AddOrganizationMemberRequest.ts
models/AgentStatus200Response.ts
models/AgentStatusRequest.ts
models/AuthUser.ts models/AuthUser.ts
models/ChangePasswordRequest.ts models/ChangePasswordRequest.ts
models/ClientVersionCheckRequest.ts models/ClientVersionCheckRequest.ts

View File

@ -0,0 +1,68 @@
/* tslint:disable */
/* eslint-disable */
/**
* zrok
* zrok client access
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import * as runtime from '../runtime';
import type {
AgentStatus200Response,
AgentStatusRequest,
} from '../models/index';
import {
AgentStatus200ResponseFromJSON,
AgentStatus200ResponseToJSON,
AgentStatusRequestFromJSON,
AgentStatusRequestToJSON,
} from '../models/index';
export interface AgentStatusOperationRequest {
body?: AgentStatusRequest;
}
/**
*
*/
export class AgentApi extends runtime.BaseAPI {
/**
*/
async agentStatusRaw(requestParameters: AgentStatusOperationRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<runtime.ApiResponse<AgentStatus200Response>> {
const queryParameters: any = {};
const headerParameters: runtime.HTTPHeaders = {};
headerParameters['Content-Type'] = 'application/zrok.v1+json';
if (this.configuration && this.configuration.apiKey) {
headerParameters["x-token"] = await this.configuration.apiKey("x-token"); // key authentication
}
const response = await this.request({
path: `/agent/status`,
method: 'POST',
headers: headerParameters,
query: queryParameters,
body: AgentStatusRequestToJSON(requestParameters['body']),
}, initOverrides);
return new runtime.JSONApiResponse(response, (jsonValue) => AgentStatus200ResponseFromJSON(jsonValue));
}
/**
*/
async agentStatus(requestParameters: AgentStatusOperationRequest = {}, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<AgentStatus200Response> {
const response = await this.agentStatusRaw(requestParameters, initOverrides);
return await response.value();
}
}

View File

@ -2,6 +2,7 @@
/* eslint-disable */ /* eslint-disable */
export * from './AccountApi'; export * from './AccountApi';
export * from './AdminApi'; export * from './AdminApi';
export * from './AgentApi';
export * from './EnvironmentApi'; export * from './EnvironmentApi';
export * from './MetadataApi'; export * from './MetadataApi';
export * from './ShareApi'; export * from './ShareApi';

View File

@ -0,0 +1,73 @@
/* tslint:disable */
/* eslint-disable */
/**
* zrok
* zrok client access
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import { mapValues } from '../runtime';
import type { Share } from './Share';
import {
ShareFromJSON,
ShareFromJSONTyped,
ShareToJSON,
ShareToJSONTyped,
} from './Share';
/**
*
* @export
* @interface AgentStatus200Response
*/
export interface AgentStatus200Response {
/**
*
* @type {Array<Share>}
* @memberof AgentStatus200Response
*/
shares?: Array<Share>;
}
/**
* Check if a given object implements the AgentStatus200Response interface.
*/
export function instanceOfAgentStatus200Response(value: object): value is AgentStatus200Response {
return true;
}
export function AgentStatus200ResponseFromJSON(json: any): AgentStatus200Response {
return AgentStatus200ResponseFromJSONTyped(json, false);
}
export function AgentStatus200ResponseFromJSONTyped(json: any, ignoreDiscriminator: boolean): AgentStatus200Response {
if (json == null) {
return json;
}
return {
'shares': json['shares'] == null ? undefined : ((json['shares'] as Array<any>).map(ShareFromJSON)),
};
}
export function AgentStatus200ResponseToJSON(json: any): AgentStatus200Response {
return AgentStatus200ResponseToJSONTyped(json, false);
}
export function AgentStatus200ResponseToJSONTyped(value?: AgentStatus200Response | null, ignoreDiscriminator: boolean = false): any {
if (value == null) {
return value;
}
return {
'shares': value['shares'] == null ? undefined : ((value['shares'] as Array<any>).map(ShareToJSON)),
};
}

View File

@ -0,0 +1,65 @@
/* tslint:disable */
/* eslint-disable */
/**
* zrok
* zrok client access
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
import { mapValues } from '../runtime';
/**
*
* @export
* @interface AgentStatusRequest
*/
export interface AgentStatusRequest {
/**
*
* @type {string}
* @memberof AgentStatusRequest
*/
envZId?: string;
}
/**
* Check if a given object implements the AgentStatusRequest interface.
*/
export function instanceOfAgentStatusRequest(value: object): value is AgentStatusRequest {
return true;
}
export function AgentStatusRequestFromJSON(json: any): AgentStatusRequest {
return AgentStatusRequestFromJSONTyped(json, false);
}
export function AgentStatusRequestFromJSONTyped(json: any, ignoreDiscriminator: boolean): AgentStatusRequest {
if (json == null) {
return json;
}
return {
'envZId': json['envZId'] == null ? undefined : json['envZId'],
};
}
export function AgentStatusRequestToJSON(json: any): AgentStatusRequest {
return AgentStatusRequestToJSONTyped(json, false);
}
export function AgentStatusRequestToJSONTyped(value?: AgentStatusRequest | null, ignoreDiscriminator: boolean = false): any {
if (value == null) {
return value;
}
return {
'envZId': value['envZId'],
};
}

View File

@ -3,6 +3,8 @@
export * from './Access201Response'; export * from './Access201Response';
export * from './AccessRequest'; export * from './AccessRequest';
export * from './AddOrganizationMemberRequest'; export * from './AddOrganizationMemberRequest';
export * from './AgentStatus200Response';
export * from './AgentStatusRequest';
export * from './AuthUser'; export * from './AuthUser';
export * from './ChangePasswordRequest'; export * from './ChangePasswordRequest';
export * from './ClientVersionCheckRequest'; export * from './ClientVersionCheckRequest';