fnf

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EndpointMap map[string]string

EndpointMap Endpoint Data

View Source 
var EndpointType = "regional"

EndpointType regional or central

Functions

func GetEndpointMap 

func GetEndpointMap() map[string]string

GetEndpointMap Get Endpoint Data Map

func GetEndpointType 

func GetEndpointType() string

GetEndpointType Get Endpoint Type Value

func SetClientProperty 

func SetClientProperty(client *Client, propertyName string, propertyValue interface{})

SetClientProperty Set Property by Reflect

func SetEndpointDataToClient 

func SetEndpointDataToClient(client *Client)

SetEndpointDataToClient Set EndpointMap and ENdpointType

Types

type Client 

type Client struct {
	sdk.Client
}

Client is the sdk client struct, each func corresponds to an OpenAPI

func NewClient 

func NewClient() (client *Client, err error)

NewClient creates a sdk client with environment variables

func NewClientWithAccessKey 

func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)

NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithEcsRamRole 

func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)

NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithOptions 

func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)

NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client

func NewClientWithProvider 

func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)

NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRamRoleArn 

func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)

NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRamRoleArnAndPolicy 

func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)

NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRsaKeyPair 

func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)

NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithStsToken 

func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)

NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func (*Client) CreateFlow 

func (client *Client) CreateFlow(request *CreateFlowRequest) (response *CreateFlowResponse, err error)

CreateFlow invokes the fnf.CreateFlow API synchronously

func (*Client) CreateFlowWithCallback 

func (client *Client) CreateFlowWithCallback(request *CreateFlowRequest, callback func(response *CreateFlowResponse, err error)) <-chan int

CreateFlowWithCallback invokes the fnf.CreateFlow API asynchronously

func (*Client) CreateFlowWithChan 

func (client *Client) CreateFlowWithChan(request *CreateFlowRequest) (<-chan *CreateFlowResponse, <-chan error)

CreateFlowWithChan invokes the fnf.CreateFlow API asynchronously

func (*Client) CreateSchedule 

func (client *Client) CreateSchedule(request *CreateScheduleRequest) (response *CreateScheduleResponse, err error)

CreateSchedule invokes the fnf.CreateSchedule API synchronously

func (*Client) CreateScheduleWithCallback 

func (client *Client) CreateScheduleWithCallback(request *CreateScheduleRequest, callback func(response *CreateScheduleResponse, err error)) <-chan int

CreateScheduleWithCallback invokes the fnf.CreateSchedule API asynchronously

func (*Client) CreateScheduleWithChan 

func (client *Client) CreateScheduleWithChan(request *CreateScheduleRequest) (<-chan *CreateScheduleResponse, <-chan error)

CreateScheduleWithChan invokes the fnf.CreateSchedule API asynchronously

func (*Client) DeleteFlow 

func (client *Client) DeleteFlow(request *DeleteFlowRequest) (response *DeleteFlowResponse, err error)

DeleteFlow invokes the fnf.DeleteFlow API synchronously

func (*Client) DeleteFlowWithCallback 

func (client *Client) DeleteFlowWithCallback(request *DeleteFlowRequest, callback func(response *DeleteFlowResponse, err error)) <-chan int

DeleteFlowWithCallback invokes the fnf.DeleteFlow API asynchronously

func (*Client) DeleteFlowWithChan 

func (client *Client) DeleteFlowWithChan(request *DeleteFlowRequest) (<-chan *DeleteFlowResponse, <-chan error)

DeleteFlowWithChan invokes the fnf.DeleteFlow API asynchronously

func (*Client) DeleteSchedule 

func (client *Client) DeleteSchedule(request *DeleteScheduleRequest) (response *DeleteScheduleResponse, err error)

DeleteSchedule invokes the fnf.DeleteSchedule API synchronously

func (*Client) DeleteScheduleWithCallback 

func (client *Client) DeleteScheduleWithCallback(request *DeleteScheduleRequest, callback func(response *DeleteScheduleResponse, err error)) <-chan int

DeleteScheduleWithCallback invokes the fnf.DeleteSchedule API asynchronously

func (*Client) DeleteScheduleWithChan 

func (client *Client) DeleteScheduleWithChan(request *DeleteScheduleRequest) (<-chan *DeleteScheduleResponse, <-chan error)

DeleteScheduleWithChan invokes the fnf.DeleteSchedule API asynchronously

func (*Client) DescribeExecution 

func (client *Client) DescribeExecution(request *DescribeExecutionRequest) (response *DescribeExecutionResponse, err error)

DescribeExecution invokes the fnf.DescribeExecution API synchronously

func (*Client) DescribeExecutionWithCallback 

func (client *Client) DescribeExecutionWithCallback(request *DescribeExecutionRequest, callback func(response *DescribeExecutionResponse, err error)) <-chan int

DescribeExecutionWithCallback invokes the fnf.DescribeExecution API asynchronously

func (*Client) DescribeExecutionWithChan 

func (client *Client) DescribeExecutionWithChan(request *DescribeExecutionRequest) (<-chan *DescribeExecutionResponse, <-chan error)

DescribeExecutionWithChan invokes the fnf.DescribeExecution API asynchronously

func (*Client) DescribeFlow 

func (client *Client) DescribeFlow(request *DescribeFlowRequest) (response *DescribeFlowResponse, err error)

