server

package
v0.0.0-...-3febccf Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateRestoreServicePath 

func CreateRestoreServicePath() string

CreateRestoreServicePath returns the URL path to the Restore Service service create HTTP endpoint.

func DecodeCreateRequest 

func DecodeCreateRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)

DecodeCreateRequest returns a decoder for requests sent to the Restore Service create endpoint.

func DecodeDeleteRequest 

func DecodeDeleteRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)

DecodeDeleteRequest returns a decoder for requests sent to the Restore Service delete endpoint.

func DecodeGetRequest 

func DecodeGetRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)

DecodeGetRequest returns a decoder for requests sent to the Restore Service get endpoint.

func DecodeUpdateRequest 

func DecodeUpdateRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (interface{}, error)

DecodeUpdateRequest returns a decoder for requests sent to the Restore Service update endpoint.

func DeleteRestoreServicePath 

func DeleteRestoreServicePath(id string) string

DeleteRestoreServicePath returns the URL path to the Restore Service service delete HTTP endpoint.

func EncodeCreateError 

func EncodeCreateError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, formatter func(err error) goahttp.Statuser) func(context.Context, http.ResponseWriter, error) error

EncodeCreateError returns an encoder for errors returned by the create Restore Service endpoint.

func EncodeCreateResponse 

func EncodeCreateResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeCreateResponse returns an encoder for responses returned by the Restore Service create endpoint.

func EncodeDeleteResponse 

func EncodeDeleteResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeDeleteResponse returns an encoder for responses returned by the Restore Service delete endpoint.

func EncodeGetResponse 

func EncodeGetResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeGetResponse returns an encoder for responses returned by the Restore Service get endpoint.

func EncodeUpdateResponse 

func EncodeUpdateResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, interface{}) error

EncodeUpdateResponse returns an encoder for responses returned by the Restore Service update endpoint.

func GetRestoreServicePath 

func GetRestoreServicePath(id string) string

GetRestoreServicePath returns the URL path to the Restore Service service get HTTP endpoint.

func Mount 

func Mount(mux goahttp.Muxer, h *Server)

Mount configures the mux to serve the Restore Service endpoints.

func MountCreateHandler 

func MountCreateHandler(mux goahttp.Muxer, h http.Handler)

MountCreateHandler configures the mux to serve the "Restore Service" service "create" endpoint.

func MountDeleteHandler 

func MountDeleteHandler(mux goahttp.Muxer, h http.Handler)

MountDeleteHandler configures the mux to serve the "Restore Service" service "delete" endpoint.

func MountGenHTTPOpenapi3JSON 

func MountGenHTTPOpenapi3JSON(mux goahttp.Muxer, h http.Handler)

MountGenHTTPOpenapi3JSON configures the mux to serve GET request made to "/openapi3.json".

func MountGetHandler 

func MountGetHandler(mux goahttp.Muxer, h http.Handler)

MountGetHandler configures the mux to serve the "Restore Service" service "get" endpoint.

func MountUpdateHandler 

func MountUpdateHandler(mux goahttp.Muxer, h http.Handler)

MountUpdateHandler configures the mux to serve the "Restore Service" service "update" endpoint.

func NewCreateHandler 

func NewCreateHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewCreateHandler creates a HTTP handler which loads the HTTP request and calls the "Restore Service" service "create" endpoint.

func NewCreateRestore 

func NewCreateRestore(body *CreateRequestBody) *restoreservice.Restore

NewCreateRestore builds a Restore Service service create endpoint payload.

func NewDeleteHandler 

func NewDeleteHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewDeleteHandler creates a HTTP handler which loads the HTTP request and calls the "Restore Service" service "delete" endpoint.

func NewDeletePayload 

func NewDeletePayload(id string) *restoreservice.DeletePayload

NewDeletePayload builds a Restore Service service delete endpoint payload.

func NewGetHandler 

func NewGetHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewGetHandler creates a HTTP handler which loads the HTTP request and calls the "Restore Service" service "get" endpoint.

func NewGetPayload 

func NewGetPayload(id string) *restoreservice.GetPayload

