Documentation
¶
Overview ¶
Package api provides primitives to interact with the openapi HTTP API.
Code generated by github.com/oapi-codegen/oapi-codegen/v2 version v2.6.0 DO NOT EDIT.
Index ¶
- func NewAddClusterRequest(server string, name string, body AddClusterJSONRequestBody) (*http.Request, error)
- func NewAddClusterRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewAddPolicyRequest(server string, name string, body AddPolicyJSONRequestBody) (*http.Request, error)
- func NewAddPolicyRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewAddRoutineRequest(server string, name string, body AddRoutineJSONRequestBody) (*http.Request, error)
- func NewAddRoutineRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewAddStorageRequest(server string, name string, body AddStorageJSONRequestBody) (*http.Request, error)
- func NewAddStorageRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewApiDocsRequest(server string) (*http.Request, error)
- func NewApplyConfigRequest(server string) (*http.Request, error)
- func NewCancelCurrentBackupRequest(server string, name string) (*http.Request, error)
- func NewCancelRestoreRequest(server string, jobId int64) (*http.Request, error)
- func NewDeleteClusterRequest(server string, name string) (*http.Request, error)
- func NewDeletePolicyRequest(server string, name string) (*http.Request, error)
- func NewDeleteRoutineRequest(server string, name string) (*http.Request, error)
- func NewDeleteStorageRequest(server string, name string) (*http.Request, error)
- func NewDisableRoutineRequest(server string, name string) (*http.Request, error)
- func NewEnableRoutineRequest(server string, name string) (*http.Request, error)
- func NewGetCurrentBackupRequest(server string, name string) (*http.Request, error)
- func NewGetFullBackupsForRoutineRequest(server string, name string, params *GetFullBackupsForRoutineParams) (*http.Request, error)
- func NewGetFullBackupsRequest(server string, params *GetFullBackupsParams) (*http.Request, error)
- func NewGetIncrementalBackupsForRoutineRequest(server string, name string, params *GetIncrementalBackupsForRoutineParams) (*http.Request, error)
- func NewGetIncrementalBackupsRequest(server string, params *GetIncrementalBackupsParams) (*http.Request, error)
- func NewHealthRequest(server string) (*http.Request, error)
- func NewMetricsRequest(server string) (*http.Request, error)
- func NewReadAllClustersRequest(server string) (*http.Request, error)
- func NewReadAllStorageRequest(server string) (*http.Request, error)
- func NewReadClusterRequest(server string, name string) (*http.Request, error)
- func NewReadConfigRequest(server string) (*http.Request, error)
- func NewReadPoliciesRequest(server string) (*http.Request, error)
- func NewReadPolicyRequest(server string, name string) (*http.Request, error)
- func NewReadRoutineRequest(server string, name string) (*http.Request, error)
- func NewReadRoutinesRequest(server string) (*http.Request, error)
- func NewReadStorageRequest(server string, name string) (*http.Request, error)
- func NewReadyRequest(server string) (*http.Request, error)
- func NewRestoreFullRequest(server string, body RestoreFullJSONRequestBody) (*http.Request, error)
- func NewRestoreFullRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
- func NewRestoreIncrementalRequest(server string, body RestoreIncrementalJSONRequestBody) (*http.Request, error)
- func NewRestoreIncrementalRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
- func NewRestoreStatusRequest(server string, jobId int64) (*http.Request, error)
- func NewRestoreTimestampRequest(server string, body RestoreTimestampJSONRequestBody) (*http.Request, error)
- func NewRestoreTimestampRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
- func NewRetrieveConfigurationRequest(server string, name string, timestamp int64) (*http.Request, error)
- func NewRetrieveRestoreJobsRequest(server string, params *RetrieveRestoreJobsParams) (*http.Request, error)
- func NewRootRequest(server string) (*http.Request, error)
- func NewScheduleFullBackupRequest(server string, name string, params *ScheduleFullBackupParams) (*http.Request, error)
- func NewTriggerFullBackupRequest(server string, name string, params *TriggerFullBackupParams) (*http.Request, error)
- func NewTriggerIncrementalBackupRequest(server string, name string, params *TriggerIncrementalBackupParams) (*http.Request, error)
- func NewUpdateClusterRequest(server string, name string, body UpdateClusterJSONRequestBody) (*http.Request, error)
- func NewUpdateClusterRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewUpdateConfigRequest(server string, body UpdateConfigJSONRequestBody) (*http.Request, error)
- func NewUpdateConfigRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
- func NewUpdatePolicyRequest(server string, name string, body UpdatePolicyJSONRequestBody) (*http.Request, error)
- func NewUpdatePolicyRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewUpdateRoutineRequest(server string, name string, body UpdateRoutineJSONRequestBody) (*http.Request, error)
- func NewUpdateRoutineRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewUpdateStorageRequest(server string, name string, body UpdateStorageJSONRequestBody) (*http.Request, error)
- func NewUpdateStorageRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
- func NewVersionRequest(server string) (*http.Request, error)
- type AddClusterJSONRequestBody
- type AddClusterResponse
- type AddPolicyJSONRequestBody
- type AddPolicyResponse
- type AddRoutineJSONRequestBody
- type AddRoutineResponse
- type AddStorageJSONRequestBody
- type AddStorageResponse
- type ApiDocsResponse
- type ApplyConfigResponse
- type CancelCurrentBackupResponse
- type CancelRestoreResponse
- type Client
- func (c *Client) AddCluster(ctx context.Context, name string, body AddClusterJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) AddClusterWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) AddPolicy(ctx context.Context, name string, body AddPolicyJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) AddPolicyWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) AddRoutine(ctx context.Context, name string, body AddRoutineJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) AddRoutineWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) AddStorage(ctx context.Context, name string, body AddStorageJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) AddStorageWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) ApiDocs(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ApplyConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) CancelCurrentBackup(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) CancelRestore(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) DeleteCluster(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) DeletePolicy(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) DeleteRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) DeleteStorage(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) DisableRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) EnableRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) GetCurrentBackup(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) GetFullBackups(ctx context.Context, params *GetFullBackupsParams, ...) (*http.Response, error)
- func (c *Client) GetFullBackupsForRoutine(ctx context.Context, name string, params *GetFullBackupsForRoutineParams, ...) (*http.Response, error)
- func (c *Client) GetIncrementalBackups(ctx context.Context, params *GetIncrementalBackupsParams, ...) (*http.Response, error)
- func (c *Client) GetIncrementalBackupsForRoutine(ctx context.Context, name string, ...) (*http.Response, error)
- func (c *Client) Health(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) Metrics(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadAllClusters(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadAllStorage(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadCluster(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadPolicies(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadPolicy(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadRoutines(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ReadStorage(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) Ready(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) RestoreFull(ctx context.Context, body RestoreFullJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) RestoreFullWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) RestoreIncremental(ctx context.Context, body RestoreIncrementalJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) RestoreIncrementalWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) RestoreStatus(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) RestoreTimestamp(ctx context.Context, body RestoreTimestampJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) RestoreTimestampWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) RetrieveConfiguration(ctx context.Context, name string, timestamp int64, ...) (*http.Response, error)
- func (c *Client) RetrieveRestoreJobs(ctx context.Context, params *RetrieveRestoreJobsParams, ...) (*http.Response, error)
- func (c *Client) Root(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) ScheduleFullBackup(ctx context.Context, name string, params *ScheduleFullBackupParams, ...) (*http.Response, error)
- func (c *Client) TriggerFullBackup(ctx context.Context, name string, params *TriggerFullBackupParams, ...) (*http.Response, error)
- func (c *Client) TriggerIncrementalBackup(ctx context.Context, name string, params *TriggerIncrementalBackupParams, ...) (*http.Response, error)
- func (c *Client) UpdateCluster(ctx context.Context, name string, body UpdateClusterJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) UpdateClusterWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) UpdateConfig(ctx context.Context, body UpdateConfigJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) UpdateConfigWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) UpdatePolicy(ctx context.Context, name string, body UpdatePolicyJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) UpdatePolicyWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) UpdateRoutine(ctx context.Context, name string, body UpdateRoutineJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) UpdateRoutineWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) UpdateStorage(ctx context.Context, name string, body UpdateStorageJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) UpdateStorageWithBody(ctx context.Context, name string, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) Version(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
- type ClientInterface
- type ClientOption
- type ClientWithResponses
- func (c *ClientWithResponses) AddClusterWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*AddClusterResponse, error)
- func (c *ClientWithResponses) AddClusterWithResponse(ctx context.Context, name string, body AddClusterJSONRequestBody, ...) (*AddClusterResponse, error)
- func (c *ClientWithResponses) AddPolicyWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*AddPolicyResponse, error)
- func (c *ClientWithResponses) AddPolicyWithResponse(ctx context.Context, name string, body AddPolicyJSONRequestBody, ...) (*AddPolicyResponse, error)
- func (c *ClientWithResponses) AddRoutineWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*AddRoutineResponse, error)
- func (c *ClientWithResponses) AddRoutineWithResponse(ctx context.Context, name string, body AddRoutineJSONRequestBody, ...) (*AddRoutineResponse, error)
- func (c *ClientWithResponses) AddStorageWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*AddStorageResponse, error)
- func (c *ClientWithResponses) AddStorageWithResponse(ctx context.Context, name string, body AddStorageJSONRequestBody, ...) (*AddStorageResponse, error)
- func (c *ClientWithResponses) ApiDocsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ApiDocsResponse, error)
- func (c *ClientWithResponses) ApplyConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ApplyConfigResponse, error)
- func (c *ClientWithResponses) CancelCurrentBackupWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*CancelCurrentBackupResponse, error)
- func (c *ClientWithResponses) CancelRestoreWithResponse(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*CancelRestoreResponse, error)
- func (c *ClientWithResponses) DeleteClusterWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteClusterResponse, error)
- func (c *ClientWithResponses) DeletePolicyWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeletePolicyResponse, error)
- func (c *ClientWithResponses) DeleteRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteRoutineResponse, error)
- func (c *ClientWithResponses) DeleteStorageWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteStorageResponse, error)
- func (c *ClientWithResponses) DisableRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DisableRoutineResponse, error)
- func (c *ClientWithResponses) EnableRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*EnableRoutineResponse, error)
- func (c *ClientWithResponses) GetCurrentBackupWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*GetCurrentBackupResponse, error)
- func (c *ClientWithResponses) GetFullBackupsForRoutineWithResponse(ctx context.Context, name string, params *GetFullBackupsForRoutineParams, ...) (*GetFullBackupsForRoutineResponse, error)
- func (c *ClientWithResponses) GetFullBackupsWithResponse(ctx context.Context, params *GetFullBackupsParams, ...) (*GetFullBackupsResponse, error)
- func (c *ClientWithResponses) GetIncrementalBackupsForRoutineWithResponse(ctx context.Context, name string, ...) (*GetIncrementalBackupsForRoutineResponse, error)
- func (c *ClientWithResponses) GetIncrementalBackupsWithResponse(ctx context.Context, params *GetIncrementalBackupsParams, ...) (*GetIncrementalBackupsResponse, error)
- func (c *ClientWithResponses) HealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthResponse, error)
- func (c *ClientWithResponses) MetricsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*MetricsResponse, error)
- func (c *ClientWithResponses) ReadAllClustersWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadAllClustersResponse, error)
- func (c *ClientWithResponses) ReadAllStorageWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadAllStorageResponse, error)
- func (c *ClientWithResponses) ReadClusterWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadClusterResponse, error)
- func (c *ClientWithResponses) ReadConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadConfigResponse, error)
- func (c *ClientWithResponses) ReadPoliciesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadPoliciesResponse, error)
- func (c *ClientWithResponses) ReadPolicyWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadPolicyResponse, error)
- func (c *ClientWithResponses) ReadRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadRoutineResponse, error)
- func (c *ClientWithResponses) ReadRoutinesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadRoutinesResponse, error)
- func (c *ClientWithResponses) ReadStorageWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadStorageResponse, error)
- func (c *ClientWithResponses) ReadyWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadyResponse, error)
- func (c *ClientWithResponses) RestoreFullWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*RestoreFullResponse, error)
- func (c *ClientWithResponses) RestoreFullWithResponse(ctx context.Context, body RestoreFullJSONRequestBody, ...) (*RestoreFullResponse, error)
- func (c *ClientWithResponses) RestoreIncrementalWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*RestoreIncrementalResponse, error)
- func (c *ClientWithResponses) RestoreIncrementalWithResponse(ctx context.Context, body RestoreIncrementalJSONRequestBody, ...) (*RestoreIncrementalResponse, error)
- func (c *ClientWithResponses) RestoreStatusWithResponse(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*RestoreStatusResponse, error)
- func (c *ClientWithResponses) RestoreTimestampWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*RestoreTimestampResponse, error)
- func (c *ClientWithResponses) RestoreTimestampWithResponse(ctx context.Context, body RestoreTimestampJSONRequestBody, ...) (*RestoreTimestampResponse, error)
- func (c *ClientWithResponses) RetrieveConfigurationWithResponse(ctx context.Context, name string, timestamp int64, ...) (*RetrieveConfigurationResponse, error)
- func (c *ClientWithResponses) RetrieveRestoreJobsWithResponse(ctx context.Context, params *RetrieveRestoreJobsParams, ...) (*RetrieveRestoreJobsResponse, error)
- func (c *ClientWithResponses) RootWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RootResponse, error)
- func (c *ClientWithResponses) ScheduleFullBackupWithResponse(ctx context.Context, name string, params *ScheduleFullBackupParams, ...) (*ScheduleFullBackupResponse, error)
- func (c *ClientWithResponses) TriggerFullBackupWithResponse(ctx context.Context, name string, params *TriggerFullBackupParams, ...) (*TriggerFullBackupResponse, error)
- func (c *ClientWithResponses) TriggerIncrementalBackupWithResponse(ctx context.Context, name string, params *TriggerIncrementalBackupParams, ...) (*TriggerIncrementalBackupResponse, error)
- func (c *ClientWithResponses) UpdateClusterWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*UpdateClusterResponse, error)
- func (c *ClientWithResponses) UpdateClusterWithResponse(ctx context.Context, name string, body UpdateClusterJSONRequestBody, ...) (*UpdateClusterResponse, error)
- func (c *ClientWithResponses) UpdateConfigWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*UpdateConfigResponse, error)
- func (c *ClientWithResponses) UpdateConfigWithResponse(ctx context.Context, body UpdateConfigJSONRequestBody, ...) (*UpdateConfigResponse, error)
- func (c *ClientWithResponses) UpdatePolicyWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*UpdatePolicyResponse, error)
- func (c *ClientWithResponses) UpdatePolicyWithResponse(ctx context.Context, name string, body UpdatePolicyJSONRequestBody, ...) (*UpdatePolicyResponse, error)
- func (c *ClientWithResponses) UpdateRoutineWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*UpdateRoutineResponse, error)
- func (c *ClientWithResponses) UpdateRoutineWithResponse(ctx context.Context, name string, body UpdateRoutineJSONRequestBody, ...) (*UpdateRoutineResponse, error)
- func (c *ClientWithResponses) UpdateStorageWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, ...) (*UpdateStorageResponse, error)
- func (c *ClientWithResponses) UpdateStorageWithResponse(ctx context.Context, name string, body UpdateStorageJSONRequestBody, ...) (*UpdateStorageResponse, error)
- func (c *ClientWithResponses) VersionWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*VersionResponse, error)
- type ClientWithResponsesInterface
- type DeleteClusterResponse
- type DeletePolicyResponse
- type DeleteRoutineResponse
- type DeleteStorageResponse
- type DisableRoutineResponse
- type DtoAerospikeCluster
- type DtoAzureStorage
- type DtoAzureStorageClass
- type DtoAzureStorageClassData
- type DtoAzureStorageClassMetadata
- type DtoBackupCommonConfig
- type DtoBackupCommonConfigTimestampFormat
- type DtoBackupDetails
- type DtoBackupPolicy
- type DtoBackupRoutine
- type DtoCompressionPolicy
- type DtoCompressionPolicyMode
- type DtoConfig
- type DtoCredentials
- type DtoCredentialsAuthMode
- type DtoEncryptionPolicy
- type DtoEncryptionPolicyMode
- type DtoFileLoggerConfig
- type DtoGcpStorage
- type DtoGcpStorageClass
- type DtoGcpStorageClassData
- type DtoHTTPServerConfig
- type DtoJobStatus
- type DtoLocalStorage
- type DtoLoggerConfig
- type DtoLoggerConfigFormat
- type DtoLoggerConfigLevel
- type DtoMetrics
- type DtoRateLimiterConfig
- type DtoRestoreCompressionPolicy
- type DtoRestoreCompressionPolicyMode
- type DtoRestoreJobStatus
- type DtoRestoreNamespace
- type DtoRestorePolicy
- type DtoRestoreRequest
- type DtoRestoreTimestampRequest
- type DtoRetentionPolicy
- type DtoRetryPolicy
- type DtoRoutineState
- type DtoRunningJob
- type DtoS3Storage
- type DtoS3StorageClass
- type DtoS3StorageClassData
- type DtoS3StorageClassMetadata
- type DtoS3StorageS3LogLevel
- type DtoSecretAgent
- type DtoSecretAgentConnectionType
- type DtoSeedNode
- type DtoServiceConfig
- type DtoStorage
- type DtoTLS
- type DtoTimestampRestorePolicy
- type DtoVersionResponse
- type EnableRoutineResponse
- type GetCurrentBackupResponse
- type GetFullBackupsForRoutineParams
- type GetFullBackupsForRoutineResponse
- type GetFullBackupsParams
- type GetFullBackupsResponse
- type GetIncrementalBackupsForRoutineParams
- type GetIncrementalBackupsForRoutineResponse
- type GetIncrementalBackupsParams
- type GetIncrementalBackupsResponse
- type HealthResponse
- type HttpRequestDoer
- type MetricsResponse
- type ReadAllClustersResponse
- type ReadAllStorageResponse
- type ReadClusterResponse
- type ReadConfigResponse
- type ReadPoliciesResponse
- type ReadPolicyResponse
- type ReadRoutineResponse
- type ReadRoutinesResponse
- type ReadStorageResponse
- type ReadyResponse
- type RequestEditorFn
- type RestoreFullJSONRequestBody
- type RestoreFullResponse
- type RestoreIncrementalJSONRequestBody
- type RestoreIncrementalResponse
- type RestoreStatusResponse
- type RestoreTimestampJSONRequestBody
- type RestoreTimestampResponse
- type RetrieveConfigurationResponse
- type RetrieveRestoreJobsParams
- type RetrieveRestoreJobsResponse
- type RootResponse
- type ScheduleFullBackupParams
- type ScheduleFullBackupResponse
- type TriggerFullBackupParams
- type TriggerFullBackupResponse
- type TriggerIncrementalBackupParams
- type TriggerIncrementalBackupResponse
- type UpdateClusterJSONRequestBody
- type UpdateClusterResponse
- type UpdateConfigJSONRequestBody
- type UpdateConfigResponse
- type UpdatePolicyJSONRequestBody
- type UpdatePolicyResponse
- type UpdateRoutineJSONRequestBody
- type UpdateRoutineResponse
- type UpdateStorageJSONRequestBody
- type UpdateStorageResponse
- type VersionResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAddClusterRequest ¶
func NewAddClusterRequest(server string, name string, body AddClusterJSONRequestBody) (*http.Request, error)
NewAddClusterRequest calls the generic AddCluster builder with application/json body
func NewAddClusterRequestWithBody ¶
func NewAddClusterRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewAddClusterRequestWithBody generates requests for AddCluster with any type of body
func NewAddPolicyRequest ¶
func NewAddPolicyRequest(server string, name string, body AddPolicyJSONRequestBody) (*http.Request, error)
NewAddPolicyRequest calls the generic AddPolicy builder with application/json body
func NewAddPolicyRequestWithBody ¶
func NewAddPolicyRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewAddPolicyRequestWithBody generates requests for AddPolicy with any type of body
func NewAddRoutineRequest ¶
func NewAddRoutineRequest(server string, name string, body AddRoutineJSONRequestBody) (*http.Request, error)
NewAddRoutineRequest calls the generic AddRoutine builder with application/json body
func NewAddRoutineRequestWithBody ¶
func NewAddRoutineRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewAddRoutineRequestWithBody generates requests for AddRoutine with any type of body
func NewAddStorageRequest ¶
func NewAddStorageRequest(server string, name string, body AddStorageJSONRequestBody) (*http.Request, error)
NewAddStorageRequest calls the generic AddStorage builder with application/json body
func NewAddStorageRequestWithBody ¶
func NewAddStorageRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewAddStorageRequestWithBody generates requests for AddStorage with any type of body
func NewApiDocsRequest ¶
NewApiDocsRequest generates requests for ApiDocs
func NewApplyConfigRequest ¶
NewApplyConfigRequest generates requests for ApplyConfig
func NewCancelCurrentBackupRequest ¶
NewCancelCurrentBackupRequest generates requests for CancelCurrentBackup
func NewCancelRestoreRequest ¶
NewCancelRestoreRequest generates requests for CancelRestore
func NewDeleteClusterRequest ¶
NewDeleteClusterRequest generates requests for DeleteCluster
func NewDeletePolicyRequest ¶
NewDeletePolicyRequest generates requests for DeletePolicy
func NewDeleteRoutineRequest ¶
NewDeleteRoutineRequest generates requests for DeleteRoutine
func NewDeleteStorageRequest ¶
NewDeleteStorageRequest generates requests for DeleteStorage
func NewDisableRoutineRequest ¶
NewDisableRoutineRequest generates requests for DisableRoutine
func NewEnableRoutineRequest ¶
NewEnableRoutineRequest generates requests for EnableRoutine
func NewGetCurrentBackupRequest ¶
NewGetCurrentBackupRequest generates requests for GetCurrentBackup
func NewGetFullBackupsForRoutineRequest ¶
func NewGetFullBackupsForRoutineRequest(server string, name string, params *GetFullBackupsForRoutineParams) (*http.Request, error)
NewGetFullBackupsForRoutineRequest generates requests for GetFullBackupsForRoutine
func NewGetFullBackupsRequest ¶
func NewGetFullBackupsRequest(server string, params *GetFullBackupsParams) (*http.Request, error)
NewGetFullBackupsRequest generates requests for GetFullBackups
func NewGetIncrementalBackupsForRoutineRequest ¶
func NewGetIncrementalBackupsForRoutineRequest(server string, name string, params *GetIncrementalBackupsForRoutineParams) (*http.Request, error)
NewGetIncrementalBackupsForRoutineRequest generates requests for GetIncrementalBackupsForRoutine
func NewGetIncrementalBackupsRequest ¶
func NewGetIncrementalBackupsRequest(server string, params *GetIncrementalBackupsParams) (*http.Request, error)
NewGetIncrementalBackupsRequest generates requests for GetIncrementalBackups
func NewHealthRequest ¶
NewHealthRequest generates requests for Health
func NewMetricsRequest ¶
NewMetricsRequest generates requests for Metrics
func NewReadAllClustersRequest ¶
NewReadAllClustersRequest generates requests for ReadAllClusters
func NewReadAllStorageRequest ¶
NewReadAllStorageRequest generates requests for ReadAllStorage
func NewReadClusterRequest ¶
NewReadClusterRequest generates requests for ReadCluster
func NewReadConfigRequest ¶
NewReadConfigRequest generates requests for ReadConfig
func NewReadPoliciesRequest ¶
NewReadPoliciesRequest generates requests for ReadPolicies
func NewReadPolicyRequest ¶
NewReadPolicyRequest generates requests for ReadPolicy
func NewReadRoutineRequest ¶
NewReadRoutineRequest generates requests for ReadRoutine
func NewReadRoutinesRequest ¶
NewReadRoutinesRequest generates requests for ReadRoutines
func NewReadStorageRequest ¶
NewReadStorageRequest generates requests for ReadStorage
func NewReadyRequest ¶
NewReadyRequest generates requests for Ready
func NewRestoreFullRequest ¶
func NewRestoreFullRequest(server string, body RestoreFullJSONRequestBody) (*http.Request, error)
NewRestoreFullRequest calls the generic RestoreFull builder with application/json body
func NewRestoreFullRequestWithBody ¶
func NewRestoreFullRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
NewRestoreFullRequestWithBody generates requests for RestoreFull with any type of body
func NewRestoreIncrementalRequest ¶
func NewRestoreIncrementalRequest(server string, body RestoreIncrementalJSONRequestBody) (*http.Request, error)
NewRestoreIncrementalRequest calls the generic RestoreIncremental builder with application/json body
func NewRestoreIncrementalRequestWithBody ¶
func NewRestoreIncrementalRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
NewRestoreIncrementalRequestWithBody generates requests for RestoreIncremental with any type of body
func NewRestoreStatusRequest ¶
NewRestoreStatusRequest generates requests for RestoreStatus
func NewRestoreTimestampRequest ¶
func NewRestoreTimestampRequest(server string, body RestoreTimestampJSONRequestBody) (*http.Request, error)
NewRestoreTimestampRequest calls the generic RestoreTimestamp builder with application/json body
func NewRestoreTimestampRequestWithBody ¶
func NewRestoreTimestampRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
NewRestoreTimestampRequestWithBody generates requests for RestoreTimestamp with any type of body
func NewRetrieveConfigurationRequest ¶
func NewRetrieveConfigurationRequest(server string, name string, timestamp int64) (*http.Request, error)
NewRetrieveConfigurationRequest generates requests for RetrieveConfiguration
func NewRetrieveRestoreJobsRequest ¶
func NewRetrieveRestoreJobsRequest(server string, params *RetrieveRestoreJobsParams) (*http.Request, error)
NewRetrieveRestoreJobsRequest generates requests for RetrieveRestoreJobs
func NewRootRequest ¶
NewRootRequest generates requests for Root
func NewScheduleFullBackupRequest ¶
func NewScheduleFullBackupRequest(server string, name string, params *ScheduleFullBackupParams) (*http.Request, error)
NewScheduleFullBackupRequest generates requests for ScheduleFullBackup
func NewTriggerFullBackupRequest ¶
func NewTriggerFullBackupRequest(server string, name string, params *TriggerFullBackupParams) (*http.Request, error)
NewTriggerFullBackupRequest generates requests for TriggerFullBackup
func NewTriggerIncrementalBackupRequest ¶
func NewTriggerIncrementalBackupRequest(server string, name string, params *TriggerIncrementalBackupParams) (*http.Request, error)
NewTriggerIncrementalBackupRequest generates requests for TriggerIncrementalBackup
func NewUpdateClusterRequest ¶
func NewUpdateClusterRequest(server string, name string, body UpdateClusterJSONRequestBody) (*http.Request, error)
NewUpdateClusterRequest calls the generic UpdateCluster builder with application/json body
func NewUpdateClusterRequestWithBody ¶
func NewUpdateClusterRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewUpdateClusterRequestWithBody generates requests for UpdateCluster with any type of body
func NewUpdateConfigRequest ¶
func NewUpdateConfigRequest(server string, body UpdateConfigJSONRequestBody) (*http.Request, error)
NewUpdateConfigRequest calls the generic UpdateConfig builder with application/json body
func NewUpdateConfigRequestWithBody ¶
func NewUpdateConfigRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
NewUpdateConfigRequestWithBody generates requests for UpdateConfig with any type of body
func NewUpdatePolicyRequest ¶
func NewUpdatePolicyRequest(server string, name string, body UpdatePolicyJSONRequestBody) (*http.Request, error)
NewUpdatePolicyRequest calls the generic UpdatePolicy builder with application/json body
func NewUpdatePolicyRequestWithBody ¶
func NewUpdatePolicyRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewUpdatePolicyRequestWithBody generates requests for UpdatePolicy with any type of body
func NewUpdateRoutineRequest ¶
func NewUpdateRoutineRequest(server string, name string, body UpdateRoutineJSONRequestBody) (*http.Request, error)
NewUpdateRoutineRequest calls the generic UpdateRoutine builder with application/json body
func NewUpdateRoutineRequestWithBody ¶
func NewUpdateRoutineRequestWithBody(server string, name string, contentType string, body io.Reader) (*http.Request, error)
NewUpdateRoutineRequestWithBody generates requests for UpdateRoutine with any type of body
func NewUpdateStorageRequest ¶
func NewUpdateStorageRequest(server string, name string, body UpdateStorageJSONRequestBody) (*http.Request, error)
NewUpdateStorageRequest calls the generic UpdateStorage builder with application/json body
Types ¶
type AddClusterJSONRequestBody ¶
type AddClusterJSONRequestBody = DtoAerospikeCluster
AddClusterJSONRequestBody defines body for AddCluster for application/json ContentType.
type AddClusterResponse ¶
func ParseAddClusterResponse ¶
func ParseAddClusterResponse(rsp *http.Response) (*AddClusterResponse, error)
ParseAddClusterResponse parses an HTTP response from a AddClusterWithResponse call
func (AddClusterResponse) Status ¶
func (r AddClusterResponse) Status() string
Status returns HTTPResponse.Status
func (AddClusterResponse) StatusCode ¶
func (r AddClusterResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type AddPolicyJSONRequestBody ¶
type AddPolicyJSONRequestBody = DtoBackupPolicy
AddPolicyJSONRequestBody defines body for AddPolicy for application/json ContentType.
type AddPolicyResponse ¶
func ParseAddPolicyResponse ¶
func ParseAddPolicyResponse(rsp *http.Response) (*AddPolicyResponse, error)
ParseAddPolicyResponse parses an HTTP response from a AddPolicyWithResponse call
func (AddPolicyResponse) Status ¶
func (r AddPolicyResponse) Status() string
Status returns HTTPResponse.Status
func (AddPolicyResponse) StatusCode ¶
func (r AddPolicyResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type AddRoutineJSONRequestBody ¶
type AddRoutineJSONRequestBody = DtoBackupRoutine
AddRoutineJSONRequestBody defines body for AddRoutine for application/json ContentType.
type AddRoutineResponse ¶
func ParseAddRoutineResponse ¶
func ParseAddRoutineResponse(rsp *http.Response) (*AddRoutineResponse, error)
ParseAddRoutineResponse parses an HTTP response from a AddRoutineWithResponse call
func (AddRoutineResponse) Status ¶
func (r AddRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (AddRoutineResponse) StatusCode ¶
func (r AddRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type AddStorageJSONRequestBody ¶
type AddStorageJSONRequestBody = DtoStorage
AddStorageJSONRequestBody defines body for AddStorage for application/json ContentType.
type AddStorageResponse ¶
func ParseAddStorageResponse ¶
func ParseAddStorageResponse(rsp *http.Response) (*AddStorageResponse, error)
ParseAddStorageResponse parses an HTTP response from a AddStorageWithResponse call
func (AddStorageResponse) Status ¶
func (r AddStorageResponse) Status() string
Status returns HTTPResponse.Status
func (AddStorageResponse) StatusCode ¶
func (r AddStorageResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ApiDocsResponse ¶
func ParseApiDocsResponse ¶
func ParseApiDocsResponse(rsp *http.Response) (*ApiDocsResponse, error)
ParseApiDocsResponse parses an HTTP response from a ApiDocsWithResponse call
func (ApiDocsResponse) Status ¶
func (r ApiDocsResponse) Status() string
Status returns HTTPResponse.Status
func (ApiDocsResponse) StatusCode ¶
func (r ApiDocsResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ApplyConfigResponse ¶
func ParseApplyConfigResponse ¶
func ParseApplyConfigResponse(rsp *http.Response) (*ApplyConfigResponse, error)
ParseApplyConfigResponse parses an HTTP response from a ApplyConfigWithResponse call
func (ApplyConfigResponse) Status ¶
func (r ApplyConfigResponse) Status() string
Status returns HTTPResponse.Status
func (ApplyConfigResponse) StatusCode ¶
func (r ApplyConfigResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type CancelCurrentBackupResponse ¶
func ParseCancelCurrentBackupResponse ¶
func ParseCancelCurrentBackupResponse(rsp *http.Response) (*CancelCurrentBackupResponse, error)
ParseCancelCurrentBackupResponse parses an HTTP response from a CancelCurrentBackupWithResponse call
func (CancelCurrentBackupResponse) Status ¶
func (r CancelCurrentBackupResponse) Status() string
Status returns HTTPResponse.Status
func (CancelCurrentBackupResponse) StatusCode ¶
func (r CancelCurrentBackupResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type CancelRestoreResponse ¶
func ParseCancelRestoreResponse ¶
func ParseCancelRestoreResponse(rsp *http.Response) (*CancelRestoreResponse, error)
ParseCancelRestoreResponse parses an HTTP response from a CancelRestoreWithResponse call
func (CancelRestoreResponse) Status ¶
func (r CancelRestoreResponse) Status() string
Status returns HTTPResponse.Status
func (CancelRestoreResponse) StatusCode ¶
func (r CancelRestoreResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type Client ¶
type Client struct {
// The endpoint of the server conforming to this interface, with scheme,
// https://api.deepmap.com for example. This can contain a path relative
// to the server, such as https://api.deepmap.com/dev-test, and all the
// paths in the swagger spec will be appended to the server.
Server string
// Doer for performing requests, typically a *http.Client with any
// customized settings, such as certificate chains.
Client HttpRequestDoer
// A list of callbacks for modifying requests which are generated before sending over
// the network.
RequestEditors []RequestEditorFn
}
Client which conforms to the OpenAPI3 specification for this service.
func NewClient ¶
func NewClient(server string, opts ...ClientOption) (*Client, error)
Creates a new Client, with reasonable defaults
func (*Client) AddCluster ¶
func (c *Client) AddCluster(ctx context.Context, name string, body AddClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) AddClusterWithBody ¶
func (*Client) AddPolicy ¶
func (c *Client) AddPolicy(ctx context.Context, name string, body AddPolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) AddPolicyWithBody ¶
func (*Client) AddRoutine ¶
func (c *Client) AddRoutine(ctx context.Context, name string, body AddRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) AddRoutineWithBody ¶
func (*Client) AddStorage ¶
func (c *Client) AddStorage(ctx context.Context, name string, body AddStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) AddStorageWithBody ¶
func (*Client) ApplyConfig ¶
func (*Client) CancelCurrentBackup ¶
func (*Client) CancelRestore ¶
func (*Client) DeleteCluster ¶
func (*Client) DeletePolicy ¶
func (*Client) DeleteRoutine ¶
func (*Client) DeleteStorage ¶
func (*Client) DisableRoutine ¶
func (*Client) EnableRoutine ¶
func (*Client) GetCurrentBackup ¶
func (*Client) GetFullBackups ¶
func (c *Client) GetFullBackups(ctx context.Context, params *GetFullBackupsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) GetFullBackupsForRoutine ¶
func (c *Client) GetFullBackupsForRoutine(ctx context.Context, name string, params *GetFullBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) GetIncrementalBackups ¶
func (c *Client) GetIncrementalBackups(ctx context.Context, params *GetIncrementalBackupsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) GetIncrementalBackupsForRoutine ¶
func (c *Client) GetIncrementalBackupsForRoutine(ctx context.Context, name string, params *GetIncrementalBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) ReadAllClusters ¶
func (*Client) ReadAllStorage ¶
func (*Client) ReadCluster ¶
func (*Client) ReadConfig ¶
func (*Client) ReadPolicies ¶
func (*Client) ReadPolicy ¶
func (*Client) ReadRoutine ¶
func (*Client) ReadRoutines ¶
func (*Client) ReadStorage ¶
func (*Client) RestoreFull ¶
func (c *Client) RestoreFull(ctx context.Context, body RestoreFullJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) RestoreFullWithBody ¶
func (*Client) RestoreIncremental ¶
func (c *Client) RestoreIncremental(ctx context.Context, body RestoreIncrementalJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) RestoreIncrementalWithBody ¶
func (*Client) RestoreStatus ¶
func (*Client) RestoreTimestamp ¶
func (c *Client) RestoreTimestamp(ctx context.Context, body RestoreTimestampJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) RestoreTimestampWithBody ¶
func (*Client) RetrieveConfiguration ¶
func (*Client) RetrieveRestoreJobs ¶
func (c *Client) RetrieveRestoreJobs(ctx context.Context, params *RetrieveRestoreJobsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) ScheduleFullBackup ¶
func (c *Client) ScheduleFullBackup(ctx context.Context, name string, params *ScheduleFullBackupParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) TriggerFullBackup ¶
func (c *Client) TriggerFullBackup(ctx context.Context, name string, params *TriggerFullBackupParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) TriggerIncrementalBackup ¶
func (c *Client) TriggerIncrementalBackup(ctx context.Context, name string, params *TriggerIncrementalBackupParams, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpdateCluster ¶
func (c *Client) UpdateCluster(ctx context.Context, name string, body UpdateClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpdateClusterWithBody ¶
func (*Client) UpdateConfig ¶
func (c *Client) UpdateConfig(ctx context.Context, body UpdateConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpdateConfigWithBody ¶
func (*Client) UpdatePolicy ¶
func (c *Client) UpdatePolicy(ctx context.Context, name string, body UpdatePolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpdatePolicyWithBody ¶
func (*Client) UpdateRoutine ¶
func (c *Client) UpdateRoutine(ctx context.Context, name string, body UpdateRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpdateRoutineWithBody ¶
func (*Client) UpdateStorage ¶
func (c *Client) UpdateStorage(ctx context.Context, name string, body UpdateStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpdateStorageWithBody ¶
type ClientInterface ¶
type ClientInterface interface {
// Root request
Root(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// ApiDocs request
ApiDocs(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// Health request
Health(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// Metrics request
Metrics(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// Ready request
Ready(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// CancelCurrentBackup request
CancelCurrentBackup(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// GetCurrentBackup request
GetCurrentBackup(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// GetFullBackups request
GetFullBackups(ctx context.Context, params *GetFullBackupsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// GetFullBackupsForRoutine request
GetFullBackupsForRoutine(ctx context.Context, name string, params *GetFullBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// TriggerFullBackup request
TriggerFullBackup(ctx context.Context, name string, params *TriggerFullBackupParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// GetIncrementalBackups request
GetIncrementalBackups(ctx context.Context, params *GetIncrementalBackupsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// GetIncrementalBackupsForRoutine request
GetIncrementalBackupsForRoutine(ctx context.Context, name string, params *GetIncrementalBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// TriggerIncrementalBackup request
TriggerIncrementalBackup(ctx context.Context, name string, params *TriggerIncrementalBackupParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// ScheduleFullBackup request
ScheduleFullBackup(ctx context.Context, name string, params *ScheduleFullBackupParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadConfig request
ReadConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// UpdateConfigWithBody request with any body
UpdateConfigWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
UpdateConfig(ctx context.Context, body UpdateConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// ApplyConfig request
ApplyConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadAllClusters request
ReadAllClusters(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// DeleteCluster request
DeleteCluster(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadCluster request
ReadCluster(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// AddClusterWithBody request with any body
AddClusterWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
AddCluster(ctx context.Context, name string, body AddClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// UpdateClusterWithBody request with any body
UpdateClusterWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
UpdateCluster(ctx context.Context, name string, body UpdateClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadPolicies request
ReadPolicies(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// DeletePolicy request
DeletePolicy(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadPolicy request
ReadPolicy(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// AddPolicyWithBody request with any body
AddPolicyWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
AddPolicy(ctx context.Context, name string, body AddPolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// UpdatePolicyWithBody request with any body
UpdatePolicyWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
UpdatePolicy(ctx context.Context, name string, body UpdatePolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadRoutines request
ReadRoutines(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// DeleteRoutine request
DeleteRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadRoutine request
ReadRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// AddRoutineWithBody request with any body
AddRoutineWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
AddRoutine(ctx context.Context, name string, body AddRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// UpdateRoutineWithBody request with any body
UpdateRoutineWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
UpdateRoutine(ctx context.Context, name string, body UpdateRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// DisableRoutine request
DisableRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// EnableRoutine request
EnableRoutine(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadAllStorage request
ReadAllStorage(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
// DeleteStorage request
DeleteStorage(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// ReadStorage request
ReadStorage(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*http.Response, error)
// AddStorageWithBody request with any body
AddStorageWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
AddStorage(ctx context.Context, name string, body AddStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// UpdateStorageWithBody request with any body
UpdateStorageWithBody(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
UpdateStorage(ctx context.Context, name string, body UpdateStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// CancelRestore request
CancelRestore(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*http.Response, error)
// RestoreFullWithBody request with any body
RestoreFullWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
RestoreFull(ctx context.Context, body RestoreFullJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// RestoreIncrementalWithBody request with any body
RestoreIncrementalWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
RestoreIncremental(ctx context.Context, body RestoreIncrementalJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// RetrieveRestoreJobs request
RetrieveRestoreJobs(ctx context.Context, params *RetrieveRestoreJobsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
// RestoreStatus request
RestoreStatus(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*http.Response, error)
// RestoreTimestampWithBody request with any body
RestoreTimestampWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)
RestoreTimestamp(ctx context.Context, body RestoreTimestampJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
// RetrieveConfiguration request
RetrieveConfiguration(ctx context.Context, name string, timestamp int64, reqEditors ...RequestEditorFn) (*http.Response, error)
// Version request
Version(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
}
The interface specification for the client above.
type ClientOption ¶
ClientOption allows setting custom parameters during construction
func WithHTTPClient ¶
func WithHTTPClient(doer HttpRequestDoer) ClientOption
WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.
func WithRequestEditorFn ¶
func WithRequestEditorFn(fn RequestEditorFn) ClientOption
WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.
type ClientWithResponses ¶
type ClientWithResponses struct {
ClientInterface
}
ClientWithResponses builds on ClientInterface to offer response payloads
func NewClientWithResponses ¶
func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)
NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling
func (*ClientWithResponses) AddClusterWithBodyWithResponse ¶
func (c *ClientWithResponses) AddClusterWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddClusterResponse, error)
AddClusterWithBodyWithResponse request with arbitrary body returning *AddClusterResponse
func (*ClientWithResponses) AddClusterWithResponse ¶
func (c *ClientWithResponses) AddClusterWithResponse(ctx context.Context, name string, body AddClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*AddClusterResponse, error)
func (*ClientWithResponses) AddPolicyWithBodyWithResponse ¶
func (c *ClientWithResponses) AddPolicyWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddPolicyResponse, error)
AddPolicyWithBodyWithResponse request with arbitrary body returning *AddPolicyResponse
func (*ClientWithResponses) AddPolicyWithResponse ¶
func (c *ClientWithResponses) AddPolicyWithResponse(ctx context.Context, name string, body AddPolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*AddPolicyResponse, error)
func (*ClientWithResponses) AddRoutineWithBodyWithResponse ¶
func (c *ClientWithResponses) AddRoutineWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddRoutineResponse, error)
AddRoutineWithBodyWithResponse request with arbitrary body returning *AddRoutineResponse
func (*ClientWithResponses) AddRoutineWithResponse ¶
func (c *ClientWithResponses) AddRoutineWithResponse(ctx context.Context, name string, body AddRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*AddRoutineResponse, error)
func (*ClientWithResponses) AddStorageWithBodyWithResponse ¶
func (c *ClientWithResponses) AddStorageWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddStorageResponse, error)
AddStorageWithBodyWithResponse request with arbitrary body returning *AddStorageResponse
func (*ClientWithResponses) AddStorageWithResponse ¶
func (c *ClientWithResponses) AddStorageWithResponse(ctx context.Context, name string, body AddStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*AddStorageResponse, error)
func (*ClientWithResponses) ApiDocsWithResponse ¶
func (c *ClientWithResponses) ApiDocsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ApiDocsResponse, error)
ApiDocsWithResponse request returning *ApiDocsResponse
func (*ClientWithResponses) ApplyConfigWithResponse ¶
func (c *ClientWithResponses) ApplyConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ApplyConfigResponse, error)
ApplyConfigWithResponse request returning *ApplyConfigResponse
func (*ClientWithResponses) CancelCurrentBackupWithResponse ¶
func (c *ClientWithResponses) CancelCurrentBackupWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*CancelCurrentBackupResponse, error)
CancelCurrentBackupWithResponse request returning *CancelCurrentBackupResponse
func (*ClientWithResponses) CancelRestoreWithResponse ¶
func (c *ClientWithResponses) CancelRestoreWithResponse(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*CancelRestoreResponse, error)
CancelRestoreWithResponse request returning *CancelRestoreResponse
func (*ClientWithResponses) DeleteClusterWithResponse ¶
func (c *ClientWithResponses) DeleteClusterWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteClusterResponse, error)
DeleteClusterWithResponse request returning *DeleteClusterResponse
func (*ClientWithResponses) DeletePolicyWithResponse ¶
func (c *ClientWithResponses) DeletePolicyWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeletePolicyResponse, error)
DeletePolicyWithResponse request returning *DeletePolicyResponse
func (*ClientWithResponses) DeleteRoutineWithResponse ¶
func (c *ClientWithResponses) DeleteRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteRoutineResponse, error)
DeleteRoutineWithResponse request returning *DeleteRoutineResponse
func (*ClientWithResponses) DeleteStorageWithResponse ¶
func (c *ClientWithResponses) DeleteStorageWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteStorageResponse, error)
DeleteStorageWithResponse request returning *DeleteStorageResponse
func (*ClientWithResponses) DisableRoutineWithResponse ¶
func (c *ClientWithResponses) DisableRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DisableRoutineResponse, error)
DisableRoutineWithResponse request returning *DisableRoutineResponse
func (*ClientWithResponses) EnableRoutineWithResponse ¶
func (c *ClientWithResponses) EnableRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*EnableRoutineResponse, error)
EnableRoutineWithResponse request returning *EnableRoutineResponse
func (*ClientWithResponses) GetCurrentBackupWithResponse ¶
func (c *ClientWithResponses) GetCurrentBackupWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*GetCurrentBackupResponse, error)
GetCurrentBackupWithResponse request returning *GetCurrentBackupResponse
func (*ClientWithResponses) GetFullBackupsForRoutineWithResponse ¶
func (c *ClientWithResponses) GetFullBackupsForRoutineWithResponse(ctx context.Context, name string, params *GetFullBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*GetFullBackupsForRoutineResponse, error)
GetFullBackupsForRoutineWithResponse request returning *GetFullBackupsForRoutineResponse
func (*ClientWithResponses) GetFullBackupsWithResponse ¶
func (c *ClientWithResponses) GetFullBackupsWithResponse(ctx context.Context, params *GetFullBackupsParams, reqEditors ...RequestEditorFn) (*GetFullBackupsResponse, error)
GetFullBackupsWithResponse request returning *GetFullBackupsResponse
func (*ClientWithResponses) GetIncrementalBackupsForRoutineWithResponse ¶
func (c *ClientWithResponses) GetIncrementalBackupsForRoutineWithResponse(ctx context.Context, name string, params *GetIncrementalBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*GetIncrementalBackupsForRoutineResponse, error)
GetIncrementalBackupsForRoutineWithResponse request returning *GetIncrementalBackupsForRoutineResponse
func (*ClientWithResponses) GetIncrementalBackupsWithResponse ¶
func (c *ClientWithResponses) GetIncrementalBackupsWithResponse(ctx context.Context, params *GetIncrementalBackupsParams, reqEditors ...RequestEditorFn) (*GetIncrementalBackupsResponse, error)
GetIncrementalBackupsWithResponse request returning *GetIncrementalBackupsResponse
func (*ClientWithResponses) HealthWithResponse ¶
func (c *ClientWithResponses) HealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthResponse, error)
HealthWithResponse request returning *HealthResponse
func (*ClientWithResponses) MetricsWithResponse ¶
func (c *ClientWithResponses) MetricsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*MetricsResponse, error)
MetricsWithResponse request returning *MetricsResponse
func (*ClientWithResponses) ReadAllClustersWithResponse ¶
func (c *ClientWithResponses) ReadAllClustersWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadAllClustersResponse, error)
ReadAllClustersWithResponse request returning *ReadAllClustersResponse
func (*ClientWithResponses) ReadAllStorageWithResponse ¶
func (c *ClientWithResponses) ReadAllStorageWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadAllStorageResponse, error)
ReadAllStorageWithResponse request returning *ReadAllStorageResponse
func (*ClientWithResponses) ReadClusterWithResponse ¶
func (c *ClientWithResponses) ReadClusterWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadClusterResponse, error)
ReadClusterWithResponse request returning *ReadClusterResponse
func (*ClientWithResponses) ReadConfigWithResponse ¶
func (c *ClientWithResponses) ReadConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadConfigResponse, error)
ReadConfigWithResponse request returning *ReadConfigResponse
func (*ClientWithResponses) ReadPoliciesWithResponse ¶
func (c *ClientWithResponses) ReadPoliciesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadPoliciesResponse, error)
ReadPoliciesWithResponse request returning *ReadPoliciesResponse
func (*ClientWithResponses) ReadPolicyWithResponse ¶
func (c *ClientWithResponses) ReadPolicyWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadPolicyResponse, error)
ReadPolicyWithResponse request returning *ReadPolicyResponse
func (*ClientWithResponses) ReadRoutineWithResponse ¶
func (c *ClientWithResponses) ReadRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadRoutineResponse, error)
ReadRoutineWithResponse request returning *ReadRoutineResponse
func (*ClientWithResponses) ReadRoutinesWithResponse ¶
func (c *ClientWithResponses) ReadRoutinesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadRoutinesResponse, error)
ReadRoutinesWithResponse request returning *ReadRoutinesResponse
func (*ClientWithResponses) ReadStorageWithResponse ¶
func (c *ClientWithResponses) ReadStorageWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadStorageResponse, error)
ReadStorageWithResponse request returning *ReadStorageResponse
func (*ClientWithResponses) ReadyWithResponse ¶
func (c *ClientWithResponses) ReadyWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadyResponse, error)
ReadyWithResponse request returning *ReadyResponse
func (*ClientWithResponses) RestoreFullWithBodyWithResponse ¶
func (c *ClientWithResponses) RestoreFullWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RestoreFullResponse, error)
RestoreFullWithBodyWithResponse request with arbitrary body returning *RestoreFullResponse
func (*ClientWithResponses) RestoreFullWithResponse ¶
func (c *ClientWithResponses) RestoreFullWithResponse(ctx context.Context, body RestoreFullJSONRequestBody, reqEditors ...RequestEditorFn) (*RestoreFullResponse, error)
func (*ClientWithResponses) RestoreIncrementalWithBodyWithResponse ¶
func (c *ClientWithResponses) RestoreIncrementalWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RestoreIncrementalResponse, error)
RestoreIncrementalWithBodyWithResponse request with arbitrary body returning *RestoreIncrementalResponse
func (*ClientWithResponses) RestoreIncrementalWithResponse ¶
func (c *ClientWithResponses) RestoreIncrementalWithResponse(ctx context.Context, body RestoreIncrementalJSONRequestBody, reqEditors ...RequestEditorFn) (*RestoreIncrementalResponse, error)
func (*ClientWithResponses) RestoreStatusWithResponse ¶
func (c *ClientWithResponses) RestoreStatusWithResponse(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*RestoreStatusResponse, error)
RestoreStatusWithResponse request returning *RestoreStatusResponse
func (*ClientWithResponses) RestoreTimestampWithBodyWithResponse ¶
func (c *ClientWithResponses) RestoreTimestampWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RestoreTimestampResponse, error)
RestoreTimestampWithBodyWithResponse request with arbitrary body returning *RestoreTimestampResponse
func (*ClientWithResponses) RestoreTimestampWithResponse ¶
func (c *ClientWithResponses) RestoreTimestampWithResponse(ctx context.Context, body RestoreTimestampJSONRequestBody, reqEditors ...RequestEditorFn) (*RestoreTimestampResponse, error)
func (*ClientWithResponses) RetrieveConfigurationWithResponse ¶
func (c *ClientWithResponses) RetrieveConfigurationWithResponse(ctx context.Context, name string, timestamp int64, reqEditors ...RequestEditorFn) (*RetrieveConfigurationResponse, error)
RetrieveConfigurationWithResponse request returning *RetrieveConfigurationResponse
func (*ClientWithResponses) RetrieveRestoreJobsWithResponse ¶
func (c *ClientWithResponses) RetrieveRestoreJobsWithResponse(ctx context.Context, params *RetrieveRestoreJobsParams, reqEditors ...RequestEditorFn) (*RetrieveRestoreJobsResponse, error)
RetrieveRestoreJobsWithResponse request returning *RetrieveRestoreJobsResponse
func (*ClientWithResponses) RootWithResponse ¶
func (c *ClientWithResponses) RootWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RootResponse, error)
RootWithResponse request returning *RootResponse
func (*ClientWithResponses) ScheduleFullBackupWithResponse ¶
func (c *ClientWithResponses) ScheduleFullBackupWithResponse(ctx context.Context, name string, params *ScheduleFullBackupParams, reqEditors ...RequestEditorFn) (*ScheduleFullBackupResponse, error)
ScheduleFullBackupWithResponse request returning *ScheduleFullBackupResponse
func (*ClientWithResponses) TriggerFullBackupWithResponse ¶
func (c *ClientWithResponses) TriggerFullBackupWithResponse(ctx context.Context, name string, params *TriggerFullBackupParams, reqEditors ...RequestEditorFn) (*TriggerFullBackupResponse, error)
TriggerFullBackupWithResponse request returning *TriggerFullBackupResponse
func (*ClientWithResponses) TriggerIncrementalBackupWithResponse ¶
func (c *ClientWithResponses) TriggerIncrementalBackupWithResponse(ctx context.Context, name string, params *TriggerIncrementalBackupParams, reqEditors ...RequestEditorFn) (*TriggerIncrementalBackupResponse, error)
TriggerIncrementalBackupWithResponse request returning *TriggerIncrementalBackupResponse
func (*ClientWithResponses) UpdateClusterWithBodyWithResponse ¶
func (c *ClientWithResponses) UpdateClusterWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateClusterResponse, error)
UpdateClusterWithBodyWithResponse request with arbitrary body returning *UpdateClusterResponse
func (*ClientWithResponses) UpdateClusterWithResponse ¶
func (c *ClientWithResponses) UpdateClusterWithResponse(ctx context.Context, name string, body UpdateClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateClusterResponse, error)
func (*ClientWithResponses) UpdateConfigWithBodyWithResponse ¶
func (c *ClientWithResponses) UpdateConfigWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateConfigResponse, error)
UpdateConfigWithBodyWithResponse request with arbitrary body returning *UpdateConfigResponse
func (*ClientWithResponses) UpdateConfigWithResponse ¶
func (c *ClientWithResponses) UpdateConfigWithResponse(ctx context.Context, body UpdateConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateConfigResponse, error)
func (*ClientWithResponses) UpdatePolicyWithBodyWithResponse ¶
func (c *ClientWithResponses) UpdatePolicyWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdatePolicyResponse, error)
UpdatePolicyWithBodyWithResponse request with arbitrary body returning *UpdatePolicyResponse
func (*ClientWithResponses) UpdatePolicyWithResponse ¶
func (c *ClientWithResponses) UpdatePolicyWithResponse(ctx context.Context, name string, body UpdatePolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdatePolicyResponse, error)
func (*ClientWithResponses) UpdateRoutineWithBodyWithResponse ¶
func (c *ClientWithResponses) UpdateRoutineWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateRoutineResponse, error)
UpdateRoutineWithBodyWithResponse request with arbitrary body returning *UpdateRoutineResponse
func (*ClientWithResponses) UpdateRoutineWithResponse ¶
func (c *ClientWithResponses) UpdateRoutineWithResponse(ctx context.Context, name string, body UpdateRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateRoutineResponse, error)
func (*ClientWithResponses) UpdateStorageWithBodyWithResponse ¶
func (c *ClientWithResponses) UpdateStorageWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateStorageResponse, error)
UpdateStorageWithBodyWithResponse request with arbitrary body returning *UpdateStorageResponse
func (*ClientWithResponses) UpdateStorageWithResponse ¶
func (c *ClientWithResponses) UpdateStorageWithResponse(ctx context.Context, name string, body UpdateStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateStorageResponse, error)
func (*ClientWithResponses) VersionWithResponse ¶
func (c *ClientWithResponses) VersionWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*VersionResponse, error)
VersionWithResponse request returning *VersionResponse
type ClientWithResponsesInterface ¶
type ClientWithResponsesInterface interface {
// RootWithResponse request
RootWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RootResponse, error)
// ApiDocsWithResponse request
ApiDocsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ApiDocsResponse, error)
// HealthWithResponse request
HealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthResponse, error)
// MetricsWithResponse request
MetricsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*MetricsResponse, error)
// ReadyWithResponse request
ReadyWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadyResponse, error)
// CancelCurrentBackupWithResponse request
CancelCurrentBackupWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*CancelCurrentBackupResponse, error)
// GetCurrentBackupWithResponse request
GetCurrentBackupWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*GetCurrentBackupResponse, error)
// GetFullBackupsWithResponse request
GetFullBackupsWithResponse(ctx context.Context, params *GetFullBackupsParams, reqEditors ...RequestEditorFn) (*GetFullBackupsResponse, error)
// GetFullBackupsForRoutineWithResponse request
GetFullBackupsForRoutineWithResponse(ctx context.Context, name string, params *GetFullBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*GetFullBackupsForRoutineResponse, error)
// TriggerFullBackupWithResponse request
TriggerFullBackupWithResponse(ctx context.Context, name string, params *TriggerFullBackupParams, reqEditors ...RequestEditorFn) (*TriggerFullBackupResponse, error)
// GetIncrementalBackupsWithResponse request
GetIncrementalBackupsWithResponse(ctx context.Context, params *GetIncrementalBackupsParams, reqEditors ...RequestEditorFn) (*GetIncrementalBackupsResponse, error)
// GetIncrementalBackupsForRoutineWithResponse request
GetIncrementalBackupsForRoutineWithResponse(ctx context.Context, name string, params *GetIncrementalBackupsForRoutineParams, reqEditors ...RequestEditorFn) (*GetIncrementalBackupsForRoutineResponse, error)
// TriggerIncrementalBackupWithResponse request
TriggerIncrementalBackupWithResponse(ctx context.Context, name string, params *TriggerIncrementalBackupParams, reqEditors ...RequestEditorFn) (*TriggerIncrementalBackupResponse, error)
// ScheduleFullBackupWithResponse request
ScheduleFullBackupWithResponse(ctx context.Context, name string, params *ScheduleFullBackupParams, reqEditors ...RequestEditorFn) (*ScheduleFullBackupResponse, error)
// ReadConfigWithResponse request
ReadConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadConfigResponse, error)
// UpdateConfigWithBodyWithResponse request with any body
UpdateConfigWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateConfigResponse, error)
UpdateConfigWithResponse(ctx context.Context, body UpdateConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateConfigResponse, error)
// ApplyConfigWithResponse request
ApplyConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ApplyConfigResponse, error)
// ReadAllClustersWithResponse request
ReadAllClustersWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadAllClustersResponse, error)
// DeleteClusterWithResponse request
DeleteClusterWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteClusterResponse, error)
// ReadClusterWithResponse request
ReadClusterWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadClusterResponse, error)
// AddClusterWithBodyWithResponse request with any body
AddClusterWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddClusterResponse, error)
AddClusterWithResponse(ctx context.Context, name string, body AddClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*AddClusterResponse, error)
// UpdateClusterWithBodyWithResponse request with any body
UpdateClusterWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateClusterResponse, error)
UpdateClusterWithResponse(ctx context.Context, name string, body UpdateClusterJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateClusterResponse, error)
// ReadPoliciesWithResponse request
ReadPoliciesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadPoliciesResponse, error)
// DeletePolicyWithResponse request
DeletePolicyWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeletePolicyResponse, error)
// ReadPolicyWithResponse request
ReadPolicyWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadPolicyResponse, error)
// AddPolicyWithBodyWithResponse request with any body
AddPolicyWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddPolicyResponse, error)
AddPolicyWithResponse(ctx context.Context, name string, body AddPolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*AddPolicyResponse, error)
// UpdatePolicyWithBodyWithResponse request with any body
UpdatePolicyWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdatePolicyResponse, error)
UpdatePolicyWithResponse(ctx context.Context, name string, body UpdatePolicyJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdatePolicyResponse, error)
// ReadRoutinesWithResponse request
ReadRoutinesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadRoutinesResponse, error)
// DeleteRoutineWithResponse request
DeleteRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteRoutineResponse, error)
// ReadRoutineWithResponse request
ReadRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadRoutineResponse, error)
// AddRoutineWithBodyWithResponse request with any body
AddRoutineWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddRoutineResponse, error)
AddRoutineWithResponse(ctx context.Context, name string, body AddRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*AddRoutineResponse, error)
// UpdateRoutineWithBodyWithResponse request with any body
UpdateRoutineWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateRoutineResponse, error)
UpdateRoutineWithResponse(ctx context.Context, name string, body UpdateRoutineJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateRoutineResponse, error)
// DisableRoutineWithResponse request
DisableRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DisableRoutineResponse, error)
// EnableRoutineWithResponse request
EnableRoutineWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*EnableRoutineResponse, error)
// ReadAllStorageWithResponse request
ReadAllStorageWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ReadAllStorageResponse, error)
// DeleteStorageWithResponse request
DeleteStorageWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*DeleteStorageResponse, error)
// ReadStorageWithResponse request
ReadStorageWithResponse(ctx context.Context, name string, reqEditors ...RequestEditorFn) (*ReadStorageResponse, error)
// AddStorageWithBodyWithResponse request with any body
AddStorageWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddStorageResponse, error)
AddStorageWithResponse(ctx context.Context, name string, body AddStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*AddStorageResponse, error)
// UpdateStorageWithBodyWithResponse request with any body
UpdateStorageWithBodyWithResponse(ctx context.Context, name string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateStorageResponse, error)
UpdateStorageWithResponse(ctx context.Context, name string, body UpdateStorageJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateStorageResponse, error)
// CancelRestoreWithResponse request
CancelRestoreWithResponse(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*CancelRestoreResponse, error)
// RestoreFullWithBodyWithResponse request with any body
RestoreFullWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RestoreFullResponse, error)
RestoreFullWithResponse(ctx context.Context, body RestoreFullJSONRequestBody, reqEditors ...RequestEditorFn) (*RestoreFullResponse, error)
// RestoreIncrementalWithBodyWithResponse request with any body
RestoreIncrementalWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RestoreIncrementalResponse, error)
RestoreIncrementalWithResponse(ctx context.Context, body RestoreIncrementalJSONRequestBody, reqEditors ...RequestEditorFn) (*RestoreIncrementalResponse, error)
// RetrieveRestoreJobsWithResponse request
RetrieveRestoreJobsWithResponse(ctx context.Context, params *RetrieveRestoreJobsParams, reqEditors ...RequestEditorFn) (*RetrieveRestoreJobsResponse, error)
// RestoreStatusWithResponse request
RestoreStatusWithResponse(ctx context.Context, jobId int64, reqEditors ...RequestEditorFn) (*RestoreStatusResponse, error)
// RestoreTimestampWithBodyWithResponse request with any body
RestoreTimestampWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RestoreTimestampResponse, error)
RestoreTimestampWithResponse(ctx context.Context, body RestoreTimestampJSONRequestBody, reqEditors ...RequestEditorFn) (*RestoreTimestampResponse, error)
// RetrieveConfigurationWithResponse request
RetrieveConfigurationWithResponse(ctx context.Context, name string, timestamp int64, reqEditors ...RequestEditorFn) (*RetrieveConfigurationResponse, error)
// VersionWithResponse request
VersionWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*VersionResponse, error)
}
ClientWithResponsesInterface is the interface specification for the client with responses above.
type DeleteClusterResponse ¶
func ParseDeleteClusterResponse ¶
func ParseDeleteClusterResponse(rsp *http.Response) (*DeleteClusterResponse, error)
ParseDeleteClusterResponse parses an HTTP response from a DeleteClusterWithResponse call
func (DeleteClusterResponse) Status ¶
func (r DeleteClusterResponse) Status() string
Status returns HTTPResponse.Status
func (DeleteClusterResponse) StatusCode ¶
func (r DeleteClusterResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type DeletePolicyResponse ¶
func ParseDeletePolicyResponse ¶
func ParseDeletePolicyResponse(rsp *http.Response) (*DeletePolicyResponse, error)
ParseDeletePolicyResponse parses an HTTP response from a DeletePolicyWithResponse call
func (DeletePolicyResponse) Status ¶
func (r DeletePolicyResponse) Status() string
Status returns HTTPResponse.Status
func (DeletePolicyResponse) StatusCode ¶
func (r DeletePolicyResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type DeleteRoutineResponse ¶
func ParseDeleteRoutineResponse ¶
func ParseDeleteRoutineResponse(rsp *http.Response) (*DeleteRoutineResponse, error)
ParseDeleteRoutineResponse parses an HTTP response from a DeleteRoutineWithResponse call
func (DeleteRoutineResponse) Status ¶
func (r DeleteRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (DeleteRoutineResponse) StatusCode ¶
func (r DeleteRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type DeleteStorageResponse ¶
func ParseDeleteStorageResponse ¶
func ParseDeleteStorageResponse(rsp *http.Response) (*DeleteStorageResponse, error)
ParseDeleteStorageResponse parses an HTTP response from a DeleteStorageWithResponse call
func (DeleteStorageResponse) Status ¶
func (r DeleteStorageResponse) Status() string
Status returns HTTPResponse.Status
func (DeleteStorageResponse) StatusCode ¶
func (r DeleteStorageResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type DisableRoutineResponse ¶
func ParseDisableRoutineResponse ¶
func ParseDisableRoutineResponse(rsp *http.Response) (*DisableRoutineResponse, error)
ParseDisableRoutineResponse parses an HTTP response from a DisableRoutineWithResponse call
func (DisableRoutineResponse) Status ¶
func (r DisableRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (DisableRoutineResponse) StatusCode ¶
func (r DisableRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type DtoAerospikeCluster ¶
type DtoAerospikeCluster struct {
// ConnTimeout The connection timeout in milliseconds.
ConnTimeout *int `json:"conn-timeout,omitempty" yaml:"conn-timeout,omitempty"`
// Credentials The authentication details to the Aerospike cluster.
Credentials *DtoCredentials `json:"credentials,omitempty" yaml:"credentials,omitempty"`
// Label The cluster name. Optional: used only in logs and error messages.
Label *string `json:"label,omitempty" yaml:"label,omitempty"`
// MaxParallelScans Specifies the maximum number of parallel scans allowed across the cluster.
// This property helps reduce the load on the cluster and is shared among all backups using the cluster.
// Default: unlimited.
MaxParallelScans *int `json:"max-parallel-scans,omitempty" yaml:"max-parallel-scans,omitempty"`
// PreferRacks The list of acceptable racks in order of preference.
// Nodes in prefer-racks[0] are chosen first.
// If a node is not found in prefer-racks[0], then nodes in prefer-racks[1] are searched, and so on.
// Mutually exclusive with the routine's rack-list, node-list and partition-list properties.
PreferRacks *[]int `json:"prefer-racks,omitempty" yaml:"prefer-racks,omitempty"`
// SeedNodes The seed nodes details.
SeedNodes []DtoSeedNode `json:"seed-nodes" yaml:"seed-nodes"`
// Tls The cluster TLS configuration.
Tls *DtoTLS `json:"tls,omitempty" yaml:"tls,omitempty"`
// UseServicesAlternate Whether should use "services-alternate" instead of "services" in info request during cluster tending.
UseServicesAlternate *bool `json:"use-services-alternate,omitempty" yaml:"use-services-alternate,omitempty"`
}
DtoAerospikeCluster AerospikeCluster represents the configuration for an Aerospike cluster for backup.
type DtoAzureStorage ¶
type DtoAzureStorage struct {
// AccountKey AccountKey is the Azure storage account key for Shared Key authentication.
// This is sensitive information. Can be a path in secret agent or an actual value.
AccountKey *string `json:"account-key,omitempty" yaml:"account-key,omitempty"`
// AccountName AccountName is the Azure storage account name for Shared Key authentication.
AccountName *string `json:"account-name,omitempty" yaml:"account-name,omitempty"`
// ClientId ClientID is the Azure Active Directory client ID for AAD authentication.
ClientId *string `json:"client-id,omitempty" yaml:"client-id,omitempty"`
// ClientSecret ClientSecret is the Azure Active Directory client secret for AAD authentication.
// This is sensitive information. Can be a path in secret agent or an actual value.
ClientSecret *string `json:"client-secret,omitempty" yaml:"client-secret,omitempty"`
// ContainerName ContainerName is the name of the Azure Blob container.
ContainerName string `json:"container-name" yaml:"container-name"`
// Endpoint Endpoint is the Azure Blob service endpoint URL.
Endpoint string `json:"endpoint" yaml:"endpoint"`
// MinPartSize The minimum size in bytes of individual Azure Blob chunks.
MinPartSize *int `json:"min-part-size,omitempty" yaml:"min-part-size,omitempty"`
// Path Path is the root path for the backup repository within the container.
// If not specified, backups will be saved in the container's root.
Path *string `json:"path,omitempty" yaml:"path,omitempty"`
// SecretAgent Secret Agent configuration (optional).
// Mutually exclusive with 'secret-agent-name'.
SecretAgent *DtoSecretAgent `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SecretAgentName Secret Agent configuration (optional). Link to one of preconfigured agents.
// Mutually exclusive with 'secret-agent'.
SecretAgentName *string `json:"secret-agent-name,omitempty" yaml:"secret-agent-name,omitempty"`
// StorageClass StorageClass defines the storage tier for data and metadata objects.
StorageClass *DtoAzureStorageClass `json:"storage-class,omitempty" yaml:"storage-class,omitempty"`
// TenantId TenantID is the Azure Active Directory tenant ID for AAD authentication.
TenantId *string `json:"tenant-id,omitempty" yaml:"tenant-id,omitempty"`
}
DtoAzureStorage AzureStorage represents the configuration for Azure Blob storage.
type DtoAzureStorageClass ¶
type DtoAzureStorageClass struct {
// Data DataClass specifies the storage tier for object data.
Data *DtoAzureStorageClassData `json:"data,omitempty" yaml:"data,omitempty"`
// Metadata MetadataClass specifies the storage tier for metadata.
Metadata *DtoAzureStorageClassMetadata `json:"metadata,omitempty" yaml:"metadata,omitempty"`
}
DtoAzureStorageClass AzureStorageClass represents the configuration for Azure Blob Storage access tiers.
type DtoAzureStorageClassData ¶
type DtoAzureStorageClassData string
DtoAzureStorageClassData DataClass specifies the storage tier for object data.
const ( DtoAzureStorageClassDataArchive DtoAzureStorageClassData = "Archive" DtoAzureStorageClassDataCold DtoAzureStorageClassData = "Cold" DtoAzureStorageClassDataCool DtoAzureStorageClassData = "Cool" DtoAzureStorageClassDataHot DtoAzureStorageClassData = "Hot" )
Defines values for DtoAzureStorageClassData.
func (DtoAzureStorageClassData) Valid ¶
func (e DtoAzureStorageClassData) Valid() bool
Valid indicates whether the value is a known member of the DtoAzureStorageClassData enum.
type DtoAzureStorageClassMetadata ¶
type DtoAzureStorageClassMetadata string
DtoAzureStorageClassMetadata MetadataClass specifies the storage tier for metadata.
const ( DtoAzureStorageClassMetadataCold DtoAzureStorageClassMetadata = "Cold" DtoAzureStorageClassMetadataCool DtoAzureStorageClassMetadata = "Cool" DtoAzureStorageClassMetadataHot DtoAzureStorageClassMetadata = "Hot" )
Defines values for DtoAzureStorageClassMetadata.
func (DtoAzureStorageClassMetadata) Valid ¶
func (e DtoAzureStorageClassMetadata) Valid() bool
Valid indicates whether the value is a known member of the DtoAzureStorageClassMetadata enum.
type DtoBackupCommonConfig ¶
type DtoBackupCommonConfig struct {
// TimestampFormat Encoding for backup date in human-readable format in backup file paths (optional).
// Allowed values:
// * ISO (e.g. 2006-01-02T15-04-05)
// * EU (e.g. 02-Jan-2006-15-04-05)
// * US (e.g. Jan-02-2006-15-04-05)
TimestampFormat *DtoBackupCommonConfigTimestampFormat `json:"timestamp-format,omitempty" yaml:"timestamp-format,omitempty"`
}
DtoBackupCommonConfig BackupCommonConfig represents service-level backup settings.
type DtoBackupCommonConfigTimestampFormat ¶
type DtoBackupCommonConfigTimestampFormat string
DtoBackupCommonConfigTimestampFormat Encoding for backup date in human-readable format in backup file paths (optional). Allowed values: * ISO (e.g. 2006-01-02T15-04-05) * EU (e.g. 02-Jan-2006-15-04-05) * US (e.g. Jan-02-2006-15-04-05)
const ( EU DtoBackupCommonConfigTimestampFormat = "EU" ISO DtoBackupCommonConfigTimestampFormat = "ISO" US DtoBackupCommonConfigTimestampFormat = "US" )
Defines values for DtoBackupCommonConfigTimestampFormat.
func (DtoBackupCommonConfigTimestampFormat) Valid ¶
func (e DtoBackupCommonConfigTimestampFormat) Valid() bool
Valid indicates whether the value is a known member of the DtoBackupCommonConfigTimestampFormat enum.
type DtoBackupDetails ¶
type DtoBackupDetails struct {
// ByteCount The size of the backup in bytes.
ByteCount *int64 `json:"byte-count,omitempty" yaml:"byte-count,omitempty"`
// Compression Compression specifies the compression mode used for the backup (ZSTD or NONE).
Compression *string `json:"compression,omitempty" yaml:"compression,omitempty"`
// Created The backup time in the ISO 8601 format.
Created *string `json:"created,omitempty" yaml:"created,omitempty"`
// Duration Duration represents the elapsed time taken by the backup process in seconds.
Duration *int `json:"duration,omitempty" yaml:"duration,omitempty"`
// Encryption Encryption specifies the encryption mode used for the backup (NONE, AES128, AES256).
Encryption *string `json:"encryption,omitempty" yaml:"encryption,omitempty"`
// FileCount The number of backup files created.
FileCount *int64 `json:"file-count,omitempty" yaml:"file-count,omitempty"`
// Finished The time the backup operation completed.
Finished *string `json:"finished,omitempty" yaml:"finished,omitempty"`
// From The lower time bound of backup entities in the ISO 8601 format (for incremental backups only).
From *string `json:"from,omitempty" yaml:"from,omitempty"`
// Key Key is the path to the backup files within the configured storage location.
// This value can be used as `backup-data-path` in dto.RestoreRequest.
Key *string `json:"key,omitempty" yaml:"key,omitempty"`
// Namespace The namespace of a backup.
Namespace *string `json:"namespace,omitempty" yaml:"namespace,omitempty"`
// RecordCount The total number of records backed up.
RecordCount *int64 `json:"record-count,omitempty" yaml:"record-count,omitempty"`
// SecondaryIndexCount The number of secondary indexes backed up.
SecondaryIndexCount *int64 `json:"secondary-index-count,omitempty" yaml:"secondary-index-count,omitempty"`
// Storage Storage specifies the details of the storage location where the backup is stored.
Storage *DtoStorage `json:"storage,omitempty" yaml:"storage,omitempty"`
// Timestamp The backup time in epoch millis.
Timestamp *int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
// UdfCount The number of UDF files backed up.
UdfCount *int64 `json:"udf-count,omitempty" yaml:"udf-count,omitempty"`
}
DtoBackupDetails BackupDetails contains information about a finished backup.
type DtoBackupPolicy ¶
type DtoBackupPolicy struct {
// Bandwidth Throttles backup write speed to a maximum of the specified bandwidth in MiB/s.
// Default is no limit.
Bandwidth *int `json:"bandwidth,omitempty" yaml:"bandwidth,omitempty"`
// Compression Compression details (algorithm and mode). Default is no compression.
// Enabling compression reduces storage and network usage, but increases CPU usage during the backup.
// Depending on the system configuration, compression may improve or degrade overall performance.
Compression *DtoCompressionPolicy `json:"compression,omitempty" yaml:"compression,omitempty"`
// ConcurrentIncremental Allows incremental backups to run concurrently.
// When false (default), incremental backups are skipped if another backup for same routine is in progress.
ConcurrentIncremental *bool `json:"concurrent-incremental,omitempty" yaml:"concurrent-incremental,omitempty"`
// Encryption Encryption details (algorithm and key). Default is no encryption.
Encryption *DtoEncryptionPolicy `json:"encryption,omitempty" yaml:"encryption,omitempty"`
// FileLimit File size limit (in MB) for the backup directory. If an .asb backup file crosses this size threshold,
// a new backup file will be created.
FileLimit *int `json:"file-limit,omitempty" yaml:"file-limit,omitempty"`
// MaxConcurrentNodes Maximum number of concurrent requests to server nodes.
// Default is to issue requests to all server nodes in parallel.
MaxConcurrentNodes *int `json:"max-concurrent-nodes,omitempty" yaml:"max-concurrent-nodes,omitempty"`
// NoIndexes Do not back up any secondary index definitions.
NoIndexes *bool `json:"no-indexes,omitempty" yaml:"no-indexes,omitempty"`
// NoRecords Do not back up any record data (metadata or bin data).
NoRecords *bool `json:"no-records,omitempty" yaml:"no-records,omitempty"`
// NoUdfs Do not back up any UDF modules.
NoUdfs *bool `json:"no-udfs,omitempty" yaml:"no-udfs,omitempty"`
// Parallel Maximum number of scan calls to run in parallel. Each scan call processes a subset of the total
// data partitions. The optimal value depends on hardware and network configuration.
Parallel *int `json:"parallel,omitempty" yaml:"parallel,omitempty"`
// ParallelWrite Maximum number of threads to use for writing backup files. If not specified, same values as `parallel` is used.
ParallelWrite *int `json:"parallel-write,omitempty" yaml:"parallel-write,omitempty"`
// RecordsPerSecond Limits the number of records returned per second (RPS).
// Default is no limit.
RecordsPerSecond *int `json:"records-per-second,omitempty" yaml:"records-per-second,omitempty"`
// Retention Specifies how long to retain full and incremental backups.
// Cleanup runs asynchronously after each successful full backup, never deleting backups preemptively.
// Ensure storage capacity for at least one extra full backup beyond the retention configuration.
Retention *DtoRetentionPolicy `json:"retention,omitempty" yaml:"retention,omitempty"`
// RetryPolicy RetryPolicy defines the configuration for database scan retry attempts in case of failures.
// If nil, the default policy is used (5 retries with a one-minute delay between attempts).
RetryPolicy *DtoRetryPolicy `json:"retry-policy,omitempty" yaml:"retry-policy,omitempty"`
// Sealed Sealed determines whether backup should include keys updated during the backup process.
// When true, the backup contains only records that last modified before backup started.
// When false (default), records updated during backup might be included in the backup, but it's not guaranteed.
// This parameter does not affect XDR backups (which always includes all keys).
Sealed *bool `json:"sealed,omitempty" yaml:"sealed,omitempty"`
// SocketTimeout Socket timeout in milliseconds. Default is 10 minutes. If this value is 0, it is set to total-timeout.
// If both are 0, there is no socket idle time limit.
SocketTimeout *int `json:"socket-timeout,omitempty" yaml:"socket-timeout,omitempty"`
// TotalTimeout Total socket timeout in milliseconds. Default is 0, that is, no timeout.
TotalTimeout *int `json:"total-timeout,omitempty" yaml:"total-timeout,omitempty"`
// UseScanCompression Enables built-in compression during scan operation.
// Valid for Aerospike Server Enterprise Edition only.
UseScanCompression *bool `json:"use-scan-compression,omitempty" yaml:"use-scan-compression,omitempty"`
// WithClusterConfiguration Back up Aerospike cluster configuration.
WithClusterConfiguration *bool `json:"with-cluster-configuration,omitempty" yaml:"with-cluster-configuration,omitempty"`
}
DtoBackupPolicy BackupPolicy represents a scheduled backup policy.
type DtoBackupRoutine ¶
type DtoBackupRoutine struct {
// BackupPolicy The name of the corresponding backup policy, one of defined in `config.backup-policies` (optional).
BackupPolicy *string `json:"backup-policy,omitempty" yaml:"backup-policy,omitempty"`
// BinList The list of backup bin names (optional, an empty list implies backing up all bins) extensions:"x-nullable".
BinList *[]string `json:"bin-list,omitempty" yaml:"bin-list,omitempty"`
// Disabled Whether this routine is disabled and should not run. Default: false.
Disabled *bool `json:"disabled,omitempty" yaml:"disabled,omitempty"`
// IncrIntervalCron The interval for incremental backup as a cron expression string (optional).
IncrIntervalCron *string `json:"incr-interval-cron,omitempty" yaml:"incr-interval-cron,omitempty"`
// IntervalCron The interval for full backup as a cron expression string.
// Cron expression format: https://github.com/reugn/go-quartz?tab=readme-ov-file#cron-expression-format
IntervalCron string `json:"interval-cron" yaml:"interval-cron"`
// Namespaces The list of the namespaces to back up (empty list implies backup of the whole cluster).
Namespaces []string `json:"namespaces" yaml:"namespaces"`
// NodeList NodeList specifies which Aerospike nodes to include in the backup.
// Only the listed nodes will be backed up.
// Each node can be specified as one of the following:
// - "<IP address>:<port>"
// - "<hostname>:<port>"
// - "<node ID>"
// To obtain node identifiers, run: `asinfo -v "service:"`.
// If using IP addresses or hostnames, ensure they match the values returned by the `asinfo` command.
// Mutually exclusive with partition-list and rack-list in this routine,
// and also mutually exclusive with the cluster's prefer-racks setting.
// Parallelism is determined by the number of listed nodes unless `BackupPolicy.Parallel` is set to a lower value.
NodeList *[]string `json:"node-list,omitempty" yaml:"node-list,omitempty"`
// PartitionList PartitionList defines the list of partitions to include in the backup.
// The format supports individual partitions or ranges.
// - A range is specified as "<start>-<count>" (e.g., "100-50" backs up 50 partitions starting from 100).
// - A single partition is specified as a number (e.g., "0").
// Multiple entries can be comma-separated: e.g., "0,100,200,300,400,500".
// By default, all partitions (0 to 4095) are backed up.
// Mutually exclusive with node-list and rack-list in this routine,
// and also mutually exclusive with the cluster's prefer-racks setting.
PartitionList *string `json:"partition-list,omitempty" yaml:"partition-list,omitempty"`
// RackList RackList specifies the Aerospike Server rack IDs from which to read records
// during backup.
// If provided, only nodes belonging to these specified racks will be scanned.
// If the list is empty or omitted, no rack filtering is applied.
// Mutually exclusive with partition-list and node-list in this routine,
// and also mutually exclusive with the cluster's prefer-racks setting.
RackList *[]int `json:"rack-list,omitempty" yaml:"rack-list,omitempty"`
// SecretAgent The name of a Secret Agent to read secrets from (optional).
SecretAgent *string `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SetList The list of backup set names (optional, an empty list implies backing up all sets).
SetList *[]string `json:"set-list,omitempty" yaml:"set-list,omitempty"`
// SourceCluster The name of the corresponding source cluster.
SourceCluster string `json:"source-cluster" yaml:"source-cluster"`
// Storage The name of the corresponding storage provider configuration.
Storage string `json:"storage" yaml:"storage"`
}
DtoBackupRoutine BackupRoutine represents a scheduled backup operation routine.
type DtoCompressionPolicy ¶
type DtoCompressionPolicy struct {
// Level The compression level to use.
// Algorithm-specific; for zstd: from -1 (fastest) to 22 (best compression).
// This field is ignored if the compression mode is NONE.
Level *int `json:"level,omitempty" yaml:"level,omitempty"`
// Mode The compression mode to be used (default is NONE).
Mode *DtoCompressionPolicyMode `json:"mode,omitempty" yaml:"mode,omitempty"`
}
DtoCompressionPolicy CompressionPolicy contains backup compression information.
type DtoCompressionPolicyMode ¶
type DtoCompressionPolicyMode string
DtoCompressionPolicyMode The compression mode to be used (default is NONE).
const ( DtoCompressionPolicyModeNONE DtoCompressionPolicyMode = "NONE" DtoCompressionPolicyModeZSTD DtoCompressionPolicyMode = "ZSTD" )
Defines values for DtoCompressionPolicyMode.
func (DtoCompressionPolicyMode) Valid ¶
func (e DtoCompressionPolicyMode) Valid() bool
Valid indicates whether the value is a known member of the DtoCompressionPolicyMode enum.
type DtoConfig ¶
type DtoConfig struct {
// AerospikeClusters AerospikeClusters is a map of Aerospike clusters that can be used by backup routines.
AerospikeClusters *map[string]DtoAerospikeCluster `json:"aerospike-clusters,omitempty" yaml:"aerospike-clusters,omitempty"`
// BackupPolicies BackupPolicies is a map of backup policies that can be used by backup routines.
BackupPolicies *map[string]DtoBackupPolicy `json:"backup-policies,omitempty" yaml:"backup-policies,omitempty"`
// BackupRoutines BackupRoutines is a map of backup routines.
BackupRoutines *map[string]DtoBackupRoutine `json:"backup-routines,omitempty" yaml:"backup-routines,omitempty"`
// SecretAgents SecretAgents is a map of secret agents used by backup routines (for encryption keys), clusters (for credentials), and storage (for authentication).
SecretAgents *map[string]DtoSecretAgent `json:"secret-agents,omitempty" yaml:"secret-agents,omitempty"`
// Service ServiceConfig contains general service settings.
Service *DtoServiceConfig `json:"service,omitempty" yaml:"service,omitempty"`
// Storage Storage is a map of storages that can be used by backup routines.
Storage *map[string]DtoStorage `json:"storage,omitempty" yaml:"storage,omitempty"`
}
DtoConfig Config represents the service configuration file.
type DtoCredentials ¶
type DtoCredentials struct {
// AuthMode The authentication mode string (INTERNAL, EXTERNAL, PKI).
AuthMode *DtoCredentialsAuthMode `json:"auth-mode,omitempty" yaml:"auth-mode,omitempty"`
// Password The password for the cluster authentication.
// It can be either plain text or path into the secret agent.
Password *string `json:"password,omitempty" yaml:"password,omitempty"`
// PasswordPath The file path with the password string.
PasswordPath *string `json:"password-path,omitempty" yaml:"password-path,omitempty"`
// SecretAgent Secret Agent configuration (optional).
// Mutually exclusive with 'secret-agent-name'.
SecretAgent *DtoSecretAgent `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SecretAgentName Secret Agent configuration (optional). Link to one of preconfigured agents.
// Mutually exclusive with 'secret-agent'.
SecretAgentName *string `json:"secret-agent-name,omitempty" yaml:"secret-agent-name,omitempty"`
// User The username for the cluster authentication.
User *string `json:"user,omitempty" yaml:"user,omitempty"`
}
DtoCredentials Credentials represents authentication details to the Aerospike cluster.
type DtoCredentialsAuthMode ¶
type DtoCredentialsAuthMode string
DtoCredentialsAuthMode The authentication mode string (INTERNAL, EXTERNAL, PKI).
const ( EXTERNAL DtoCredentialsAuthMode = "EXTERNAL" INTERNAL DtoCredentialsAuthMode = "INTERNAL" PKI DtoCredentialsAuthMode = "PKI" )
Defines values for DtoCredentialsAuthMode.
func (DtoCredentialsAuthMode) Valid ¶
func (e DtoCredentialsAuthMode) Valid() bool
Valid indicates whether the value is a known member of the DtoCredentialsAuthMode enum.
type DtoEncryptionPolicy ¶
type DtoEncryptionPolicy struct {
// KeyEnv The name of the environment variable containing the encryption key.
KeyEnv *string `json:"key-env,omitempty" yaml:"key-env,omitempty"`
// KeyFile The path to the file containing the encryption key.
KeyFile *string `json:"key-file,omitempty" yaml:"key-file,omitempty"`
// KeySecret The secret keyword in Aerospike Secret Agent containing the encryption key.
KeySecret *string `json:"key-secret,omitempty" yaml:"key-secret,omitempty"`
// Mode The encryption mode to be used (NONE, AES128, AES256)
Mode *DtoEncryptionPolicyMode `json:"mode,omitempty" yaml:"mode,omitempty"`
}
DtoEncryptionPolicy EncryptionPolicy contains backup encryption information.
type DtoEncryptionPolicyMode ¶
type DtoEncryptionPolicyMode string
DtoEncryptionPolicyMode The encryption mode to be used (NONE, AES128, AES256)
const ( DtoEncryptionPolicyModeAES128 DtoEncryptionPolicyMode = "AES128" DtoEncryptionPolicyModeAES256 DtoEncryptionPolicyMode = "AES256" DtoEncryptionPolicyModeNONE DtoEncryptionPolicyMode = "NONE" )
Defines values for DtoEncryptionPolicyMode.
func (DtoEncryptionPolicyMode) Valid ¶
func (e DtoEncryptionPolicyMode) Valid() bool
Valid indicates whether the value is a known member of the DtoEncryptionPolicyMode enum.
type DtoFileLoggerConfig ¶
type DtoFileLoggerConfig struct {
// Compress Compress determines if the rotated log files should be compressed
// using gzip. The default is not to perform compression.
Compress *bool `json:"compress,omitempty" yaml:"compress,omitempty"`
// Filename Filename is the file to write logs to.
Filename string `json:"filename" yaml:"filename"`
// Maxage MaxAge is the maximum number of days to retain old log files based on the
// timestamp encoded in their filename. The default is not to remove old log files
// based on age.
Maxage *int `json:"maxage,omitempty" yaml:"maxage,omitempty"`
// Maxbackups MaxBackups is the maximum number of old log files to retain. The default
// is to retain all old log files.
Maxbackups *int `json:"maxbackups,omitempty" yaml:"maxbackups,omitempty"`
// Maxsize MaxSize is the maximum size in megabytes of the log file before it gets rotated.
Maxsize *int `json:"maxsize,omitempty" yaml:"maxsize,omitempty"`
}
DtoFileLoggerConfig FileLoggerConfig represents the configuration for the file logger writer.
type DtoGcpStorage ¶
type DtoGcpStorage struct {
// BucketName GCP storage bucket name.
BucketName string `json:"bucket-name" yaml:"bucket-name"`
// Endpoint Alternative url.
// It is not recommended to use an alternate URL in a production environment.
Endpoint *string `json:"endpoint,omitempty" yaml:"endpoint,omitempty"`
// Key Key is the service account key in JSON format.
// This is sensitive information. Can be a path in secret agent or an actual value.
Key *string `json:"key,omitempty" yaml:"key,omitempty"`
// KeyFilePath Path to the file containing the service account key in JSON format.
KeyFilePath *string `json:"key-file-path,omitempty" yaml:"key-file-path,omitempty"`
// MinPartSize The minimum size in bytes of individual GCP storage chunks.
MinPartSize *int `json:"min-part-size,omitempty" yaml:"min-part-size,omitempty"`
// Path The root path for the backup repository. If not specified, backups will be saved in the bucket's root.
Path *string `json:"path,omitempty" yaml:"path,omitempty"`
// SecretAgent Secret Agent configuration (optional).
// Mutually exclusive with 'secret-agent-name'.
SecretAgent *DtoSecretAgent `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SecretAgentName Secret Agent configuration (optional). Link to one of preconfigured agents.
// Mutually exclusive with 'secret-agent'.
SecretAgentName *string `json:"secret-agent-name,omitempty" yaml:"secret-agent-name,omitempty"`
// StorageClass StorageClass defines the storage class for data and metadata objects.
StorageClass *DtoGcpStorageClass `json:"storage-class,omitempty" yaml:"storage-class,omitempty"`
}
DtoGcpStorage GcpStorage represents the configuration for GCP storage.
type DtoGcpStorageClass ¶
type DtoGcpStorageClass struct {
// Data DataClass specifies the storage class for object data.
Data *DtoGcpStorageClassData `json:"data,omitempty" yaml:"data,omitempty"`
}
DtoGcpStorageClass GcpStorageClass represents the configuration for GCP Storage Class.
type DtoGcpStorageClassData ¶
type DtoGcpStorageClassData string
DtoGcpStorageClassData DataClass specifies the storage class for object data.
const ( DtoGcpStorageClassDataARCHIVE DtoGcpStorageClassData = "ARCHIVE" DtoGcpStorageClassDataCOLDLINE DtoGcpStorageClassData = "COLDLINE" DtoGcpStorageClassDataNEARLINE DtoGcpStorageClassData = "NEARLINE" DtoGcpStorageClassDataSTANDARD DtoGcpStorageClassData = "STANDARD" )
Defines values for DtoGcpStorageClassData.
func (DtoGcpStorageClassData) Valid ¶
func (e DtoGcpStorageClassData) Valid() bool
Valid indicates whether the value is a known member of the DtoGcpStorageClassData enum.
type DtoHTTPServerConfig ¶
type DtoHTTPServerConfig struct {
// Address The address to listen on.
Address *string `json:"address,omitempty" yaml:"address,omitempty"`
// ContextPath ContextPath customizes path for the API endpoints.
ContextPath *string `json:"context-path,omitempty" yaml:"context-path,omitempty"`
// Port The port to listen on.
Port *int `json:"port,omitempty" yaml:"port,omitempty"`
// Rate HTTP rate limiter configuration.
Rate *DtoRateLimiterConfig `json:"rate,omitempty" yaml:"rate,omitempty"`
// Timeout Timeout for http server operations in milliseconds.
Timeout *int `json:"timeout,omitempty" yaml:"timeout,omitempty"`
}
DtoHTTPServerConfig HTTPServerConfig represents the service's HTTP server configuration.
type DtoJobStatus ¶
type DtoJobStatus string
DtoJobStatus JobStatus represents possible states of restore jobs.
const ( JobStatusCanceled DtoJobStatus = "Canceled" JobStatusDone DtoJobStatus = "Done" JobStatusFailed DtoJobStatus = "Failed" JobStatusRunning DtoJobStatus = "Running" )
Defines values for DtoJobStatus.
func (DtoJobStatus) Valid ¶
func (e DtoJobStatus) Valid() bool
Valid indicates whether the value is a known member of the DtoJobStatus enum.
type DtoLocalStorage ¶
type DtoLocalStorage struct {
// MinPartSize The minimum size in bytes of individual storage chunks.
MinPartSize *int `json:"min-part-size,omitempty" yaml:"min-part-size,omitempty"`
// Path The root path for the backup repository.
Path string `json:"path" yaml:"path"`
}
DtoLocalStorage LocalStorage represents the configuration for local storage.
type DtoLoggerConfig ¶
type DtoLoggerConfig struct {
// FileWriter File writer logging configuration.
FileWriter *DtoFileLoggerConfig `json:"file-writer,omitempty" yaml:"file-writer,omitempty"`
// Format Format is the logger format (PLAIN, JSON).
Format *DtoLoggerConfigFormat `json:"format,omitempty" yaml:"format,omitempty"`
// Level Level is the logger level.
Level *DtoLoggerConfigLevel `json:"level,omitempty" yaml:"level,omitempty"`
// StdoutWriter Whether to enable logging to the standard output.
StdoutWriter *bool `json:"stdout-writer,omitempty" yaml:"stdout-writer,omitempty"`
}
DtoLoggerConfig LoggerConfig represents the backup service logger configuration.
type DtoLoggerConfigFormat ¶
type DtoLoggerConfigFormat string
DtoLoggerConfigFormat Format is the logger format (PLAIN, JSON).
const ( JSON DtoLoggerConfigFormat = "JSON" PLAIN DtoLoggerConfigFormat = "PLAIN" )
Defines values for DtoLoggerConfigFormat.
func (DtoLoggerConfigFormat) Valid ¶
func (e DtoLoggerConfigFormat) Valid() bool
Valid indicates whether the value is a known member of the DtoLoggerConfigFormat enum.
type DtoLoggerConfigLevel ¶
type DtoLoggerConfigLevel string
DtoLoggerConfigLevel Level is the logger level.
const ( DtoLoggerConfigLevelDEBUG DtoLoggerConfigLevel = "DEBUG" DtoLoggerConfigLevelERROR DtoLoggerConfigLevel = "ERROR" DtoLoggerConfigLevelINFO DtoLoggerConfigLevel = "INFO" DtoLoggerConfigLevelTRACE DtoLoggerConfigLevel = "TRACE" DtoLoggerConfigLevelWARN DtoLoggerConfigLevel = "WARN" DtoLoggerConfigLevelWARNING DtoLoggerConfigLevel = "WARNING" )
Defines values for DtoLoggerConfigLevel.
func (DtoLoggerConfigLevel) Valid ¶
func (e DtoLoggerConfigLevel) Valid() bool
Valid indicates whether the value is a known member of the DtoLoggerConfigLevel enum.
type DtoMetrics ¶
type DtoMetrics struct {
// KilobytesPerSecond Current speed as the amount of data processed by storage per second, in kilobytes.
KilobytesPerSecond *int `json:"kilobytes-per-second,omitempty" yaml:"kilobytes-per-second,omitempty"`
// Pipeline The number of records that have been read from the source, but not yet written to the destination.
// This metric helps identify bottlenecks:
// - If Pipeline is zero or fluctuates near zero, it means the destination is consuming data
// faster than the source can read.
// - If Pipeline grows large, it indicates that the source is producing data faster
// than the destination can consume.
Pipeline *int `json:"pipeline,omitempty" yaml:"pipeline,omitempty"`
// RecordsPerSecond Current speed as the number of records processed by Aerospike per second.
RecordsPerSecond *int `json:"records-per-second,omitempty" yaml:"records-per-second,omitempty"`
}
DtoMetrics Metrics represents the current job speed.
type DtoRateLimiterConfig ¶
type DtoRateLimiterConfig struct {
// Size Rate limiter token bucket size (bursts threshold).
Size *int `json:"size,omitempty" yaml:"size,omitempty"`
// Tps Rate limiter tokens per second threshold.
Tps *int `json:"tps,omitempty" yaml:"tps,omitempty"`
// WhiteList The list of ips to whitelist in rate limiting (optional).
// Default: allow all.
WhiteList *[]string `json:"white-list,omitempty" yaml:"white-list,omitempty"`
}
DtoRateLimiterConfig RateLimiterConfig is the HTTP server rate limiter configuration.
type DtoRestoreCompressionPolicy ¶
type DtoRestoreCompressionPolicy struct {
// Mode The compression mode to be used (default is NONE).
Mode *DtoRestoreCompressionPolicyMode `json:"mode,omitempty" yaml:"mode,omitempty"`
}
DtoRestoreCompressionPolicy RestoreCompressionPolicy contains restore compression information.
type DtoRestoreCompressionPolicyMode ¶
type DtoRestoreCompressionPolicyMode string
DtoRestoreCompressionPolicyMode The compression mode to be used (default is NONE).
const ( NONE DtoRestoreCompressionPolicyMode = "NONE" ZSTD DtoRestoreCompressionPolicyMode = "ZSTD" )
Defines values for DtoRestoreCompressionPolicyMode.
func (DtoRestoreCompressionPolicyMode) Valid ¶
func (e DtoRestoreCompressionPolicyMode) Valid() bool
Valid indicates whether the value is a known member of the DtoRestoreCompressionPolicyMode enum.
type DtoRestoreJobStatus ¶
type DtoRestoreJobStatus struct {
// CurrentJob Speed related metrics of the restore process.
CurrentJob *DtoRunningJob `json:"current-job,omitempty" yaml:"current-job,omitempty"`
// Error Error message if any.
Error *string `json:"error,omitempty" yaml:"error,omitempty"`
// ErrorsInDoubt The number of errors in doubt while restoring.
// (IsInDoubt signifies that the write operation may have gone through on the server
// but the client is not able to confirm that due an error.)
// Non zero value indicates that there are might be unexpected side effects during restore, like
// * Generation counter greater than expected for some records.
// * Fresher records counter greater than expected.
ErrorsInDoubt *int64 `json:"errors-in-doubt,omitempty" yaml:"errors-in-doubt,omitempty"`
// ExistedRecords The number of records dropped because they already existed in the database.
ExistedRecords *int64 `json:"existed-records,omitempty" yaml:"existed-records,omitempty"`
// ExpiredRecords The number of records dropped because they were expired.
ExpiredRecords *int64 `json:"expired-records,omitempty" yaml:"expired-records,omitempty"`
// FresherRecords The number of records dropped because the database already contained the records with a higher generation count.
FresherRecords *int64 `json:"fresher-records,omitempty" yaml:"fresher-records,omitempty"`
// IgnoredRecords The number of records ignored because of a record-level permanent error while restoring.
IgnoredRecords *int64 `json:"ignored-records,omitempty" yaml:"ignored-records,omitempty"`
// IndexCount The number of successfully created secondary indexes.
IndexCount *int64 `json:"index-count,omitempty" yaml:"index-count,omitempty"`
// InsertedRecords The number of successfully restored records.
InsertedRecords *int64 `json:"inserted-records,omitempty" yaml:"inserted-records,omitempty"`
// ReadRecords Number of records read from backup.
// When restore is finished, `read-records` = `inserted-records` + `fresher-records` +
// `existed-records` + `ignored-records` + `skipped-records` + `expired-records`
ReadRecords *int64 `json:"read-records,omitempty" yaml:"read-records,omitempty"`
// SkippedRecords The number of records dropped because they didn't contain any of the
// selected bins or didn't belong to any of the selected sets.
SkippedRecords *int64 `json:"skipped-records,omitempty" yaml:"skipped-records,omitempty"`
// Status Status of the restore job.
Status *DtoJobStatus `json:"status,omitempty" yaml:"status,omitempty"`
// TotalBytes Total bytes read from backup.
TotalBytes *int64 `json:"total-bytes,omitempty" yaml:"total-bytes,omitempty"`
// UdfCount The number of successfully stored UDF files.
UdfCount *int64 `json:"udf-count,omitempty" yaml:"udf-count,omitempty"`
}
DtoRestoreJobStatus RestoreJobStatus represents restore job status.
type DtoRestoreNamespace ¶
type DtoRestoreNamespace struct {
// Destination Name of the destination namespace to restore data into.
Destination string `json:"destination" yaml:"destination"`
// Source Original namespace name.
// This field is required as a safeguard to ensure intentional namespace remapping.
Source string `json:"source" yaml:"source"`
}
DtoRestoreNamespace RestoreNamespace specifies an alternative namespace name for the restore operation.
type DtoRestorePolicy ¶
type DtoRestorePolicy struct {
// Bandwidth Throttles read operations from the backup file(s) to not exceed the given I/O bandwidth in MiB/s.
// Default: no limit.
Bandwidth *int `json:"bandwidth,omitempty" yaml:"bandwidth,omitempty"`
// BatchSize The max allowed number of records per an async batch write call.
// Only applicable when using batch writes.
BatchSize *int `json:"batch-size,omitempty" yaml:"batch-size,omitempty"`
// BinList The bins to restore (optional, an empty list implies restoring all bins).
BinList *[]string `json:"bin-list,omitempty" yaml:"bin-list,omitempty"`
// Compression Compression details (algorithm). Default is no compression.
Compression *DtoRestoreCompressionPolicy `json:"compression,omitempty" yaml:"compression,omitempty"`
// DisableBatchWrites Disables the use of batch writes when restoring records to the Aerospike cluster.
// By default, the cluster is checked for batch write support.
DisableBatchWrites *bool `json:"disable-batch-writes,omitempty" yaml:"disable-batch-writes,omitempty"`
// Encryption Encryption details (algorithm and key). Default is no encryption.
Encryption *DtoEncryptionPolicy `json:"encryption,omitempty" yaml:"encryption,omitempty"`
// ExtraTtl Amount of extra time-to-live to add to records that have expirable void-times.
// Must be set in seconds.
ExtraTtl *int `json:"extra-ttl,omitempty" yaml:"extra-ttl,omitempty"`
// MaxAsyncBatches The max number of outstanding async record batch write calls at a time.
MaxAsyncBatches *int `json:"max-async-batches,omitempty" yaml:"max-async-batches,omitempty"`
// Namespace Namespace optionally specifies an alternative namespace name for the restore operation.
// By default, the data is restored to the namespace from which it was taken.
Namespace *DtoRestoreNamespace `json:"namespace,omitempty" yaml:"namespace,omitempty"`
// NoGeneration Records from backups take precedence. This option disables the generation check.
// With this option, records from the backup always overwrite records that already exist in
// the namespace, regardless of generation numbers.
NoGeneration *bool `json:"no-generation,omitempty" yaml:"no-generation,omitempty"`
// NoIndexes Do not restore any secondary index definitions.
NoIndexes *bool `json:"no-indexes,omitempty" yaml:"no-indexes,omitempty"`
// NoRecords Do not restore any record data (metadata or bin data).
// By default, record data, secondary index definitions, and UDF modules will be restored.
NoRecords *bool `json:"no-records,omitempty" yaml:"no-records,omitempty"`
// NoUdfs Do not restore any UDF modules.
NoUdfs *bool `json:"no-udfs,omitempty" yaml:"no-udfs,omitempty"`
// Parallel The number of concurrent record readers from backup files.
// This value controls the level of parallelism used by the backup service when
// reading backup files.
// The optimal value depends on hardware and network configuration.
Parallel *int `json:"parallel,omitempty" yaml:"parallel,omitempty"`
// Replace Replace records. This controls how records from the backup overwrite existing records in
// the namespace. By default, restoring a record from a backup only replaces the bins
// contained in the backup; all other bins of an existing record remain untouched.
Replace *bool `json:"replace,omitempty" yaml:"replace,omitempty"`
// RetryPolicy Configuration of retries for each restore write operation.
// If nil, the default policy is used (5 retries with a one-minute delay between attempts).
RetryPolicy *DtoRetryPolicy `json:"retry-policy,omitempty" yaml:"retry-policy,omitempty"`
// SetList The sets to restore (optional, an empty list implies restoring all sets).
SetList *[]string `json:"set-list,omitempty" yaml:"set-list,omitempty"`
// SocketTimeout Timeout (ms) for Aerospike commands to write records, create indexes and create UDFs.
// Socket timeout in milliseconds. Default is 10 minutes. If this value is 0, it is set to total-timeout.
// If both are 0, there is no socket idle time limit.
SocketTimeout *int `json:"socket-timeout,omitempty" yaml:"socket-timeout,omitempty"`
// TotalTimeout Total socket timeout in milliseconds. Default is 0, that is, no timeout.
TotalTimeout *int `json:"total-timeout,omitempty" yaml:"total-timeout,omitempty"`
// Tps Throttles read operations from the backup file(s) to not exceed the given number of transactions per second.
// Default: no limit.
Tps *int `json:"tps,omitempty" yaml:"tps,omitempty"`
// Unique Existing records take precedence. With this option, only records that do not exist in
// the namespace are restored, regardless of generation numbers. If a record exists in
// the namespace, the record from the backup is ignored.
Unique *bool `json:"unique,omitempty" yaml:"unique,omitempty"`
}
DtoRestorePolicy RestorePolicy represents a policy for the restore operation.
type DtoRestoreRequest ¶
type DtoRestoreRequest struct {
// BackupDataPath Path to the data from storage root.
// You can obtain this value by:
// - Browsing the storage UI, or
// - Reading the `key` field in the response from GET `v1/backups/full/{routine}`
BackupDataPath string `json:"backup-data-path" yaml:"backup-data-path"`
// Destination The details of the Aerospike destination cluster.
// Mutually exclusive with 'destination-name'.
Destination *DtoAerospikeCluster `json:"destination,omitempty" yaml:"destination,omitempty"`
// DestinationName Link to one of preconfigured clusters.
// Mutually exclusive with 'destination'.
DestinationName *string `json:"destination-name,omitempty" yaml:"destination-name,omitempty"`
// Policy Restore policy to use in the operation.
Policy *DtoRestorePolicy `json:"policy,omitempty" yaml:"policy,omitempty"`
// SecretAgent Secret Agent configuration (optional).
// Mutually exclusive with 'secret-agent-name'.
SecretAgent *DtoSecretAgent `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SecretAgentName Secret Agent configuration (optional). Link to one of preconfigured agents.
// Mutually exclusive with 'secret-agent'.
SecretAgentName *string `json:"secret-agent-name,omitempty" yaml:"secret-agent-name,omitempty"`
// Source The details of the storage configuration.
// Mutually exclusive with 'source-name'.
Source *DtoStorage `json:"source,omitempty" yaml:"source,omitempty"`
// SourceName Link to one of preconfigured storages.
// Mutually exclusive with 'source'.
SourceName *string `json:"source-name,omitempty" yaml:"source-name,omitempty"`
}
DtoRestoreRequest RestoreRequest represents a restore operation request.
type DtoRestoreTimestampRequest ¶
type DtoRestoreTimestampRequest struct {
// Destination The details of the Aerospike destination cluster.
// Mutually exclusive with 'destination-name'.
Destination *DtoAerospikeCluster `json:"destination,omitempty" yaml:"destination,omitempty"`
// DestinationName Link to one of preconfigured clusters.
// Mutually exclusive with 'destination'.
DestinationName *string `json:"destination-name,omitempty" yaml:"destination-name,omitempty"`
// DisableReordering Disable reverse order of incremental backups optimisation.
DisableReordering *bool `json:"disable-reordering,omitempty" yaml:"disable-reordering,omitempty"`
// Policy Restore policy to use in the operation.
Policy *DtoTimestampRestorePolicy `json:"policy,omitempty" yaml:"policy,omitempty"`
// Routine The backup routine name.
Routine string `json:"routine" yaml:"routine"`
// SecretAgent Secret Agent configuration (optional).
// Mutually exclusive with 'secret-agent-name'.
SecretAgent *DtoSecretAgent `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SecretAgentName Secret Agent configuration (optional). Link to one of preconfigured agents.
// Mutually exclusive with 'secret-agent'.
SecretAgentName *string `json:"secret-agent-name,omitempty" yaml:"secret-agent-name,omitempty"`
// Time Required epoch time (in millis) for recovery. The closest backup before the timestamp will be applied.
Time int64 `json:"time" yaml:"time"`
}
DtoRestoreTimestampRequest RestoreTimestampRequest represents a restore by timestamp operation request.
type DtoRetentionPolicy ¶
type DtoRetentionPolicy struct {
// Full Number of full backups to store:
// - If nil, retain all full backups.
// - If N is specified, retain the last N full backups.
// - The minimum value is 1.
Full *int `json:"full,omitempty" yaml:"full,omitempty"`
// Incremental Number of full backups to store incremental backups for:
// - If nil, retain all incremental backups.
// - If N is specified, retain incremental backups for the last N full backups.
// - If set to 0, do not retain any incremental backups.
// - Must not exceed the value of FullBackups.
Incremental *int `json:"incremental,omitempty" yaml:"incremental,omitempty"`
}
DtoRetentionPolicy RetentionPolicy specifies how many full and incremental backups to keep.
type DtoRetryPolicy ¶
type DtoRetryPolicy struct {
// BaseTimeout BaseTimeout is the initial delay between retry attempts, in milliseconds.
BaseTimeout *int `json:"base-timeout,omitempty" yaml:"base-timeout,omitempty"`
// MaxRetries MaxRetries is the maximum number of retry attempts that will be made.
// If set to 0, no retries will be performed.
MaxRetries *int `json:"max-retries,omitempty" yaml:"max-retries,omitempty"`
// Multiplier Multiplier is used to increase the delay between subsequent retry attempts.
// The actual delay is calculated as: BaseTimeout * (Multiplier ^ attemptNumber)
Multiplier *float32 `json:"multiplier,omitempty" yaml:"multiplier,omitempty"`
}
DtoRetryPolicy RetryPolicy defines the configuration for retry attempts in case of failures.
type DtoRoutineState ¶
type DtoRoutineState struct {
// Full Full represents the state of a full backup. Nil if no full backup is running.
Full *DtoRunningJob `json:"full,omitempty" yaml:"full,omitempty"`
// Incremental Incremental represents the state of an incremental backup. Nil if no incremental backup is running.
Incremental *DtoRunningJob `json:"incremental,omitempty" yaml:"incremental,omitempty"`
// LastFull LastFull: the time of the last successful full backup.
// A nil value indicates that there has never been a full backup.
LastFull *string `json:"last-full,omitempty" yaml:"last-full,omitempty"`
// LastIncremental LastIncremental: the time of the last successful incremental backup.
// A nil value indicates that there has never been an incremental backup.
LastIncremental *string `json:"last-incremental,omitempty" yaml:"last-incremental,omitempty"`
// NextFull NextFull: the time of the next scheduled full backup.
NextFull *string `json:"next-full,omitempty" yaml:"next-full,omitempty"`
// NextIncremental NextIncremental: the time of the next scheduled incremental backup.
NextIncremental *string `json:"next-incremental,omitempty" yaml:"next-incremental,omitempty"`
}
DtoRoutineState RoutineState represent the current state of backups (full and incremental).
type DtoRunningJob ¶
type DtoRunningJob struct {
// DoneRecords The number of records that have been successfully done.
DoneRecords *int `json:"done-records,omitempty" yaml:"done-records,omitempty"`
// Duration Duration represents the elapsed time taken by the job in seconds.
Duration *int `json:"duration,omitempty" yaml:"duration,omitempty"`
// EstimatedEndTime The estimated time when the backup operation will be completed.
// It is calculated based on the current percentage done and duration.
// A nil value indicates that the estimation is not available yet.
// This value is not guaranteed to be accurate.
EstimatedEndTime *string `json:"estimated-end-time,omitempty" yaml:"estimated-end-time,omitempty"`
// FinishTime The time when the operation finished.
// A nil value indicates that the operation is still running.
FinishTime *string `json:"finish-time,omitempty" yaml:"finish-time,omitempty"`
// Metrics Metrics provides real-time information about data flow performance.
Metrics *DtoMetrics `json:"metrics,omitempty" yaml:"metrics,omitempty"`
// PercentageDone The progress of the backup operation as a percentage.
// This value is not guaranteed to be accurate.
PercentageDone *int `json:"percentage-done,omitempty" yaml:"percentage-done,omitempty"`
// StartTime The time when the operation started.
StartTime *string `json:"start-time,omitempty" yaml:"start-time,omitempty"`
// TotalRecords The total number of records to be processed.
TotalRecords *int `json:"total-records,omitempty" yaml:"total-records,omitempty"`
}
DtoRunningJob RunningJob tracks progress of currently running job.
type DtoS3Storage ¶
type DtoS3Storage struct {
// AccessKeyId Access Key ID for authentication with S3 StaticCredentialsProvider.
// This is sensitive information. Can be a path in secret agent or an actual value.
AccessKeyId *string `json:"access-key-id,omitempty" yaml:"access-key-id,omitempty"`
// Bucket The S3 bucket name.
Bucket string `json:"bucket" yaml:"bucket"`
// MaxAsyncConnections The maximum number of simultaneous requests from S3.
MaxAsyncConnections *int `json:"max-async-connections,omitempty" yaml:"max-async-connections,omitempty"`
// MinPartSize The minimum size in bytes of individual S3 UploadParts.
MinPartSize *int `json:"min-part-size,omitempty" yaml:"min-part-size,omitempty"`
// Path The root path for the backup repository within the bucket.
// If not specified, backups will be saved in the bucket's root.
Path *string `json:"path,omitempty" yaml:"path,omitempty"`
// S3EndpointOverride An alternative endpoint for the S3 SDK to communicate (AWS S3 optional).
S3EndpointOverride *string `json:"s3-endpoint-override,omitempty" yaml:"s3-endpoint-override,omitempty"`
// S3LogLevel The log level of the AWS S3 SDK (AWS S3 optional).
S3LogLevel *DtoS3StorageS3LogLevel `json:"s3-log-level,omitempty" yaml:"s3-log-level,omitempty"`
// S3Profile The S3 profile name (AWS S3 optional).
S3Profile *string `json:"s3-profile,omitempty" yaml:"s3-profile,omitempty"`
// S3Region The S3 region string.
S3Region string `json:"s3-region" yaml:"s3-region"`
// SecretAccessKey Secret Access Key for authentication with S3 StaticCredentialsProvider.
// This is sensitive information. Can be a path in secret agent or an actual value.
SecretAccessKey *string `json:"secret-access-key,omitempty" yaml:"secret-access-key,omitempty"`
// SecretAgent Secret Agent configuration (optional).
// Mutually exclusive with 'secret-agent-name'.
SecretAgent *DtoSecretAgent `json:"secret-agent,omitempty" yaml:"secret-agent,omitempty"`
// SecretAgentName Secret Agent configuration (optional). Link to one of preconfigured agents.
// Mutually exclusive with 'secret-agent'.
SecretAgentName *string `json:"secret-agent-name,omitempty" yaml:"secret-agent-name,omitempty"`
// StorageClass StorageClass defines the storage class for data and metadata objects.
StorageClass *DtoS3StorageClass `json:"storage-class,omitempty" yaml:"storage-class,omitempty"`
}
DtoS3Storage S3Storage represents the configuration for S3 storage.
type DtoS3StorageClass ¶
type DtoS3StorageClass struct {
// Data DataClass specifies the storage class for object data.
Data *DtoS3StorageClassData `json:"data,omitempty" yaml:"data,omitempty"`
// Metadata MetadataClass specifies the storage class for metadata.
Metadata *DtoS3StorageClassMetadata `json:"metadata,omitempty" yaml:"metadata,omitempty"`
}
DtoS3StorageClass S3StorageClass represents the configuration for S3 Storage Class.
type DtoS3StorageClassData ¶
type DtoS3StorageClassData string
DtoS3StorageClassData DataClass specifies the storage class for object data.
const ( DtoS3StorageClassDataDEEPARCHIVE DtoS3StorageClassData = "DEEP_ARCHIVE" DtoS3StorageClassDataEXPRESSONEZONE DtoS3StorageClassData = "EXPRESS_ONEZONE" DtoS3StorageClassDataGLACIER DtoS3StorageClassData = "GLACIER" DtoS3StorageClassDataGLACIERIR DtoS3StorageClassData = "GLACIER_IR" DtoS3StorageClassDataINTELLIGENTTIERING DtoS3StorageClassData = "INTELLIGENT_TIERING" DtoS3StorageClassDataONEZONEIA DtoS3StorageClassData = "ONEZONE_IA" DtoS3StorageClassDataOUTPOSTS DtoS3StorageClassData = "OUTPOSTS" DtoS3StorageClassDataSNOW DtoS3StorageClassData = "SNOW" DtoS3StorageClassDataSTANDARD DtoS3StorageClassData = "STANDARD" DtoS3StorageClassDataSTANDARDIA DtoS3StorageClassData = "STANDARD_IA" )
Defines values for DtoS3StorageClassData.
func (DtoS3StorageClassData) Valid ¶
func (e DtoS3StorageClassData) Valid() bool
Valid indicates whether the value is a known member of the DtoS3StorageClassData enum.
type DtoS3StorageClassMetadata ¶
type DtoS3StorageClassMetadata string
DtoS3StorageClassMetadata MetadataClass specifies the storage class for metadata.
const ( EXPRESSONEZONE DtoS3StorageClassMetadata = "EXPRESS_ONEZONE" INTELLIGENTTIERING DtoS3StorageClassMetadata = "INTELLIGENT_TIERING" ONEZONEIA DtoS3StorageClassMetadata = "ONEZONE_IA" OUTPOSTS DtoS3StorageClassMetadata = "OUTPOSTS" STANDARD DtoS3StorageClassMetadata = "STANDARD" STANDARDIA DtoS3StorageClassMetadata = "STANDARD_IA" )
Defines values for DtoS3StorageClassMetadata.
func (DtoS3StorageClassMetadata) Valid ¶
func (e DtoS3StorageClassMetadata) Valid() bool
Valid indicates whether the value is a known member of the DtoS3StorageClassMetadata enum.
type DtoS3StorageS3LogLevel ¶
type DtoS3StorageS3LogLevel string
DtoS3StorageS3LogLevel The log level of the AWS S3 SDK (AWS S3 optional).
const ( DtoS3StorageS3LogLevelDEBUG DtoS3StorageS3LogLevel = "DEBUG" DtoS3StorageS3LogLevelERROR DtoS3StorageS3LogLevel = "ERROR" DtoS3StorageS3LogLevelFATAL DtoS3StorageS3LogLevel = "FATAL" DtoS3StorageS3LogLevelINFO DtoS3StorageS3LogLevel = "INFO" DtoS3StorageS3LogLevelOFF DtoS3StorageS3LogLevel = "OFF" DtoS3StorageS3LogLevelTRACE DtoS3StorageS3LogLevel = "TRACE" DtoS3StorageS3LogLevelWARN DtoS3StorageS3LogLevel = "WARN" )
Defines values for DtoS3StorageS3LogLevel.
func (DtoS3StorageS3LogLevel) Valid ¶
func (e DtoS3StorageS3LogLevel) Valid() bool
Valid indicates whether the value is a known member of the DtoS3StorageS3LogLevel enum.
type DtoSecretAgent ¶
type DtoSecretAgent struct {
// Address Address of the Secret Agent.
Address string `json:"address" yaml:"address"`
// CaFile Path to a trusted CA certificate file in PEM format.
CaFile *string `json:"ca-file,omitempty" yaml:"ca-file,omitempty"`
// CertFile Path to a client certificate file for mutual TLS authentication.
CertFile *string `json:"cert-file,omitempty" yaml:"cert-file,omitempty"`
// ConnectionType Connection type.
ConnectionType DtoSecretAgentConnectionType `json:"connection-type" yaml:"connection-type"`
// IsBase64 Flag that shows if secret agent responses are encrypted with base64.
IsBase64 *bool `json:"is-base64,omitempty" yaml:"is-base64,omitempty"`
// KeyFile Path to a client private key file for mutual TLS authentication.
KeyFile *string `json:"key-file,omitempty" yaml:"key-file,omitempty"`
// Name TLSName used for server certificate verification (ServerName for SNI).
Name *string `json:"name,omitempty" yaml:"name,omitempty"`
// Port Port the Secret Agent is running on.
Port *int `json:"port,omitempty" yaml:"port,omitempty"`
// Timeout Timeout in milliseconds.
Timeout *int `json:"timeout,omitempty" yaml:"timeout,omitempty"`
}
DtoSecretAgent SecretAgent represents the configuration of an Aerospike Secret Agent.
type DtoSecretAgentConnectionType ¶
type DtoSecretAgentConnectionType string
DtoSecretAgentConnectionType Connection type.
const ( Tcp DtoSecretAgentConnectionType = "tcp" Unix DtoSecretAgentConnectionType = "unix" )
Defines values for DtoSecretAgentConnectionType.
func (DtoSecretAgentConnectionType) Valid ¶
func (e DtoSecretAgentConnectionType) Valid() bool
Valid indicates whether the value is a known member of the DtoSecretAgentConnectionType enum.
type DtoSeedNode ¶
type DtoSeedNode struct {
// HostName The host name of the node.
HostName string `json:"host-name" yaml:"host-name"`
// Port The port of the node.
Port int `json:"port" yaml:"port"`
// TlsName TLS certificate name used for secure connections (if enabled).
TlsName *string `json:"tls-name,omitempty" yaml:"tls-name,omitempty"`
}
DtoSeedNode SeedNode represents details of a node in the Aerospike cluster.
type DtoServiceConfig ¶
type DtoServiceConfig struct {
// Backup Backup contains service-level backup settings.
Backup *DtoBackupCommonConfig `json:"backup,omitempty" yaml:"backup,omitempty"`
// Http HTTPServer is the backup service HTTP server configuration.
Http *DtoHTTPServerConfig `json:"http,omitempty" yaml:"http,omitempty"`
// Logger Logger is the backup service logger configuration.
Logger *DtoLoggerConfig `json:"logger,omitempty" yaml:"logger,omitempty"`
}
DtoServiceConfig ServiceConfig represents the backup service configuration properties.
type DtoStorage ¶
type DtoStorage struct {
// AzureStorage AzureStorage configuration, set if using Azure storage.
AzureStorage *DtoAzureStorage `json:"azure-storage,omitempty" yaml:"azure-storage,omitempty"`
// GcpStorage GcpStorage configuration, set if using GCP storage.
GcpStorage *DtoGcpStorage `json:"gcp-storage,omitempty" yaml:"gcp-storage,omitempty"`
// LocalStorage LocalStorage configuration, set if using local storage.
LocalStorage *DtoLocalStorage `json:"local-storage,omitempty" yaml:"local-storage,omitempty"`
// S3Storage S3Storage configuration, set if using S3 storage.
S3Storage *DtoS3Storage `json:"s3-storage,omitempty" yaml:"s3-storage,omitempty"`
}
DtoStorage Storage represents the configuration for a backup storage details.
type DtoTLS ¶
type DtoTLS struct {
// CaFile Path to a trusted CA certificate file in PEM format.
CaFile *string `json:"ca-file,omitempty" yaml:"ca-file,omitempty"`
// CaPath Path to a directory of trusted CA certificates.
CaPath *string `json:"ca-path,omitempty" yaml:"ca-path,omitempty"`
// CertFile Path to a client certificate file for mutual TLS authentication.
CertFile *string `json:"cert-file,omitempty" yaml:"cert-file,omitempty"`
// CipherSuite TLS cipher selection criteria. The format is the same as OpenSSL's Cipher List Format.
CipherSuite *string `json:"cipher-suite,omitempty" yaml:"cipher-suite,omitempty"`
// KeyFile Path to a client private key file for mutual TLS authentication.
KeyFile *string `json:"key-file,omitempty" yaml:"key-file,omitempty"`
// KeyFilePassword Password to load protected TLS-keyfile (env:VAR, file:PATH, PASSWORD).
KeyFilePassword *string `json:"key-file-password,omitempty" yaml:"key-file-password,omitempty"`
// Name TLSName used for server certificate verification (ServerName for SNI).
Name *string `json:"name,omitempty" yaml:"name,omitempty"`
// Protocols TLS protocol selection criteria. This format is the same as Apache's SSL Protocol.
Protocols *string `json:"protocols,omitempty" yaml:"protocols,omitempty"`
}
DtoTLS TLS represents the Aerospike cluster TLS configuration options.
type DtoTimestampRestorePolicy ¶
type DtoTimestampRestorePolicy struct {
// Bandwidth Throttles read operations from the backup file(s) to not exceed the given I/O bandwidth in MiB/s.
// Default: no limit.
Bandwidth *int `json:"bandwidth,omitempty" yaml:"bandwidth,omitempty"`
// BatchSize The max allowed number of records per an async batch write call.
// Only applicable when using batch writes.
BatchSize *int `json:"batch-size,omitempty" yaml:"batch-size,omitempty"`
// BinList The bins to restore (optional, an empty list implies restoring all bins).
BinList *[]string `json:"bin-list,omitempty" yaml:"bin-list,omitempty"`
// DisableBatchWrites Disables the use of batch writes when restoring records to the Aerospike cluster.
// By default, the cluster is checked for batch write support.
DisableBatchWrites *bool `json:"disable-batch-writes,omitempty" yaml:"disable-batch-writes,omitempty"`
// Encryption Encryption details (algorithm and key). Default is no encryption.
Encryption *DtoEncryptionPolicy `json:"encryption,omitempty" yaml:"encryption,omitempty"`
// ExtraTtl Amount of extra time-to-live to add to records that have expirable void-times.
// Must be set in seconds.
ExtraTtl *int `json:"extra-ttl,omitempty" yaml:"extra-ttl,omitempty"`
// MaxAsyncBatches The max number of outstanding async record batch write calls at a time.
MaxAsyncBatches *int `json:"max-async-batches,omitempty" yaml:"max-async-batches,omitempty"`
// Namespace Namespace optionally specifies an alternative namespace name for the restore operation.
// By default, the data is restored to the namespace from which it was taken.
Namespace *DtoRestoreNamespace `json:"namespace,omitempty" yaml:"namespace,omitempty"`
// NoGeneration Records from backups take precedence. This option disables the generation check.
// With this option, records from the backup always overwrite records that already exist in
// the namespace, regardless of generation numbers.
NoGeneration *bool `json:"no-generation,omitempty" yaml:"no-generation,omitempty"`
// NoIndexes Do not restore any secondary index definitions.
NoIndexes *bool `json:"no-indexes,omitempty" yaml:"no-indexes,omitempty"`
// NoRecords Do not restore any record data (metadata or bin data).
// By default, record data, secondary index definitions, and UDF modules will be restored.
NoRecords *bool `json:"no-records,omitempty" yaml:"no-records,omitempty"`
// NoUdfs Do not restore any UDF modules.
NoUdfs *bool `json:"no-udfs,omitempty" yaml:"no-udfs,omitempty"`
// Parallel The number of concurrent record readers from backup files.
// This value controls the level of parallelism used by the backup service when
// reading backup files.
// The optimal value depends on hardware and network configuration.
Parallel *int `json:"parallel,omitempty" yaml:"parallel,omitempty"`
// Replace Replace records. This controls how records from the backup overwrite existing records in
// the namespace. By default, restoring a record from a backup only replaces the bins
// contained in the backup; all other bins of an existing record remain untouched.
Replace *bool `json:"replace,omitempty" yaml:"replace,omitempty"`
// RetryPolicy Configuration of retries for each restore write operation.
// If nil, the default policy is used (5 retries with a one-minute delay between attempts).
RetryPolicy *DtoRetryPolicy `json:"retry-policy,omitempty" yaml:"retry-policy,omitempty"`
// SetList The sets to restore (optional, an empty list implies restoring all sets).
SetList *[]string `json:"set-list,omitempty" yaml:"set-list,omitempty"`
// SocketTimeout Timeout (ms) for Aerospike commands to write records, create indexes and create UDFs.
// Socket timeout in milliseconds. Default is 10 minutes. If this value is 0, it is set to total-timeout.
// If both are 0, there is no socket idle time limit.
SocketTimeout *int `json:"socket-timeout,omitempty" yaml:"socket-timeout,omitempty"`
// TotalTimeout Total socket timeout in milliseconds. Default is 0, that is, no timeout.
TotalTimeout *int `json:"total-timeout,omitempty" yaml:"total-timeout,omitempty"`
// Tps Throttles read operations from the backup file(s) to not exceed the given number of transactions per second.
// Default: no limit.
Tps *int `json:"tps,omitempty" yaml:"tps,omitempty"`
// Unique Existing records take precedence. With this option, only records that do not exist in
// the namespace are restored, regardless of generation numbers. If a record exists in
// the namespace, the record from the backup is ignored.
Unique *bool `json:"unique,omitempty" yaml:"unique,omitempty"`
}
DtoTimestampRestorePolicy TimestampRestorePolicy represents a policy for the point-in-time restore operation.
type DtoVersionResponse ¶
type DtoVersionResponse struct {
// BuildTime BuildTime of the application in UTC.
BuildTime *string `json:"build-time,omitempty" yaml:"build-time,omitempty"`
// Commit Commit hash of the build.
Commit *string `json:"commit,omitempty" yaml:"commit,omitempty"`
// Version Version of the application.
Version *string `json:"version,omitempty" yaml:"version,omitempty"`
}
DtoVersionResponse VersionResponse represents the ABS version information.
type EnableRoutineResponse ¶
func ParseEnableRoutineResponse ¶
func ParseEnableRoutineResponse(rsp *http.Response) (*EnableRoutineResponse, error)
ParseEnableRoutineResponse parses an HTTP response from a EnableRoutineWithResponse call
func (EnableRoutineResponse) Status ¶
func (r EnableRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (EnableRoutineResponse) StatusCode ¶
func (r EnableRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type GetCurrentBackupResponse ¶
type GetCurrentBackupResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *DtoRoutineState
JSON400 *string
JSON404 *string
}
func ParseGetCurrentBackupResponse ¶
func ParseGetCurrentBackupResponse(rsp *http.Response) (*GetCurrentBackupResponse, error)
ParseGetCurrentBackupResponse parses an HTTP response from a GetCurrentBackupWithResponse call
func (GetCurrentBackupResponse) Status ¶
func (r GetCurrentBackupResponse) Status() string
Status returns HTTPResponse.Status
func (GetCurrentBackupResponse) StatusCode ¶
func (r GetCurrentBackupResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type GetFullBackupsForRoutineParams ¶
type GetFullBackupsForRoutineParams struct {
// From Lower bound timestamp filter
From *int64 `form:"from,omitempty" json:"from,omitempty" yaml:"from,omitempty"`
// To Upper bound timestamp filter
To *int64 `form:"to,omitempty" json:"to,omitempty" yaml:"to,omitempty"`
}
GetFullBackupsForRoutineParams defines parameters for GetFullBackupsForRoutine.
type GetFullBackupsForRoutineResponse ¶
type GetFullBackupsForRoutineResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *[]DtoBackupDetails
JSON400 *string
}
func ParseGetFullBackupsForRoutineResponse ¶
func ParseGetFullBackupsForRoutineResponse(rsp *http.Response) (*GetFullBackupsForRoutineResponse, error)
ParseGetFullBackupsForRoutineResponse parses an HTTP response from a GetFullBackupsForRoutineWithResponse call
func (GetFullBackupsForRoutineResponse) Status ¶
func (r GetFullBackupsForRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (GetFullBackupsForRoutineResponse) StatusCode ¶
func (r GetFullBackupsForRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type GetFullBackupsParams ¶
type GetFullBackupsParams struct {
// From Lower bound timestamp filter
From *int64 `form:"from,omitempty" json:"from,omitempty" yaml:"from,omitempty"`
// To Upper bound timestamp filter
To *int64 `form:"to,omitempty" json:"to,omitempty" yaml:"to,omitempty"`
}
GetFullBackupsParams defines parameters for GetFullBackups.
type GetFullBackupsResponse ¶
type GetFullBackupsResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string][]DtoBackupDetails
JSON400 *string
}
func ParseGetFullBackupsResponse ¶
func ParseGetFullBackupsResponse(rsp *http.Response) (*GetFullBackupsResponse, error)
ParseGetFullBackupsResponse parses an HTTP response from a GetFullBackupsWithResponse call
func (GetFullBackupsResponse) Status ¶
func (r GetFullBackupsResponse) Status() string
Status returns HTTPResponse.Status
func (GetFullBackupsResponse) StatusCode ¶
func (r GetFullBackupsResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type GetIncrementalBackupsForRoutineParams ¶
type GetIncrementalBackupsForRoutineParams struct {
// From Lower bound timestamp filter
From *int64 `form:"from,omitempty" json:"from,omitempty" yaml:"from,omitempty"`
// To Upper bound timestamp filter
To *int64 `form:"to,omitempty" json:"to,omitempty" yaml:"to,omitempty"`
}
GetIncrementalBackupsForRoutineParams defines parameters for GetIncrementalBackupsForRoutine.
type GetIncrementalBackupsForRoutineResponse ¶
type GetIncrementalBackupsForRoutineResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *[]DtoBackupDetails
JSON400 *string
}
func ParseGetIncrementalBackupsForRoutineResponse ¶
func ParseGetIncrementalBackupsForRoutineResponse(rsp *http.Response) (*GetIncrementalBackupsForRoutineResponse, error)
ParseGetIncrementalBackupsForRoutineResponse parses an HTTP response from a GetIncrementalBackupsForRoutineWithResponse call
func (GetIncrementalBackupsForRoutineResponse) Status ¶
func (r GetIncrementalBackupsForRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (GetIncrementalBackupsForRoutineResponse) StatusCode ¶
func (r GetIncrementalBackupsForRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type GetIncrementalBackupsParams ¶
type GetIncrementalBackupsParams struct {
// From Lower bound timestamp filter
From *int64 `form:"from,omitempty" json:"from,omitempty" yaml:"from,omitempty"`
// To Upper bound timestamp filter
To *int64 `form:"to,omitempty" json:"to,omitempty" yaml:"to,omitempty"`
}
GetIncrementalBackupsParams defines parameters for GetIncrementalBackups.
type GetIncrementalBackupsResponse ¶
type GetIncrementalBackupsResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string][]DtoBackupDetails
JSON400 *string
}
func ParseGetIncrementalBackupsResponse ¶
func ParseGetIncrementalBackupsResponse(rsp *http.Response) (*GetIncrementalBackupsResponse, error)
ParseGetIncrementalBackupsResponse parses an HTTP response from a GetIncrementalBackupsWithResponse call
func (GetIncrementalBackupsResponse) Status ¶
func (r GetIncrementalBackupsResponse) Status() string
Status returns HTTPResponse.Status
func (GetIncrementalBackupsResponse) StatusCode ¶
func (r GetIncrementalBackupsResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type HealthResponse ¶
func ParseHealthResponse ¶
func ParseHealthResponse(rsp *http.Response) (*HealthResponse, error)
ParseHealthResponse parses an HTTP response from a HealthWithResponse call
func (HealthResponse) Status ¶
func (r HealthResponse) Status() string
Status returns HTTPResponse.Status
func (HealthResponse) StatusCode ¶
func (r HealthResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type HttpRequestDoer ¶
Doer performs HTTP requests.
The standard http.Client implements this interface.
type MetricsResponse ¶
func ParseMetricsResponse ¶
func ParseMetricsResponse(rsp *http.Response) (*MetricsResponse, error)
ParseMetricsResponse parses an HTTP response from a MetricsWithResponse call
func (MetricsResponse) Status ¶
func (r MetricsResponse) Status() string
Status returns HTTPResponse.Status
func (MetricsResponse) StatusCode ¶
func (r MetricsResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadAllClustersResponse ¶
type ReadAllClustersResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string]DtoAerospikeCluster
}
func ParseReadAllClustersResponse ¶
func ParseReadAllClustersResponse(rsp *http.Response) (*ReadAllClustersResponse, error)
ParseReadAllClustersResponse parses an HTTP response from a ReadAllClustersWithResponse call
func (ReadAllClustersResponse) Status ¶
func (r ReadAllClustersResponse) Status() string
Status returns HTTPResponse.Status
func (ReadAllClustersResponse) StatusCode ¶
func (r ReadAllClustersResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadAllStorageResponse ¶
type ReadAllStorageResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string]DtoStorage
}
func ParseReadAllStorageResponse ¶
func ParseReadAllStorageResponse(rsp *http.Response) (*ReadAllStorageResponse, error)
ParseReadAllStorageResponse parses an HTTP response from a ReadAllStorageWithResponse call
func (ReadAllStorageResponse) Status ¶
func (r ReadAllStorageResponse) Status() string
Status returns HTTPResponse.Status
func (ReadAllStorageResponse) StatusCode ¶
func (r ReadAllStorageResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadClusterResponse ¶
type ReadClusterResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *DtoAerospikeCluster
JSON400 *string
JSON404 *string
}
func ParseReadClusterResponse ¶
func ParseReadClusterResponse(rsp *http.Response) (*ReadClusterResponse, error)
ParseReadClusterResponse parses an HTTP response from a ReadClusterWithResponse call
func (ReadClusterResponse) Status ¶
func (r ReadClusterResponse) Status() string
Status returns HTTPResponse.Status
func (ReadClusterResponse) StatusCode ¶
func (r ReadClusterResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadConfigResponse ¶
func ParseReadConfigResponse ¶
func ParseReadConfigResponse(rsp *http.Response) (*ReadConfigResponse, error)
ParseReadConfigResponse parses an HTTP response from a ReadConfigWithResponse call
func (ReadConfigResponse) Status ¶
func (r ReadConfigResponse) Status() string
Status returns HTTPResponse.Status
func (ReadConfigResponse) StatusCode ¶
func (r ReadConfigResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadPoliciesResponse ¶
type ReadPoliciesResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string]DtoBackupPolicy
}
func ParseReadPoliciesResponse ¶
func ParseReadPoliciesResponse(rsp *http.Response) (*ReadPoliciesResponse, error)
ParseReadPoliciesResponse parses an HTTP response from a ReadPoliciesWithResponse call
func (ReadPoliciesResponse) Status ¶
func (r ReadPoliciesResponse) Status() string
Status returns HTTPResponse.Status
func (ReadPoliciesResponse) StatusCode ¶
func (r ReadPoliciesResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadPolicyResponse ¶
type ReadPolicyResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *DtoBackupPolicy
JSON400 *string
JSON404 *string
}
func ParseReadPolicyResponse ¶
func ParseReadPolicyResponse(rsp *http.Response) (*ReadPolicyResponse, error)
ParseReadPolicyResponse parses an HTTP response from a ReadPolicyWithResponse call
func (ReadPolicyResponse) Status ¶
func (r ReadPolicyResponse) Status() string
Status returns HTTPResponse.Status
func (ReadPolicyResponse) StatusCode ¶
func (r ReadPolicyResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadRoutineResponse ¶
type ReadRoutineResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *DtoBackupRoutine
JSON400 *string
JSON404 *string
}
func ParseReadRoutineResponse ¶
func ParseReadRoutineResponse(rsp *http.Response) (*ReadRoutineResponse, error)
ParseReadRoutineResponse parses an HTTP response from a ReadRoutineWithResponse call
func (ReadRoutineResponse) Status ¶
func (r ReadRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (ReadRoutineResponse) StatusCode ¶
func (r ReadRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadRoutinesResponse ¶
type ReadRoutinesResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string]DtoBackupRoutine
JSON400 *string
}
func ParseReadRoutinesResponse ¶
func ParseReadRoutinesResponse(rsp *http.Response) (*ReadRoutinesResponse, error)
ParseReadRoutinesResponse parses an HTTP response from a ReadRoutinesWithResponse call
func (ReadRoutinesResponse) Status ¶
func (r ReadRoutinesResponse) Status() string
Status returns HTTPResponse.Status
func (ReadRoutinesResponse) StatusCode ¶
func (r ReadRoutinesResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadStorageResponse ¶
type ReadStorageResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *DtoStorage
JSON400 *string
JSON404 *string
}
func ParseReadStorageResponse ¶
func ParseReadStorageResponse(rsp *http.Response) (*ReadStorageResponse, error)
ParseReadStorageResponse parses an HTTP response from a ReadStorageWithResponse call
func (ReadStorageResponse) Status ¶
func (r ReadStorageResponse) Status() string
Status returns HTTPResponse.Status
func (ReadStorageResponse) StatusCode ¶
func (r ReadStorageResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ReadyResponse ¶
func ParseReadyResponse ¶
func ParseReadyResponse(rsp *http.Response) (*ReadyResponse, error)
ParseReadyResponse parses an HTTP response from a ReadyWithResponse call
func (ReadyResponse) Status ¶
func (r ReadyResponse) Status() string
Status returns HTTPResponse.Status
func (ReadyResponse) StatusCode ¶
func (r ReadyResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RequestEditorFn ¶
RequestEditorFn is the function signature for the RequestEditor callback function
type RestoreFullJSONRequestBody ¶
type RestoreFullJSONRequestBody = DtoRestoreRequest
RestoreFullJSONRequestBody defines body for RestoreFull for application/json ContentType.
type RestoreFullResponse ¶
func ParseRestoreFullResponse ¶
func ParseRestoreFullResponse(rsp *http.Response) (*RestoreFullResponse, error)
ParseRestoreFullResponse parses an HTTP response from a RestoreFullWithResponse call
func (RestoreFullResponse) Status ¶
func (r RestoreFullResponse) Status() string
Status returns HTTPResponse.Status
func (RestoreFullResponse) StatusCode ¶
func (r RestoreFullResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RestoreIncrementalJSONRequestBody ¶
type RestoreIncrementalJSONRequestBody = DtoRestoreRequest
RestoreIncrementalJSONRequestBody defines body for RestoreIncremental for application/json ContentType.
type RestoreIncrementalResponse ¶
func ParseRestoreIncrementalResponse ¶
func ParseRestoreIncrementalResponse(rsp *http.Response) (*RestoreIncrementalResponse, error)
ParseRestoreIncrementalResponse parses an HTTP response from a RestoreIncrementalWithResponse call
func (RestoreIncrementalResponse) Status ¶
func (r RestoreIncrementalResponse) Status() string
Status returns HTTPResponse.Status
func (RestoreIncrementalResponse) StatusCode ¶
func (r RestoreIncrementalResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RestoreStatusResponse ¶
type RestoreStatusResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *DtoRestoreJobStatus
JSON400 *string
JSON404 *string
}
func ParseRestoreStatusResponse ¶
func ParseRestoreStatusResponse(rsp *http.Response) (*RestoreStatusResponse, error)
ParseRestoreStatusResponse parses an HTTP response from a RestoreStatusWithResponse call
func (RestoreStatusResponse) Status ¶
func (r RestoreStatusResponse) Status() string
Status returns HTTPResponse.Status
func (RestoreStatusResponse) StatusCode ¶
func (r RestoreStatusResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RestoreTimestampJSONRequestBody ¶
type RestoreTimestampJSONRequestBody = DtoRestoreTimestampRequest
RestoreTimestampJSONRequestBody defines body for RestoreTimestamp for application/json ContentType.
type RestoreTimestampResponse ¶
func ParseRestoreTimestampResponse ¶
func ParseRestoreTimestampResponse(rsp *http.Response) (*RestoreTimestampResponse, error)
ParseRestoreTimestampResponse parses an HTTP response from a RestoreTimestampWithResponse call
func (RestoreTimestampResponse) Status ¶
func (r RestoreTimestampResponse) Status() string
Status returns HTTPResponse.Status
func (RestoreTimestampResponse) StatusCode ¶
func (r RestoreTimestampResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RetrieveConfigurationResponse ¶
func ParseRetrieveConfigurationResponse ¶
func ParseRetrieveConfigurationResponse(rsp *http.Response) (*RetrieveConfigurationResponse, error)
ParseRetrieveConfigurationResponse parses an HTTP response from a RetrieveConfigurationWithResponse call
func (RetrieveConfigurationResponse) Status ¶
func (r RetrieveConfigurationResponse) Status() string
Status returns HTTPResponse.Status
func (RetrieveConfigurationResponse) StatusCode ¶
func (r RetrieveConfigurationResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RetrieveRestoreJobsParams ¶
type RetrieveRestoreJobsParams struct {
// From Lower bound timestamp filter
From *int64 `form:"from,omitempty" json:"from,omitempty" yaml:"from,omitempty"`
// To Upper bound timestamp filter
To *int64 `form:"to,omitempty" json:"to,omitempty" yaml:"to,omitempty"`
// Status Comma-separated status filter (Running,Done,Failed,Canceled). Use ! prefix for exclude filter (e.g., !Failed,Canceled)
Status *string `form:"status,omitempty" json:"status,omitempty" yaml:"status,omitempty"`
}
RetrieveRestoreJobsParams defines parameters for RetrieveRestoreJobs.
type RetrieveRestoreJobsResponse ¶
type RetrieveRestoreJobsResponse struct {
Body []byte
HTTPResponse *http.Response
JSON200 *map[string]DtoRestoreJobStatus
JSON400 *string
}
func ParseRetrieveRestoreJobsResponse ¶
func ParseRetrieveRestoreJobsResponse(rsp *http.Response) (*RetrieveRestoreJobsResponse, error)
ParseRetrieveRestoreJobsResponse parses an HTTP response from a RetrieveRestoreJobsWithResponse call
func (RetrieveRestoreJobsResponse) Status ¶
func (r RetrieveRestoreJobsResponse) Status() string
Status returns HTTPResponse.Status
func (RetrieveRestoreJobsResponse) StatusCode ¶
func (r RetrieveRestoreJobsResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type RootResponse ¶
func ParseRootResponse ¶
func ParseRootResponse(rsp *http.Response) (*RootResponse, error)
ParseRootResponse parses an HTTP response from a RootWithResponse call
func (RootResponse) Status ¶
func (r RootResponse) Status() string
Status returns HTTPResponse.Status
func (RootResponse) StatusCode ¶
func (r RootResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type ScheduleFullBackupParams ¶
type ScheduleFullBackupParams struct {
// Delay Delay interval in milliseconds
Delay *int `form:"delay,omitempty" json:"delay,omitempty" yaml:"delay,omitempty"`
}
ScheduleFullBackupParams defines parameters for ScheduleFullBackup.
type ScheduleFullBackupResponse ¶
func ParseScheduleFullBackupResponse ¶
func ParseScheduleFullBackupResponse(rsp *http.Response) (*ScheduleFullBackupResponse, error)
ParseScheduleFullBackupResponse parses an HTTP response from a ScheduleFullBackupWithResponse call
func (ScheduleFullBackupResponse) Status ¶
func (r ScheduleFullBackupResponse) Status() string
Status returns HTTPResponse.Status
func (ScheduleFullBackupResponse) StatusCode ¶
func (r ScheduleFullBackupResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type TriggerFullBackupParams ¶
type TriggerFullBackupParams struct {
// Delay Delay interval in milliseconds
Delay *int `form:"delay,omitempty" json:"delay,omitempty" yaml:"delay,omitempty"`
}
TriggerFullBackupParams defines parameters for TriggerFullBackup.
type TriggerFullBackupResponse ¶
func ParseTriggerFullBackupResponse ¶
func ParseTriggerFullBackupResponse(rsp *http.Response) (*TriggerFullBackupResponse, error)
ParseTriggerFullBackupResponse parses an HTTP response from a TriggerFullBackupWithResponse call
func (TriggerFullBackupResponse) Status ¶
func (r TriggerFullBackupResponse) Status() string
Status returns HTTPResponse.Status
func (TriggerFullBackupResponse) StatusCode ¶
func (r TriggerFullBackupResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type TriggerIncrementalBackupParams ¶
type TriggerIncrementalBackupParams struct {
// Delay Delay interval in milliseconds
Delay *int `form:"delay,omitempty" json:"delay,omitempty" yaml:"delay,omitempty"`
}
TriggerIncrementalBackupParams defines parameters for TriggerIncrementalBackup.
type TriggerIncrementalBackupResponse ¶
func ParseTriggerIncrementalBackupResponse ¶
func ParseTriggerIncrementalBackupResponse(rsp *http.Response) (*TriggerIncrementalBackupResponse, error)
ParseTriggerIncrementalBackupResponse parses an HTTP response from a TriggerIncrementalBackupWithResponse call
func (TriggerIncrementalBackupResponse) Status ¶
func (r TriggerIncrementalBackupResponse) Status() string
Status returns HTTPResponse.Status
func (TriggerIncrementalBackupResponse) StatusCode ¶
func (r TriggerIncrementalBackupResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type UpdateClusterJSONRequestBody ¶
type UpdateClusterJSONRequestBody = DtoAerospikeCluster
UpdateClusterJSONRequestBody defines body for UpdateCluster for application/json ContentType.
type UpdateClusterResponse ¶
func ParseUpdateClusterResponse ¶
func ParseUpdateClusterResponse(rsp *http.Response) (*UpdateClusterResponse, error)
ParseUpdateClusterResponse parses an HTTP response from a UpdateClusterWithResponse call
func (UpdateClusterResponse) Status ¶
func (r UpdateClusterResponse) Status() string
Status returns HTTPResponse.Status
func (UpdateClusterResponse) StatusCode ¶
func (r UpdateClusterResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type UpdateConfigJSONRequestBody ¶
type UpdateConfigJSONRequestBody = DtoConfig
UpdateConfigJSONRequestBody defines body for UpdateConfig for application/json ContentType.
type UpdateConfigResponse ¶
func ParseUpdateConfigResponse ¶
func ParseUpdateConfigResponse(rsp *http.Response) (*UpdateConfigResponse, error)
ParseUpdateConfigResponse parses an HTTP response from a UpdateConfigWithResponse call
func (UpdateConfigResponse) Status ¶
func (r UpdateConfigResponse) Status() string
Status returns HTTPResponse.Status
func (UpdateConfigResponse) StatusCode ¶
func (r UpdateConfigResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type UpdatePolicyJSONRequestBody ¶
type UpdatePolicyJSONRequestBody = DtoBackupPolicy
UpdatePolicyJSONRequestBody defines body for UpdatePolicy for application/json ContentType.
type UpdatePolicyResponse ¶
func ParseUpdatePolicyResponse ¶
func ParseUpdatePolicyResponse(rsp *http.Response) (*UpdatePolicyResponse, error)
ParseUpdatePolicyResponse parses an HTTP response from a UpdatePolicyWithResponse call
func (UpdatePolicyResponse) Status ¶
func (r UpdatePolicyResponse) Status() string
Status returns HTTPResponse.Status
func (UpdatePolicyResponse) StatusCode ¶
func (r UpdatePolicyResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type UpdateRoutineJSONRequestBody ¶
type UpdateRoutineJSONRequestBody = DtoBackupRoutine
UpdateRoutineJSONRequestBody defines body for UpdateRoutine for application/json ContentType.
type UpdateRoutineResponse ¶
func ParseUpdateRoutineResponse ¶
func ParseUpdateRoutineResponse(rsp *http.Response) (*UpdateRoutineResponse, error)
ParseUpdateRoutineResponse parses an HTTP response from a UpdateRoutineWithResponse call
func (UpdateRoutineResponse) Status ¶
func (r UpdateRoutineResponse) Status() string
Status returns HTTPResponse.Status
func (UpdateRoutineResponse) StatusCode ¶
func (r UpdateRoutineResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type UpdateStorageJSONRequestBody ¶
type UpdateStorageJSONRequestBody = DtoStorage
UpdateStorageJSONRequestBody defines body for UpdateStorage for application/json ContentType.
type UpdateStorageResponse ¶
func ParseUpdateStorageResponse ¶
func ParseUpdateStorageResponse(rsp *http.Response) (*UpdateStorageResponse, error)
ParseUpdateStorageResponse parses an HTTP response from a UpdateStorageWithResponse call
func (UpdateStorageResponse) Status ¶
func (r UpdateStorageResponse) Status() string
Status returns HTTPResponse.Status
func (UpdateStorageResponse) StatusCode ¶
func (r UpdateStorageResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode
type VersionResponse ¶
func ParseVersionResponse ¶
func ParseVersionResponse(rsp *http.Response) (*VersionResponse, error)
ParseVersionResponse parses an HTTP response from a VersionWithResponse call
func (VersionResponse) Status ¶
func (r VersionResponse) Status() string
Status returns HTTPResponse.Status
func (VersionResponse) StatusCode ¶
func (r VersionResponse) StatusCode() int
StatusCode returns HTTPResponse.StatusCode