DescribeFlow invokes the fnf.DescribeFlow API synchronously

func (*Client) DescribeFlowWithCallback 

func (client *Client) DescribeFlowWithCallback(request *DescribeFlowRequest, callback func(response *DescribeFlowResponse, err error)) <-chan int

DescribeFlowWithCallback invokes the fnf.DescribeFlow API asynchronously

func (*Client) DescribeFlowWithChan 

func (client *Client) DescribeFlowWithChan(request *DescribeFlowRequest) (<-chan *DescribeFlowResponse, <-chan error)

DescribeFlowWithChan invokes the fnf.DescribeFlow API asynchronously

func (*Client) DescribeSchedule 

func (client *Client) DescribeSchedule(request *DescribeScheduleRequest) (response *DescribeScheduleResponse, err error)

DescribeSchedule invokes the fnf.DescribeSchedule API synchronously

func (*Client) DescribeScheduleWithCallback 

func (client *Client) DescribeScheduleWithCallback(request *DescribeScheduleRequest, callback func(response *DescribeScheduleResponse, err error)) <-chan int

DescribeScheduleWithCallback invokes the fnf.DescribeSchedule API asynchronously

func (*Client) DescribeScheduleWithChan 

func (client *Client) DescribeScheduleWithChan(request *DescribeScheduleRequest) (<-chan *DescribeScheduleResponse, <-chan error)

DescribeScheduleWithChan invokes the fnf.DescribeSchedule API asynchronously

func (*Client) GetExecutionHistory 

func (client *Client) GetExecutionHistory(request *GetExecutionHistoryRequest) (response *GetExecutionHistoryResponse, err error)

GetExecutionHistory invokes the fnf.GetExecutionHistory API synchronously

func (*Client) GetExecutionHistoryWithCallback 

func (client *Client) GetExecutionHistoryWithCallback(request *GetExecutionHistoryRequest, callback func(response *GetExecutionHistoryResponse, err error)) <-chan int

GetExecutionHistoryWithCallback invokes the fnf.GetExecutionHistory API asynchronously

func (*Client) GetExecutionHistoryWithChan 

func (client *Client) GetExecutionHistoryWithChan(request *GetExecutionHistoryRequest) (<-chan *GetExecutionHistoryResponse, <-chan error)

GetExecutionHistoryWithChan invokes the fnf.GetExecutionHistory API asynchronously

func (*Client) ListExecutions 

func (client *Client) ListExecutions(request *ListExecutionsRequest) (response *ListExecutionsResponse, err error)

ListExecutions invokes the fnf.ListExecutions API synchronously

func (*Client) ListExecutionsWithCallback 

func (client *Client) ListExecutionsWithCallback(request *ListExecutionsRequest, callback func(response *ListExecutionsResponse, err error)) <-chan int

ListExecutionsWithCallback invokes the fnf.ListExecutions API asynchronously

func (*Client) ListExecutionsWithChan 

func (client *Client) ListExecutionsWithChan(request *ListExecutionsRequest) (<-chan *ListExecutionsResponse, <-chan error)

ListExecutionsWithChan invokes the fnf.ListExecutions API asynchronously

func (*Client) ListFlows 

func (client *Client) ListFlows(request *ListFlowsRequest) (response *ListFlowsResponse, err error)

ListFlows invokes the fnf.ListFlows API synchronously

func (*Client) ListFlowsWithCallback 

func (client *Client) ListFlowsWithCallback(request *ListFlowsRequest, callback func(response *ListFlowsResponse, err error)) <-chan int

ListFlowsWithCallback invokes the fnf.ListFlows API asynchronously

func (*Client) ListFlowsWithChan 

func (client *Client) ListFlowsWithChan(request *ListFlowsRequest) (<-chan *ListFlowsResponse, <-chan error)

ListFlowsWithChan invokes the fnf.ListFlows API asynchronously

func (*Client) ListSchedules 

func (client *Client) ListSchedules(request *ListSchedulesRequest) (response *ListSchedulesResponse, err error)

ListSchedules invokes the fnf.ListSchedules API synchronously

func (*Client) ListSchedulesWithCallback 

func (client *Client) ListSchedulesWithCallback(request *ListSchedulesRequest, callback func(response *ListSchedulesResponse, err error)) <-chan int

ListSchedulesWithCallback invokes the fnf.ListSchedules API asynchronously

func (*Client) ListSchedulesWithChan 

func (client *Client) ListSchedulesWithChan(request *ListSchedulesRequest) (<-chan *ListSchedulesResponse, <-chan error)

ListSchedulesWithChan invokes the fnf.ListSchedules API asynchronously

func (*Client) ReportTaskFailed 

func (client *Client) ReportTaskFailed(request *ReportTaskFailedRequest) (response *ReportTaskFailedResponse, err error)

ReportTaskFailed invokes the fnf.ReportTaskFailed API synchronously

func (*Client) ReportTaskFailedWithCallback 

func (client *Client) ReportTaskFailedWithCallback(request *ReportTaskFailedRequest, callback func(response *ReportTaskFailedResponse, err error)) <-chan int

ReportTaskFailedWithCallback invokes the fnf.ReportTaskFailed API asynchronously

func (*Client) ReportTaskFailedWithChan 

func (client *Client) ReportTaskFailedWithChan(request *ReportTaskFailedRequest) (<-chan *ReportTaskFailedResponse, <-chan error)