NewGetPayload builds a Restore Service service get endpoint payload.

func NewUpdateHandler 

func NewUpdateHandler(
	endpoint goa.Endpoint,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
) http.Handler

NewUpdateHandler creates a HTTP handler which loads the HTTP request and calls the "Restore Service" service "update" endpoint.

func NewUpdateRestoreresult 

func NewUpdateRestoreresult(body *UpdateRequestBody) *restoreservice.Restoreresult

NewUpdateRestoreresult builds a Restore Service service update endpoint payload.

func UpdateRestoreServicePath 

func UpdateRestoreServicePath() string

UpdateRestoreServicePath returns the URL path to the Restore Service service update HTTP endpoint.

Types

type CreateBackupNotFoundResponseBody 

type CreateBackupNotFoundResponseBody struct {
	// backup resource not found
	Message string `form:"message" json:"message" xml:"message"`
}

CreateBackupNotFoundResponseBody is the type of the "Restore Service" service "create" endpoint HTTP response body for the "backup_not_found" error.

func NewCreateBackupNotFoundResponseBody 

func NewCreateBackupNotFoundResponseBody(res *restoreservice.BackupNotFound) *CreateBackupNotFoundResponseBody

NewCreateBackupNotFoundResponseBody builds the HTTP response body from the result of the "create" endpoint of the "Restore Service" service.

type CreateRequestBody 

type CreateRequestBody struct {
	// Name of pachyderm instance to restore to
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Namespace to restore to
	Namespace *string `form:"namespace,omitempty" json:"namespace,omitempty" xml:"namespace,omitempty"`
	// Kubernetes secret containing S3 storage credentials
	StorageSecret *string `form:"storage_secret,omitempty" json:"storage_secret,omitempty" xml:"storage_secret,omitempty"`
	// Key of backup tarball
	BackupLocation *string `form:"backup_location,omitempty" json:"backup_location,omitempty" xml:"backup_location,omitempty"`
}

CreateRequestBody is the type of the "Restore Service" service "create" endpoint HTTP request body.

type CreateResponseBody 

type CreateResponseBody struct {
	CreatedAt *string `form:"created_at,omitempty" json:"created_at,omitempty" xml:"created_at,omitempty"`
	UpdatedAt *string `form:"updated_at,omitempty" json:"updated_at,omitempty" xml:"updated_at,omitempty"`
	DeletedAt *string `form:"deleted_at,omitempty" json:"deleted_at,omitempty" xml:"deleted_at,omitempty"`
	ID        *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of pachyderm instance to restore to
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Namespace to restore to
	Namespace *string `form:"namespace,omitempty" json:"namespace,omitempty" xml:"namespace,omitempty"`
	// Key of backup tarball
	BackupLocation *string `form:"backup_location,omitempty" json:"backup_location,omitempty" xml:"backup_location,omitempty"`
	// Kubernetes secret containing S3 storage credentials
	StorageSecret *string `form:"storage_secret,omitempty" json:"storage_secret,omitempty" xml:"storage_secret,omitempty"`
	// base64 encoded kubernetes object
	KubernetesResource *string `form:"kubernetes_resource,omitempty" json:"kubernetes_resource,omitempty" xml:"kubernetes_resource,omitempty"`
	// base64 encoded database dump
	Database *string `form:"database,omitempty" json:"database,omitempty" xml:"database,omitempty"`
}

CreateResponseBody is the type of the "Restore Service" service "create" endpoint HTTP response body.

func NewCreateResponseBody 

func NewCreateResponseBody(res *restoreserviceviews.RestoreresultView) *CreateResponseBody

NewCreateResponseBody builds the HTTP response body from the result of the "create" endpoint of the "Restore Service" service.

type DeleteResponseBody 

