cloudflow

package
v0.9.266 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SERVICE_NAME           = "cloudflow"
	DEFAULT_SERVICE_DOMAIN = SERVICE_NAME + "." + bce.DEFAULT_REGION + ".bcebos.com"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	*bce.BceClient
}

Client of CloudFlow service is a kind of BceClient, so derived from BceClient

func NewClient 

func NewClient(ak, sk, endpoint string) (*Client, error)

NewClient make the CloudFlow service client with default configuration. Use `cli.Config.xxx` to access the config or change it to non-default value.

func NewClientWithConfig 

func NewClientWithConfig(config *ClientConfiguration) (*Client, error)

func (*Client) DeleteMigration 

func (c *Client) DeleteMigration(taskId string) (*api.MigrationResultCommon, error)

func (*Client) GetMigration 

func (c *Client) GetMigration(taskId string) (*api.GetMigrationInfo, error)

func (*Client) GetMigrationResult 

func (c *Client) GetMigrationResult(taskId string) (*api.MigrationResult, error)

func (*Client) ListMigration 

func (c *Client) ListMigration() (*api.ListMigrationInfo, error)

func (*Client) PauseMigration 

func (c *Client) PauseMigration(taskId string) (*api.MigrationResultCommon, error)

func (*Client) PostMigration 

func (c *Client) PostMigration(args *api.PostMigrationArgs) (*api.PostMigrationResult, error)

func (*Client) PostMigrationFromList 

func (c *Client) PostMigrationFromList(args *api.PostMigrationFromListArgs) (*api.PostMigrationResult, error)

func (*Client) ResumeMigration 

func (c *Client) ResumeMigration(taskId string) (*api.MigrationResultCommon, error)

func (*Client) RetryMigration 

func (c *Client) RetryMigration(taskId string) (*api.MigrationResultCommon, error)

type ClientConfiguration 

type ClientConfiguration struct {
	Ak                    string
	Sk                    string
	Endpoint              string
	RedirectDisabled      bool
	DisableKeepAlives     bool
	NoVerifySSL           bool
	RetryPolicy           bce.RetryPolicy
	DialTimeout           *time.Duration // timeout of building a connection
	KeepAlive             *time.Duration // interval between keep-alive probes for an active connection
	ReadTimeout           *time.Duration // read timeout of net.Conn
	WriteTimeOut          *time.Duration // write timeout of net.Conn
	TLSHandshakeTimeout   *time.Duration // http.Transport.TLSHandshakeTimeout
	IdleConnectionTimeout *time.Duration // http.Transport.IdleConnTimeout
	ResponseHeaderTimeout *time.Duration // http.Transport.ResponseHeaderTimeout
	HTTPClientTimeout     *time.Duration // http.Client.Timeout
	HTTPClient            *http.Client   // customized http client to send request
}

ClientConfiguration defines the config components structure by user.

func NewClientConfig 

func NewClientConfig(ak, sk, endpoint string) *ClientConfiguration

func (*ClientConfiguration) WithAk 

func (cfg *ClientConfiguration) WithAk(val string) *ClientConfiguration

func (*ClientConfiguration) WithDialTimeout 

func (cfg *ClientConfiguration) WithDialTimeout(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithDisableKeepAlives 

func (cfg *ClientConfiguration) WithDisableKeepAlives(val bool) *ClientConfiguration

func (*ClientConfiguration) WithEndpoint 

func (cfg *ClientConfiguration) WithEndpoint(val string) *ClientConfiguration

func (*ClientConfiguration) WithHttpClient 

func (cfg *ClientConfiguration) WithHttpClient(val http.Client) *ClientConfiguration

func (*ClientConfiguration) WithHttpClientTimeout 

func (cfg *ClientConfiguration) WithHttpClientTimeout(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithIdleConnectionTimeout 

func (cfg *ClientConfiguration) WithIdleConnectionTimeout(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithKeepAlive 

func (cfg *ClientConfiguration) WithKeepAlive(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithNoVerifySSL 

func (cfg *ClientConfiguration) WithNoVerifySSL(val bool) *ClientConfiguration

func (*ClientConfiguration) WithReadTimeout 

func (cfg *ClientConfiguration) WithReadTimeout(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithRedirectDisabled 

func (cfg *ClientConfiguration) WithRedirectDisabled(val bool) *ClientConfiguration

func (*ClientConfiguration) WithResponseHeaderTimeout 

func (cfg *ClientConfiguration) WithResponseHeaderTimeout(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithRetryPolicy 

func (cfg *ClientConfiguration) WithRetryPolicy(val bce.RetryPolicy) *ClientConfiguration

func (*ClientConfiguration) WithSk 

func (cfg *ClientConfiguration) WithSk(val string) *ClientConfiguration

func (*ClientConfiguration) WithTLSHandshakeTimeout 

func (cfg *ClientConfiguration) WithTLSHandshakeTimeout(val time.Duration) *ClientConfiguration

func (*ClientConfiguration) WithWriteTimeout 

func (cfg *ClientConfiguration) WithWriteTimeout(val time.Duration) *ClientConfiguration

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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