ReportTaskFailedWithChan invokes the fnf.ReportTaskFailed API asynchronously

func (*Client) ReportTaskSucceeded 

func (client *Client) ReportTaskSucceeded(request *ReportTaskSucceededRequest) (response *ReportTaskSucceededResponse, err error)

ReportTaskSucceeded invokes the fnf.ReportTaskSucceeded API synchronously

func (*Client) ReportTaskSucceededWithCallback 

func (client *Client) ReportTaskSucceededWithCallback(request *ReportTaskSucceededRequest, callback func(response *ReportTaskSucceededResponse, err error)) <-chan int

ReportTaskSucceededWithCallback invokes the fnf.ReportTaskSucceeded API asynchronously

func (*Client) ReportTaskSucceededWithChan 

func (client *Client) ReportTaskSucceededWithChan(request *ReportTaskSucceededRequest) (<-chan *ReportTaskSucceededResponse, <-chan error)

ReportTaskSucceededWithChan invokes the fnf.ReportTaskSucceeded API asynchronously

func (*Client) StartExecution 

func (client *Client) StartExecution(request *StartExecutionRequest) (response *StartExecutionResponse, err error)

StartExecution invokes the fnf.StartExecution API synchronously

func (*Client) StartExecutionWithCallback 

func (client *Client) StartExecutionWithCallback(request *StartExecutionRequest, callback func(response *StartExecutionResponse, err error)) <-chan int

StartExecutionWithCallback invokes the fnf.StartExecution API asynchronously

func (*Client) StartExecutionWithChan 

func (client *Client) StartExecutionWithChan(request *StartExecutionRequest) (<-chan *StartExecutionResponse, <-chan error)

StartExecutionWithChan invokes the fnf.StartExecution API asynchronously

func (*Client) StopExecution 

func (client *Client) StopExecution(request *StopExecutionRequest) (response *StopExecutionResponse, err error)

StopExecution invokes the fnf.StopExecution API synchronously

func (*Client) StopExecutionWithCallback 

func (client *Client) StopExecutionWithCallback(request *StopExecutionRequest, callback func(response *StopExecutionResponse, err error)) <-chan int

StopExecutionWithCallback invokes the fnf.StopExecution API asynchronously

func (*Client) StopExecutionWithChan 

func (client *Client) StopExecutionWithChan(request *StopExecutionRequest) (<-chan *StopExecutionResponse, <-chan error)

StopExecutionWithChan invokes the fnf.StopExecution API asynchronously

func (*Client) UpdateFlow 

func (client *Client) UpdateFlow(request *UpdateFlowRequest) (response *UpdateFlowResponse, err error)

UpdateFlow invokes the fnf.UpdateFlow API synchronously

func (*Client) UpdateFlowWithCallback 

func (client *Client) UpdateFlowWithCallback(request *UpdateFlowRequest, callback func(response *UpdateFlowResponse, err error)) <-chan int

UpdateFlowWithCallback invokes the fnf.UpdateFlow API asynchronously

func (*Client) UpdateFlowWithChan 

func (client *Client) UpdateFlowWithChan(request *UpdateFlowRequest) (<-chan *UpdateFlowResponse, <-chan error)

UpdateFlowWithChan invokes the fnf.UpdateFlow API asynchronously

func (*Client) UpdateSchedule 

func (client *Client) UpdateSchedule(request *UpdateScheduleRequest) (response *UpdateScheduleResponse, err error)

UpdateSchedule invokes the fnf.UpdateSchedule API synchronously

func (*Client) UpdateScheduleWithCallback 

func (client *Client) UpdateScheduleWithCallback(request *UpdateScheduleRequest, callback func(response *UpdateScheduleResponse, err error)) <-chan int

UpdateScheduleWithCallback invokes the fnf.UpdateSchedule API asynchronously

func (*Client) UpdateScheduleWithChan 

func (client *Client) UpdateScheduleWithChan(request *UpdateScheduleRequest) (<-chan *UpdateScheduleResponse, <-chan error)

UpdateScheduleWithChan invokes the fnf.UpdateSchedule API asynchronously

type CreateFlowRequest 

type CreateFlowRequest struct {
	*requests.RpcRequest
	Description             string `position:"Body" name:"Description"`
	Type                    string `position:"Body" name:"Type"`
	RequestId               string `position:"Query" name:"RequestId"`
	RoleArn                 string `position:"Body" name:"RoleArn"`
	Name                    string `position:"Body" name:"Name"`
	Definition              string `position:"Body" name:"Definition"`
	ExternalStorageLocation string `position:"Body" name:"ExternalStorageLocation"`
}

CreateFlowRequest is the request struct for api CreateFlow

func CreateCreateFlowRequest 

func CreateCreateFlowRequest() (request *CreateFlowRequest)

CreateCreateFlowRequest creates a request to invoke CreateFlow API

type CreateFlowResponse 

type CreateFlowResponse struct {
	*responses.BaseResponse
	RequestId               string `json:"RequestId" xml:"RequestId"`
	Name                    string `json:"Name" xml:"Name"`
	Description             string `json:"Description" xml:"Description"`
	Definition              string `json:"Definition" xml:"Definition"`
	Id                      string `json:"Id" xml:"Id"`
	Type                    string `json:"Type" xml:"Type"`
	RoleArn                 string `json:"RoleArn" xml:"RoleArn"`
	CreatedTime             string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime        string `json:"LastModifiedTime" xml:"LastModifiedTime"`
	ExternalStorageLocation string `json:"ExternalStorageLocation" xml:"ExternalStorageLocation"`
}