type DeleteResponseBody struct {
	CreatedAt *string `form:"created_at,omitempty" json:"created_at,omitempty" xml:"created_at,omitempty"`
	UpdatedAt *string `form:"updated_at,omitempty" json:"updated_at,omitempty" xml:"updated_at,omitempty"`
	DeletedAt *string `form:"deleted_at,omitempty" json:"deleted_at,omitempty" xml:"deleted_at,omitempty"`
	ID        *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of pachyderm instance to restore to
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Namespace to restore to
	Namespace *string `form:"namespace,omitempty" json:"namespace,omitempty" xml:"namespace,omitempty"`
	// Key of backup tarball
	BackupLocation *string `form:"backup_location,omitempty" json:"backup_location,omitempty" xml:"backup_location,omitempty"`
	// Kubernetes secret containing S3 storage credentials
	StorageSecret *string `form:"storage_secret,omitempty" json:"storage_secret,omitempty" xml:"storage_secret,omitempty"`
	// base64 encoded kubernetes object
	KubernetesResource *string `form:"kubernetes_resource,omitempty" json:"kubernetes_resource,omitempty" xml:"kubernetes_resource,omitempty"`
	// base64 encoded database dump
	Database *string `form:"database,omitempty" json:"database,omitempty" xml:"database,omitempty"`
}

DeleteResponseBody is the type of the "Restore Service" service "delete" endpoint HTTP response body.

func NewDeleteResponseBody 

func NewDeleteResponseBody(res *restoreserviceviews.RestoreresultView) *DeleteResponseBody

NewDeleteResponseBody builds the HTTP response body from the result of the "delete" endpoint of the "Restore Service" service.

type ErrorNamer 

type ErrorNamer interface {
	ErrorName() string
}

ErrorNamer is an interface implemented by generated error structs that exposes the name of the error as defined in the design.

type GetResponseBody 

type GetResponseBody struct {
	CreatedAt *string `form:"created_at,omitempty" json:"created_at,omitempty" xml:"created_at,omitempty"`
	UpdatedAt *string `form:"updated_at,omitempty" json:"updated_at,omitempty" xml:"updated_at,omitempty"`
	DeletedAt *string `form:"deleted_at,omitempty" json:"deleted_at,omitempty" xml:"deleted_at,omitempty"`
	ID        *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of pachyderm instance to restore to
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Namespace to restore to
	Namespace *string `form:"namespace,omitempty" json:"namespace,omitempty" xml:"namespace,omitempty"`
	// Key of backup tarball
	BackupLocation *string `form:"backup_location,omitempty" json:"backup_location,omitempty" xml:"backup_location,omitempty"`
	// Kubernetes secret containing S3 storage credentials
	StorageSecret *string `form:"storage_secret,omitempty" json:"storage_secret,omitempty" xml:"storage_secret,omitempty"`
	// base64 encoded kubernetes object
	KubernetesResource *string `form:"kubernetes_resource,omitempty" json:"kubernetes_resource,omitempty" xml:"kubernetes_resource,omitempty"`
	// base64 encoded database dump
	Database *string `form:"database,omitempty" json:"database,omitempty" xml:"database,omitempty"`
}

GetResponseBody is the type of the "Restore Service" service "get" endpoint HTTP response body.

func NewGetResponseBody 

func NewGetResponseBody(res *restoreserviceviews.RestoreresultView) *GetResponseBody

NewGetResponseBody builds the HTTP response body from the result of the "get" endpoint of the "Restore Service" service.

type MountPoint 

type MountPoint struct {
	// Method is the name of the service method served by the mounted HTTP handler.
	Method string
	// Verb is the HTTP method used to match requests to the mounted handler.
	Verb string
	// Pattern is the HTTP request path pattern used to match requests to the
	// mounted handler.
	Pattern string
}

MountPoint holds information about the mounted endpoints.

type Server 

type Server struct {
	Mounts              []*MountPoint
	Create              http.Handler
	Get                 http.Handler
	Update              http.Handler
	Delete              http.Handler
	GenHTTPOpenapi3JSON http.Handler
}

Server lists the Restore Service service endpoint HTTP handlers.

func New 

func New(
	e *restoreservice.Endpoints,
	mux goahttp.Muxer,
	decoder func(*http.Request) goahttp.Decoder,
	encoder func(context.Context, http.ResponseWriter) goahttp.Encoder,
	errhandler func(context.Context, http.ResponseWriter, error),
	formatter func(err error) goahttp.Statuser,
	fileSystemGenHTTPOpenapi3JSON http.FileSystem,
) *Server