CreateFlowResponse is the response struct for api CreateFlow

func CreateCreateFlowResponse 

func CreateCreateFlowResponse() (response *CreateFlowResponse)

CreateCreateFlowResponse creates a response to parse from CreateFlow response

type CreateScheduleRequest 

type CreateScheduleRequest struct {
	*requests.RpcRequest
	ScheduleName   string           `position:"Body" name:"ScheduleName"`
	CronExpression string           `position:"Body" name:"CronExpression"`
	Payload        string           `position:"Body" name:"Payload"`
	RequestId      string           `position:"Query" name:"RequestId"`
	Enable         requests.Boolean `position:"Body" name:"Enable"`
	Description    string           `position:"Body" name:"Description"`
	FlowName       string           `position:"Body" name:"FlowName"`
}

CreateScheduleRequest is the request struct for api CreateSchedule

func CreateCreateScheduleRequest 

func CreateCreateScheduleRequest() (request *CreateScheduleRequest)

CreateCreateScheduleRequest creates a request to invoke CreateSchedule API

type CreateScheduleResponse 

type CreateScheduleResponse struct {
	*responses.BaseResponse
	RequestId        string `json:"RequestId" xml:"RequestId"`
	ScheduleName     string `json:"ScheduleName" xml:"ScheduleName"`
	Description      string `json:"Description" xml:"Description"`
	ScheduleId       string `json:"ScheduleId" xml:"ScheduleId"`
	Payload          string `json:"Payload" xml:"Payload"`
	CronExpression   string `json:"CronExpression" xml:"CronExpression"`
	Enable           bool   `json:"Enable" xml:"Enable"`
	CreatedTime      string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime string `json:"LastModifiedTime" xml:"LastModifiedTime"`
}

CreateScheduleResponse is the response struct for api CreateSchedule

func CreateCreateScheduleResponse 

func CreateCreateScheduleResponse() (response *CreateScheduleResponse)

CreateCreateScheduleResponse creates a response to parse from CreateSchedule response

type DeleteFlowRequest 

type DeleteFlowRequest struct {
	*requests.RpcRequest
	RequestId string `position:"Query" name:"RequestId"`
	Name      string `position:"Query" name:"Name"`
}

DeleteFlowRequest is the request struct for api DeleteFlow

func CreateDeleteFlowRequest 

func CreateDeleteFlowRequest() (request *DeleteFlowRequest)

CreateDeleteFlowRequest creates a request to invoke DeleteFlow API

type DeleteFlowResponse 

type DeleteFlowResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
}

DeleteFlowResponse is the response struct for api DeleteFlow

func CreateDeleteFlowResponse 

func CreateDeleteFlowResponse() (response *DeleteFlowResponse)

CreateDeleteFlowResponse creates a response to parse from DeleteFlow response

type DeleteScheduleRequest 

type DeleteScheduleRequest struct {
	*requests.RpcRequest
	ScheduleName string `position:"Query" name:"ScheduleName"`
	RequestId    string `position:"Query" name:"RequestId"`
	FlowName     string `position:"Query" name:"FlowName"`
}

DeleteScheduleRequest is the request struct for api DeleteSchedule

func CreateDeleteScheduleRequest 

func CreateDeleteScheduleRequest() (request *DeleteScheduleRequest)

CreateDeleteScheduleRequest creates a request to invoke DeleteSchedule API

type DeleteScheduleResponse 

type DeleteScheduleResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
}

DeleteScheduleResponse is the response struct for api DeleteSchedule

func CreateDeleteScheduleResponse 

func CreateDeleteScheduleResponse() (response *DeleteScheduleResponse)

CreateDeleteScheduleResponse creates a response to parse from DeleteSchedule response

type DescribeExecutionRequest 

type DescribeExecutionRequest struct {
	*requests.RpcRequest
	ExecutionName   string           `position:"Query" name:"ExecutionName"`
	WaitTimeSeconds requests.Integer `position:"Query" name:"WaitTimeSeconds"`
	RequestId       string           `position:"Query" name:"RequestId"`
	FlowName        string           `position:"Query" name:"FlowName"`
}

DescribeExecutionRequest is the request struct for api DescribeExecution

func CreateDescribeExecutionRequest 

func CreateDescribeExecutionRequest() (request *DescribeExecutionRequest)

CreateDescribeExecutionRequest creates a request to invoke DescribeExecution API

type DescribeExecutionResponse 

type DescribeExecutionResponse struct {
	*responses.BaseResponse
	RequestId         string `json:"RequestId" xml:"RequestId"`
	Name              string `json:"Name" xml:"Name"`
	FlowName          string `json:"FlowName" xml:"FlowName"`
	FlowDefinition    string `json:"FlowDefinition" xml:"FlowDefinition"`
	Input             string `json:"Input" xml:"Input"`
	Output            string `json:"Output" xml:"Output"`
	Status            string `json:"Status" xml:"Status"`
	StartedTime       string `json:"StartedTime" xml:"StartedTime"`
	StoppedTime       string `json:"StoppedTime" xml:"StoppedTime"`
	ExternalInputUri  string `json:"ExternalInputUri" xml:"ExternalInputUri"`
	ExternalOutputUri string `json:"ExternalOutputUri" xml:"ExternalOutputUri"`
}

DescribeExecutionResponse is the response struct for api DescribeExecution

func CreateDescribeExecutionResponse 

func CreateDescribeExecutionResponse() (response *DescribeExecutionResponse)

CreateDescribeExecutionResponse creates a response to parse from DescribeExecution response

type DescribeFlowRequest 

type DescribeFlowRequest struct {
	*requests.RpcRequest
	RequestId string `position:"Query" name:"RequestId"`
	Name      string `position:"Query" name:"Name"`
}

DescribeFlowRequest is the request struct for api DescribeFlow

func CreateDescribeFlowRequest 

func CreateDescribeFlowRequest() (request *DescribeFlowRequest)

CreateDescribeFlowRequest creates a request to invoke DescribeFlow API

type DescribeFlowResponse 

type DescribeFlowResponse struct {
	*responses.BaseResponse
	RequestId               string `json:"RequestId" xml:"RequestId"`
	Name                    string `json:"Name" xml:"Name"`
	Description             string `json:"Description" xml:"Description"`
	Definition              string `json:"Definition" xml:"Definition"`
	Id                      string `json:"Id" xml:"Id"`
	Type                    string `json:"Type" xml:"Type"`
	RoleArn                 string `json:"RoleArn" xml:"RoleArn"`
	CreatedTime             string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime        string `json:"LastModifiedTime" xml:"LastModifiedTime"`
	ExternalStorageLocation string `json:"ExternalStorageLocation" xml:"ExternalStorageLocation"`
}

DescribeFlowResponse is the response struct for api DescribeFlow

func CreateDescribeFlowResponse 

func CreateDescribeFlowResponse() (response *DescribeFlowResponse)

CreateDescribeFlowResponse creates a response to parse from DescribeFlow response

type DescribeScheduleRequest 

type DescribeScheduleRequest struct {
	*requests.RpcRequest
	ScheduleName string `position:"Query" name:"ScheduleName"`
	RequestId    string `position:"Query" name:"RequestId"`
	FlowName     string `position:"Query" name:"FlowName"`
}

DescribeScheduleRequest is the request struct for api DescribeSchedule

func CreateDescribeScheduleRequest 

func CreateDescribeScheduleRequest() (request *DescribeScheduleRequest)

CreateDescribeScheduleRequest creates a request to invoke DescribeSchedule API

type DescribeScheduleResponse 

type DescribeScheduleResponse struct {
	*responses.BaseResponse
	RequestId        string `json:"RequestId" xml:"RequestId"`
	ScheduleName     string `json:"ScheduleName" xml:"ScheduleName"`
	Description      string `json:"Description" xml:"Description"`
	ScheduleId       string `json:"ScheduleId" xml:"ScheduleId"`
	Payload          string `json:"Payload" xml:"Payload"`
	CronExpression   string `json:"CronExpression" xml:"CronExpression"`
	Enable           bool   `json:"Enable" xml:"Enable"`
	CreatedTime      string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime string `json:"LastModifiedTime" xml:"LastModifiedTime"`
}

DescribeScheduleResponse is the response struct for api DescribeSchedule

func CreateDescribeScheduleResponse 

func CreateDescribeScheduleResponse() (response *DescribeScheduleResponse)

CreateDescribeScheduleResponse creates a response to parse from DescribeSchedule response

type Events 

type Events struct {
	EventsItem []EventsItem `json:"Events" xml:"Events"`
}

Events is a nested struct in fnf response

type EventsItem 

type EventsItem struct {
	StepName        string `json:"StepName" xml:"StepName"`
	Type            string `json:"Type" xml:"Type"`
	EventId         int64  `json:"EventId" xml:"EventId"`
	ScheduleEventId int64  `json:"ScheduleEventId" xml:"ScheduleEventId"`
	EventDetail     string `json:"EventDetail" xml:"EventDetail"`
	Time            string `json:"Time" xml:"Time"`
}

EventsItem is a nested struct in fnf response

type Executions 

type Executions struct {
	ExecutionsItem []ExecutionsItem `json:"Executions" xml:"Executions"`
}

Executions is a nested struct in fnf response

type ExecutionsItem 

type ExecutionsItem struct {
	Name              string `json:"Name" xml:"Name"`
	FlowName          string `json:"FlowName" xml:"FlowName"`
	FlowDefinition    string `json:"FlowDefinition" xml:"FlowDefinition"`
	Input             string `json:"Input" xml:"Input"`
	Output            string `json:"Output" xml:"Output"`
	Status            string `json:"Status" xml:"Status"`
	StartedTime       string `json:"StartedTime" xml:"StartedTime"`
	StoppedTime       string `json:"StoppedTime" xml:"StoppedTime"`
	ExternalInputUri  string `json:"ExternalInputUri" xml:"ExternalInputUri"`
	ExternalOutputUri string `json:"ExternalOutputUri" xml:"ExternalOutputUri"`
}

ExecutionsItem is a nested struct in fnf response

type Flows 

type Flows struct {
	FlowsItem []FlowsItem `json:"Flows" xml:"Flows"`
}