New instantiates HTTP handlers for all the Restore Service service endpoints using the provided encoder and decoder. The handlers are mounted on the given mux using the HTTP verb and path defined in the design. errhandler is called whenever a response fails to be encoded. formatter is used to format errors returned by the service methods prior to encoding. Both errhandler and formatter are optional and can be nil.

func (*Server) Mount 

func (s *Server) Mount(mux goahttp.Muxer)

Mount configures the mux to serve the Restore Service endpoints.

func (*Server) Service 

func (s *Server) Service() string

Service returns the name of the service served.

func (*Server) Use 

func (s *Server) Use(m func(http.Handler) http.Handler)

Use wraps the server handlers with the given middleware.

type UpdateRequestBody 

type UpdateRequestBody struct {
	CreatedAt *string `form:"created_at,omitempty" json:"created_at,omitempty" xml:"created_at,omitempty"`
	UpdatedAt *string `form:"updated_at,omitempty" json:"updated_at,omitempty" xml:"updated_at,omitempty"`
	DeletedAt *string `form:"deleted_at,omitempty" json:"deleted_at,omitempty" xml:"deleted_at,omitempty"`
	ID        *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of pachyderm instance to restore to
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Namespace to restore to
	Namespace *string `form:"namespace,omitempty" json:"namespace,omitempty" xml:"namespace,omitempty"`
	// Key of backup tarball
	BackupLocation *string `form:"backup_location,omitempty" json:"backup_location,omitempty" xml:"backup_location,omitempty"`
	// Kubernetes secret containing S3 storage credentials
	StorageSecret *string `form:"storage_secret,omitempty" json:"storage_secret,omitempty" xml:"storage_secret,omitempty"`
	// base64 encoded kubernetes object
	KubernetesResource *string `form:"kubernetes_resource,omitempty" json:"kubernetes_resource,omitempty" xml:"kubernetes_resource,omitempty"`
	// base64 encoded database dump
	Database *string `form:"database,omitempty" json:"database,omitempty" xml:"database,omitempty"`
}

UpdateRequestBody is the type of the "Restore Service" service "update" endpoint HTTP request body.

type UpdateResponseBody 

type UpdateResponseBody struct {
	CreatedAt *string `form:"created_at,omitempty" json:"created_at,omitempty" xml:"created_at,omitempty"`
	UpdatedAt *string `form:"updated_at,omitempty" json:"updated_at,omitempty" xml:"updated_at,omitempty"`
	DeletedAt *string `form:"deleted_at,omitempty" json:"deleted_at,omitempty" xml:"deleted_at,omitempty"`
	ID        *string `form:"id,omitempty" json:"id,omitempty" xml:"id,omitempty"`
	// Name of pachyderm instance to restore to
	Name *string `form:"name,omitempty" json:"name,omitempty" xml:"name,omitempty"`
	// Namespace to restore to
	Namespace *string `form:"namespace,omitempty" json:"namespace,omitempty" xml:"namespace,omitempty"`
	// Key of backup tarball
	BackupLocation *string `form:"backup_location,omitempty" json:"backup_location,omitempty" xml:"backup_location,omitempty"`
	// Kubernetes secret containing S3 storage credentials
	StorageSecret *string `form:"storage_secret,omitempty" json:"storage_secret,omitempty" xml:"storage_secret,omitempty"`
	// base64 encoded kubernetes object
	KubernetesResource *string `form:"kubernetes_resource,omitempty" json:"kubernetes_resource,omitempty" xml:"kubernetes_resource,omitempty"`
	// base64 encoded database dump
	Database *string `form:"database,omitempty" json:"database,omitempty" xml:"database,omitempty"`
}

UpdateResponseBody is the type of the "Restore Service" service "update" endpoint HTTP response body.

func NewUpdateResponseBody 

func NewUpdateResponseBody(res *restoreserviceviews.RestoreresultView) *UpdateResponseBody

NewUpdateResponseBody builds the HTTP response body from the result of the "update" endpoint of the "Restore Service" service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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