Flows is a nested struct in fnf response

type FlowsItem 

type FlowsItem struct {
	Name                    string `json:"Name" xml:"Name"`
	Description             string `json:"Description" xml:"Description"`
	Definition              string `json:"Definition" xml:"Definition"`
	Id                      string `json:"Id" xml:"Id"`
	Type                    string `json:"Type" xml:"Type"`
	RoleArn                 string `json:"RoleArn" xml:"RoleArn"`
	CreatedTime             string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime        string `json:"LastModifiedTime" xml:"LastModifiedTime"`
	ExternalStorageLocation string `json:"ExternalStorageLocation" xml:"ExternalStorageLocation"`
}

FlowsItem is a nested struct in fnf response

type GetExecutionHistoryRequest 

type GetExecutionHistoryRequest struct {
	*requests.RpcRequest
	ExecutionName string           `position:"Query" name:"ExecutionName"`
	NextToken     string           `position:"Query" name:"NextToken"`
	RequestId     string           `position:"Query" name:"RequestId"`
	Limit         requests.Integer `position:"Query" name:"Limit"`
	FlowName      string           `position:"Query" name:"FlowName"`
}

GetExecutionHistoryRequest is the request struct for api GetExecutionHistory

func CreateGetExecutionHistoryRequest 

func CreateGetExecutionHistoryRequest() (request *GetExecutionHistoryRequest)

CreateGetExecutionHistoryRequest creates a request to invoke GetExecutionHistory API

type GetExecutionHistoryResponse 

type GetExecutionHistoryResponse struct {
	*responses.BaseResponse
	RequestId string       `json:"RequestId" xml:"RequestId"`
	NextToken string       `json:"NextToken" xml:"NextToken"`
	Events    []EventsItem `json:"Events" xml:"Events"`
}

GetExecutionHistoryResponse is the response struct for api GetExecutionHistory

func CreateGetExecutionHistoryResponse 

func CreateGetExecutionHistoryResponse() (response *GetExecutionHistoryResponse)

CreateGetExecutionHistoryResponse creates a response to parse from GetExecutionHistory response

type ListExecutionsRequest 

type ListExecutionsRequest struct {
	*requests.RpcRequest
	StartedTimeBegin    string           `position:"Query" name:"StartedTimeBegin"`
	ExecutionNamePrefix string           `position:"Query" name:"ExecutionNamePrefix"`
	NextToken           string           `position:"Query" name:"NextToken"`
	RequestId           string           `position:"Query" name:"RequestId"`
	Limit               requests.Integer `position:"Query" name:"Limit"`
	FlowName            string           `position:"Query" name:"FlowName"`
	StartedTimeEnd      string           `position:"Query" name:"StartedTimeEnd"`
	Status              string           `position:"Query" name:"Status"`
}

ListExecutionsRequest is the request struct for api ListExecutions

func CreateListExecutionsRequest 

func CreateListExecutionsRequest() (request *ListExecutionsRequest)

CreateListExecutionsRequest creates a request to invoke ListExecutions API

type ListExecutionsResponse 

type ListExecutionsResponse struct {
	*responses.BaseResponse
	RequestId  string           `json:"RequestId" xml:"RequestId"`
	NextToken  string           `json:"NextToken" xml:"NextToken"`
	Executions []ExecutionsItem `json:"Executions" xml:"Executions"`
}

ListExecutionsResponse is the response struct for api ListExecutions

func CreateListExecutionsResponse 

func CreateListExecutionsResponse() (response *ListExecutionsResponse)

CreateListExecutionsResponse creates a response to parse from ListExecutions response

type ListFlowsRequest 

type ListFlowsRequest struct {
	*requests.RpcRequest
	NextToken string           `position:"Query" name:"NextToken"`
	RequestId string           `position:"Query" name:"RequestId"`
	Limit     requests.Integer `position:"Query" name:"Limit"`
}

ListFlowsRequest is the request struct for api ListFlows

func CreateListFlowsRequest 

func CreateListFlowsRequest() (request *ListFlowsRequest)

CreateListFlowsRequest creates a request to invoke ListFlows API

type ListFlowsResponse 

type ListFlowsResponse struct {
	*responses.BaseResponse
	RequestId string      `json:"RequestId" xml:"RequestId"`
	NextToken string      `json:"NextToken" xml:"NextToken"`
	Flows     []FlowsItem `json:"Flows" xml:"Flows"`
}

ListFlowsResponse is the response struct for api ListFlows

func CreateListFlowsResponse 

func CreateListFlowsResponse() (response *ListFlowsResponse)

CreateListFlowsResponse creates a response to parse from ListFlows response

type ListSchedulesRequest 

type ListSchedulesRequest struct {
	*requests.RpcRequest
	NextToken string           `position:"Query" name:"NextToken"`
	RequestId string           `position:"Query" name:"RequestId"`
	Limit     requests.Integer `position:"Query" name:"Limit"`
	FlowName  string           `position:"Query" name:"FlowName"`
}

ListSchedulesRequest is the request struct for api ListSchedules

func CreateListSchedulesRequest 

func CreateListSchedulesRequest() (request *ListSchedulesRequest)

CreateListSchedulesRequest creates a request to invoke ListSchedules API

type ListSchedulesResponse 

type ListSchedulesResponse struct {
	*responses.BaseResponse
	RequestId string          `json:"RequestId" xml:"RequestId"`
	NextToken string          `json:"NextToken" xml:"NextToken"`
	Schedules []SchedulesItem `json:"Schedules" xml:"Schedules"`
}

ListSchedulesResponse is the response struct for api ListSchedules

func CreateListSchedulesResponse 

func CreateListSchedulesResponse() (response *ListSchedulesResponse)

CreateListSchedulesResponse creates a response to parse from ListSchedules response

type ReportTaskFailedRequest 

type ReportTaskFailedRequest struct {
	*requests.RpcRequest
	Cause     string `position:"Body" name:"Cause"`
	Error     string `position:"Body" name:"Error"`
	RequestId string `position:"Query" name:"RequestId"`
	TaskToken string `position:"Query" name:"TaskToken"`
}

ReportTaskFailedRequest is the request struct for api ReportTaskFailed

func CreateReportTaskFailedRequest 

func CreateReportTaskFailedRequest() (request *ReportTaskFailedRequest)

CreateReportTaskFailedRequest creates a request to invoke ReportTaskFailed API

type ReportTaskFailedResponse 

type ReportTaskFailedResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	EventId   int64  `json:"EventId" xml:"EventId"`
}

ReportTaskFailedResponse is the response struct for api ReportTaskFailed

func CreateReportTaskFailedResponse 

func CreateReportTaskFailedResponse() (response *ReportTaskFailedResponse)

CreateReportTaskFailedResponse creates a response to parse from ReportTaskFailed response

type ReportTaskSucceededRequest 

type ReportTaskSucceededRequest struct {
	*requests.RpcRequest
	Output    string `position:"Body" name:"Output"`
	RequestId string `position:"Query" name:"RequestId"`
	TaskToken string `position:"Query" name:"TaskToken"`
}

ReportTaskSucceededRequest is the request struct for api ReportTaskSucceeded

func CreateReportTaskSucceededRequest 

func CreateReportTaskSucceededRequest() (request *ReportTaskSucceededRequest)

CreateReportTaskSucceededRequest creates a request to invoke ReportTaskSucceeded API

type ReportTaskSucceededResponse 

type ReportTaskSucceededResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	EventId   int64  `json:"EventId" xml:"EventId"`
}

ReportTaskSucceededResponse is the response struct for api ReportTaskSucceeded

func CreateReportTaskSucceededResponse 

func CreateReportTaskSucceededResponse() (response *ReportTaskSucceededResponse)

CreateReportTaskSucceededResponse creates a response to parse from ReportTaskSucceeded response

type Schedules 

type Schedules struct {
	SchedulesItem []SchedulesItem `json:"Schedules" xml:"Schedules"`
}

Schedules is a nested struct in fnf response

type SchedulesItem 

type SchedulesItem struct {
	ScheduleName     string `json:"ScheduleName" xml:"ScheduleName"`
	Description      string `json:"Description" xml:"Description"`
	ScheduleId       string `json:"ScheduleId" xml:"ScheduleId"`
	Payload          string `json:"Payload" xml:"Payload"`
	CronExpression   string `json:"CronExpression" xml:"CronExpression"`
	Enable           bool   `json:"Enable" xml:"Enable"`
	CreatedTime      string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime string `json:"LastModifiedTime" xml:"LastModifiedTime"`
}

SchedulesItem is a nested struct in fnf response

type StartExecutionRequest 

type StartExecutionRequest struct {
	*requests.RpcRequest
	CallbackFnFTaskToken string `position:"Body" name:"CallbackFnFTaskToken"`
	ExecutionName        string `position:"Body" name:"ExecutionName"`
	Input                string `position:"Body" name:"Input"`
	RequestId            string `position:"Query" name:"RequestId"`
	FlowName             string `position:"Body" name:"FlowName"`
}

StartExecutionRequest is the request struct for api StartExecution

func CreateStartExecutionRequest 

func CreateStartExecutionRequest() (request *StartExecutionRequest)

CreateStartExecutionRequest creates a request to invoke StartExecution API

type StartExecutionResponse 

type StartExecutionResponse struct {
	*responses.BaseResponse
	RequestId         string `json:"RequestId" xml:"RequestId"`
	Name              string `json:"Name" xml:"Name"`
	FlowName          string `json:"FlowName" xml:"FlowName"`
	FlowDefinition    string `json:"FlowDefinition" xml:"FlowDefinition"`
	Input             string `json:"Input" xml:"Input"`
	Output            string `json:"Output" xml:"Output"`
	Status            string `json:"Status" xml:"Status"`
	StartedTime       string `json:"StartedTime" xml:"StartedTime"`
	StoppedTime       string `json:"StoppedTime" xml:"StoppedTime"`
	ExternalInputUri  string `json:"ExternalInputUri" xml:"ExternalInputUri"`
	ExternalOutputUri string `json:"ExternalOutputUri" xml:"ExternalOutputUri"`
}

StartExecutionResponse is the response struct for api StartExecution

func CreateStartExecutionResponse 

func CreateStartExecutionResponse() (response *StartExecutionResponse)

CreateStartExecutionResponse creates a response to parse from StartExecution response

type StopExecutionRequest 

type StopExecutionRequest struct {
	*requests.RpcRequest
	ExecutionName string `position:"Body" name:"ExecutionName"`
	Cause         string `position:"Body" name:"Cause"`
	Error         string `position:"Body" name:"Error"`
	RequestId     string `position:"Query" name:"RequestId"`
	FlowName      string `position:"Body" name:"FlowName"`
}

StopExecutionRequest is the request struct for api StopExecution

func CreateStopExecutionRequest 

func CreateStopExecutionRequest() (request *StopExecutionRequest)

CreateStopExecutionRequest creates a request to invoke StopExecution API

type StopExecutionResponse 

type StopExecutionResponse struct {
	*responses.BaseResponse
	RequestId         string `json:"RequestId" xml:"RequestId"`
	Name              string `json:"Name" xml:"Name"`
	FlowName          string `json:"FlowName" xml:"FlowName"`
	FlowDefinition    string `json:"FlowDefinition" xml:"FlowDefinition"`
	Input             string `json:"Input" xml:"Input"`
	Output            string `json:"Output" xml:"Output"`
	Status            string `json:"Status" xml:"Status"`
	StartedTime       string `json:"StartedTime" xml:"StartedTime"`
	StoppedTime       string `json:"StoppedTime" xml:"StoppedTime"`
	ExternalInputUri  string `json:"ExternalInputUri" xml:"ExternalInputUri"`
	ExternalOutputUri string `json:"ExternalOutputUri" xml:"ExternalOutputUri"`
}

StopExecutionResponse is the response struct for api StopExecution

func CreateStopExecutionResponse 

func CreateStopExecutionResponse() (response *StopExecutionResponse)

CreateStopExecutionResponse creates a response to parse from StopExecution response

type UpdateFlowRequest 

type UpdateFlowRequest struct {
	*requests.RpcRequest
	Description             string `position:"Body" name:"Description"`
	Type                    string `position:"Body" name:"Type"`
	RequestId               string `position:"Query" name:"RequestId"`
	RoleArn                 string `position:"Body" name:"RoleArn"`
	Name                    string `position:"Body" name:"Name"`
	Definition              string `position:"Body" name:"Definition"`
	ExternalStorageLocation string `position:"Body" name:"ExternalStorageLocation"`
}

UpdateFlowRequest is the request struct for api UpdateFlow

func CreateUpdateFlowRequest 

func CreateUpdateFlowRequest() (request *UpdateFlowRequest)

CreateUpdateFlowRequest creates a request to invoke UpdateFlow API

type UpdateFlowResponse 

type UpdateFlowResponse struct {
	*responses.BaseResponse
	RequestId               string `json:"RequestId" xml:"RequestId"`
	Name                    string `json:"Name" xml:"Name"`
	Description             string `json:"Description" xml:"Description"`
	Definition              string `json:"Definition" xml:"Definition"`
	Id                      string `json:"Id" xml:"Id"`
	Type                    string `json:"Type" xml:"Type"`
	RoleArn                 string `json:"RoleArn" xml:"RoleArn"`
	CreatedTime             string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime        string `json:"LastModifiedTime" xml:"LastModifiedTime"`
	ExternalStorageLocation string `json:"ExternalStorageLocation" xml:"ExternalStorageLocation"`
}

UpdateFlowResponse is the response struct for api UpdateFlow

func CreateUpdateFlowResponse 

func CreateUpdateFlowResponse() (response *UpdateFlowResponse)

CreateUpdateFlowResponse creates a response to parse from UpdateFlow response

type UpdateScheduleRequest 

type UpdateScheduleRequest struct {
	*requests.RpcRequest
	ScheduleName   string           `position:"Body" name:"ScheduleName"`
	CronExpression string           `position:"Body" name:"CronExpression"`
	Payload        string           `position:"Body" name:"Payload"`
	RequestId      string           `position:"Query" name:"RequestId"`
	Enable         requests.Boolean `position:"Body" name:"Enable"`
	Description    string           `position:"Body" name:"Description"`
	FlowName       string           `position:"Body" name:"FlowName"`
}

UpdateScheduleRequest is the request struct for api UpdateSchedule

func CreateUpdateScheduleRequest 

func CreateUpdateScheduleRequest() (request *UpdateScheduleRequest)

CreateUpdateScheduleRequest creates a request to invoke UpdateSchedule API

type UpdateScheduleResponse 

type UpdateScheduleResponse struct {
	*responses.BaseResponse
	RequestId        string `json:"RequestId" xml:"RequestId"`
	ScheduleName     string `json:"ScheduleName" xml:"ScheduleName"`
	Description      string `json:"Description" xml:"Description"`
	ScheduleId       string `json:"ScheduleId" xml:"ScheduleId"`
	Payload          string `json:"Payload" xml:"Payload"`
	CronExpression   string `json:"CronExpression" xml:"CronExpression"`
	Enable           bool   `json:"Enable" xml:"Enable"`
	CreatedTime      string `json:"CreatedTime" xml:"CreatedTime"`
	LastModifiedTime string `json:"LastModifiedTime" xml:"LastModifiedTime"`
}

UpdateScheduleResponse is the response struct for api UpdateSchedule

func CreateUpdateScheduleResponse 

func CreateUpdateScheduleResponse() (response *UpdateScheduleResponse)

CreateUpdateScheduleResponse creates a response to parse from UpdateSchedule response

Source Files

View all Source files

Jump to

Keyboard shortcuts

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