本文整理汇总了Golang中github.com/upstartmobile/aws-sdk-go/service/swf.New函数的典型用法代码示例。如果您正苦于以下问题:Golang New函数的具体用法?Golang New怎么用?Golang New使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了New函数的18个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: ExampleSWF_GetWorkflowExecutionHistory
func ExampleSWF_GetWorkflowExecutionHistory() {
svc := swf.New(nil)
params := &swf.GetWorkflowExecutionHistoryInput{
Domain: aws.String("DomainName"), // Required
Execution: &swf.WorkflowExecution{ // Required
RunId: aws.String("RunId"), // Required
WorkflowId: aws.String("WorkflowId"), // Required
},
MaximumPageSize: aws.Int64(1),
NextPageToken: aws.String("PageToken"),
ReverseOrder: aws.Bool(true),
}
resp, err := svc.GetWorkflowExecutionHistory(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:25,代码来源:examples_test.go
示例2: ExampleSWF_RegisterWorkflowType
func ExampleSWF_RegisterWorkflowType() {
svc := swf.New(nil)
params := &swf.RegisterWorkflowTypeInput{
Domain: aws.String("DomainName"), // Required
Name: aws.String("Name"), // Required
Version: aws.String("Version"), // Required
DefaultChildPolicy: aws.String("ChildPolicy"),
DefaultExecutionStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
DefaultLambdaRole: aws.String("Arn"),
DefaultTaskList: &swf.TaskList{
Name: aws.String("Name"), // Required
},
DefaultTaskPriority: aws.String("TaskPriority"),
DefaultTaskStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
Description: aws.String("Description"),
}
resp, err := svc.RegisterWorkflowType(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:29,代码来源:examples_test.go
示例3: ExampleSWF_CountOpenWorkflowExecutions
func ExampleSWF_CountOpenWorkflowExecutions() {
svc := swf.New(nil)
params := &swf.CountOpenWorkflowExecutionsInput{
Domain: aws.String("DomainName"), // Required
StartTimeFilter: &swf.ExecutionTimeFilter{ // Required
OldestDate: aws.Time(time.Now()), // Required
LatestDate: aws.Time(time.Now()),
},
ExecutionFilter: &swf.WorkflowExecutionFilter{
WorkflowId: aws.String("WorkflowId"), // Required
},
TagFilter: &swf.TagFilter{
Tag: aws.String("Tag"), // Required
},
TypeFilter: &swf.WorkflowTypeFilter{
Name: aws.String("Name"), // Required
Version: aws.String("VersionOptional"),
},
}
resp, err := svc.CountOpenWorkflowExecutions(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:32,代码来源:examples_test.go
示例4: ExampleSWF_PollForDecisionTask
func ExampleSWF_PollForDecisionTask() {
svc := swf.New(nil)
params := &swf.PollForDecisionTaskInput{
Domain: aws.String("DomainName"), // Required
TaskList: &swf.TaskList{ // Required
Name: aws.String("Name"), // Required
},
Identity: aws.String("Identity"),
MaximumPageSize: aws.Int64(1),
NextPageToken: aws.String("PageToken"),
ReverseOrder: aws.Bool(true),
}
resp, err := svc.PollForDecisionTask(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:25,代码来源:examples_test.go
示例5: ExampleSWF_DescribeDomain
func ExampleSWF_DescribeDomain() {
svc := swf.New(nil)
params := &swf.DescribeDomainInput{
Name: aws.String("DomainName"), // Required
}
resp, err := svc.DescribeDomain(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:18,代码来源:examples_test.go
示例6: ExampleSWF_RespondActivityTaskCompleted
func ExampleSWF_RespondActivityTaskCompleted() {
svc := swf.New(nil)
params := &swf.RespondActivityTaskCompletedInput{
TaskToken: aws.String("TaskToken"), // Required
Result: aws.String("Data"),
}
resp, err := svc.RespondActivityTaskCompleted(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:19,代码来源:examples_test.go
示例7: ExampleSWF_RecordActivityTaskHeartbeat
func ExampleSWF_RecordActivityTaskHeartbeat() {
svc := swf.New(nil)
params := &swf.RecordActivityTaskHeartbeatInput{
TaskToken: aws.String("TaskToken"), // Required
Details: aws.String("LimitedData"),
}
resp, err := svc.RecordActivityTaskHeartbeat(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:19,代码来源:examples_test.go
示例8: ExampleSWF_ListClosedWorkflowExecutions
func ExampleSWF_ListClosedWorkflowExecutions() {
svc := swf.New(nil)
params := &swf.ListClosedWorkflowExecutionsInput{
Domain: aws.String("DomainName"), // Required
CloseStatusFilter: &swf.CloseStatusFilter{
Status: aws.String("CloseStatus"), // Required
},
CloseTimeFilter: &swf.ExecutionTimeFilter{
OldestDate: aws.Time(time.Now()), // Required
LatestDate: aws.Time(time.Now()),
},
ExecutionFilter: &swf.WorkflowExecutionFilter{
WorkflowId: aws.String("WorkflowId"), // Required
},
MaximumPageSize: aws.Int64(1),
NextPageToken: aws.String("PageToken"),
ReverseOrder: aws.Bool(true),
StartTimeFilter: &swf.ExecutionTimeFilter{
OldestDate: aws.Time(time.Now()), // Required
LatestDate: aws.Time(time.Now()),
},
TagFilter: &swf.TagFilter{
Tag: aws.String("Tag"), // Required
},
TypeFilter: &swf.WorkflowTypeFilter{
Name: aws.String("Name"), // Required
Version: aws.String("VersionOptional"),
},
}
resp, err := svc.ListClosedWorkflowExecutions(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:42,代码来源:examples_test.go
示例9: ExampleSWF_RequestCancelWorkflowExecution
func ExampleSWF_RequestCancelWorkflowExecution() {
svc := swf.New(nil)
params := &swf.RequestCancelWorkflowExecutionInput{
Domain: aws.String("DomainName"), // Required
WorkflowId: aws.String("WorkflowId"), // Required
RunId: aws.String("RunIdOptional"),
}
resp, err := svc.RequestCancelWorkflowExecution(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:20,代码来源:examples_test.go
示例10: ExampleSWF_RegisterDomain
func ExampleSWF_RegisterDomain() {
svc := swf.New(nil)
params := &swf.RegisterDomainInput{
Name: aws.String("DomainName"), // Required
WorkflowExecutionRetentionPeriodInDays: aws.String("DurationInDays"), // Required
Description: aws.String("Description"),
}
resp, err := svc.RegisterDomain(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:20,代码来源:examples_test.go
示例11: ExampleSWF_ListDomains
func ExampleSWF_ListDomains() {
svc := swf.New(nil)
params := &swf.ListDomainsInput{
RegistrationStatus: aws.String("RegistrationStatus"), // Required
MaximumPageSize: aws.Int64(1),
NextPageToken: aws.String("PageToken"),
ReverseOrder: aws.Bool(true),
}
resp, err := svc.ListDomains(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:21,代码来源:examples_test.go
示例12: ExampleSWF_CountPendingActivityTasks
func ExampleSWF_CountPendingActivityTasks() {
svc := swf.New(nil)
params := &swf.CountPendingActivityTasksInput{
Domain: aws.String("DomainName"), // Required
TaskList: &swf.TaskList{ // Required
Name: aws.String("Name"), // Required
},
}
resp, err := svc.CountPendingActivityTasks(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:21,代码来源:examples_test.go
示例13: ExampleSWF_DescribeWorkflowType
func ExampleSWF_DescribeWorkflowType() {
svc := swf.New(nil)
params := &swf.DescribeWorkflowTypeInput{
Domain: aws.String("DomainName"), // Required
WorkflowType: &swf.WorkflowType{ // Required
Name: aws.String("Name"), // Required
Version: aws.String("Version"), // Required
},
}
resp, err := svc.DescribeWorkflowType(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:22,代码来源:examples_test.go
示例14: ExampleSWF_TerminateWorkflowExecution
func ExampleSWF_TerminateWorkflowExecution() {
svc := swf.New(nil)
params := &swf.TerminateWorkflowExecutionInput{
Domain: aws.String("DomainName"), // Required
WorkflowId: aws.String("WorkflowId"), // Required
ChildPolicy: aws.String("ChildPolicy"),
Details: aws.String("Data"),
Reason: aws.String("TerminateReason"),
RunId: aws.String("RunIdOptional"),
}
resp, err := svc.TerminateWorkflowExecution(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:23,代码来源:examples_test.go
示例15: ExampleSWF_StartWorkflowExecution
func ExampleSWF_StartWorkflowExecution() {
svc := swf.New(nil)
params := &swf.StartWorkflowExecutionInput{
Domain: aws.String("DomainName"), // Required
WorkflowId: aws.String("WorkflowId"), // Required
WorkflowType: &swf.WorkflowType{ // Required
Name: aws.String("Name"), // Required
Version: aws.String("Version"), // Required
},
ChildPolicy: aws.String("ChildPolicy"),
ExecutionStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
Input: aws.String("Data"),
LambdaRole: aws.String("Arn"),
TagList: []*string{
aws.String("Tag"), // Required
// More values...
},
TaskList: &swf.TaskList{
Name: aws.String("Name"), // Required
},
TaskPriority: aws.String("TaskPriority"),
TaskStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
}
resp, err := svc.StartWorkflowExecution(params)
if err != nil {
// Print the error, cast err to awserr.Error to get the Code and
// Message from an error.
fmt.Println(err.Error())
return
}
// Pretty-print the response data.
fmt.Println(resp)
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:36,代码来源:examples_test.go
示例16: ExampleSWF_RespondDecisionTaskCompleted
func ExampleSWF_RespondDecisionTaskCompleted() {
svc := swf.New(nil)
params := &swf.RespondDecisionTaskCompletedInput{
TaskToken: aws.String("TaskToken"), // Required
Decisions: []*swf.Decision{
{ // Required
DecisionType: aws.String("DecisionType"), // Required
CancelTimerDecisionAttributes: &swf.CancelTimerDecisionAttributes{
TimerId: aws.String("TimerId"), // Required
},
CancelWorkflowExecutionDecisionAttributes: &swf.CancelWorkflowExecutionDecisionAttributes{
Details: aws.String("Data"),
},
CompleteWorkflowExecutionDecisionAttributes: &swf.CompleteWorkflowExecutionDecisionAttributes{
Result: aws.String("Data"),
},
ContinueAsNewWorkflowExecutionDecisionAttributes: &swf.ContinueAsNewWorkflowExecutionDecisionAttributes{
ChildPolicy: aws.String("ChildPolicy"),
ExecutionStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
Input: aws.String("Data"),
LambdaRole: aws.String("Arn"),
TagList: []*string{
aws.String("Tag"), // Required
// More values...
},
TaskList: &swf.TaskList{
Name: aws.String("Name"), // Required
},
TaskPriority: aws.String("TaskPriority"),
TaskStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
WorkflowTypeVersion: aws.String("Version"),
},
FailWorkflowExecutionDecisionAttributes: &swf.FailWorkflowExecutionDecisionAttributes{
Details: aws.String("Data"),
Reason: aws.String("FailureReason"),
},
RecordMarkerDecisionAttributes: &swf.RecordMarkerDecisionAttributes{
MarkerName: aws.String("MarkerName"), // Required
Details: aws.String("Data"),
},
RequestCancelActivityTaskDecisionAttributes: &swf.RequestCancelActivityTaskDecisionAttributes{
ActivityId: aws.String("ActivityId"), // Required
},
RequestCancelExternalWorkflowExecutionDecisionAttributes: &swf.RequestCancelExternalWorkflowExecutionDecisionAttributes{
WorkflowId: aws.String("WorkflowId"), // Required
Control: aws.String("Data"),
RunId: aws.String("RunIdOptional"),
},
ScheduleActivityTaskDecisionAttributes: &swf.ScheduleActivityTaskDecisionAttributes{
ActivityId: aws.String("ActivityId"), // Required
ActivityType: &swf.ActivityType{ // Required
Name: aws.String("Name"), // Required
Version: aws.String("Version"), // Required
},
Control: aws.String("Data"),
HeartbeatTimeout: aws.String("DurationInSecondsOptional"),
Input: aws.String("Data"),
ScheduleToCloseTimeout: aws.String("DurationInSecondsOptional"),
ScheduleToStartTimeout: aws.String("DurationInSecondsOptional"),
StartToCloseTimeout: aws.String("DurationInSecondsOptional"),
TaskList: &swf.TaskList{
Name: aws.String("Name"), // Required
},
TaskPriority: aws.String("TaskPriority"),
},
ScheduleLambdaFunctionDecisionAttributes: &swf.ScheduleLambdaFunctionDecisionAttributes{
Id: aws.String("FunctionId"), // Required
Name: aws.String("FunctionName"), // Required
Input: aws.String("FunctionInput"),
StartToCloseTimeout: aws.String("DurationInSecondsOptional"),
},
SignalExternalWorkflowExecutionDecisionAttributes: &swf.SignalExternalWorkflowExecutionDecisionAttributes{
SignalName: aws.String("SignalName"), // Required
WorkflowId: aws.String("WorkflowId"), // Required
Control: aws.String("Data"),
Input: aws.String("Data"),
RunId: aws.String("RunIdOptional"),
},
StartChildWorkflowExecutionDecisionAttributes: &swf.StartChildWorkflowExecutionDecisionAttributes{
WorkflowId: aws.String("WorkflowId"), // Required
WorkflowType: &swf.WorkflowType{ // Required
Name: aws.String("Name"), // Required
Version: aws.String("Version"), // Required
},
ChildPolicy: aws.String("ChildPolicy"),
Control: aws.String("Data"),
ExecutionStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
Input: aws.String("Data"),
LambdaRole: aws.String("Arn"),
TagList: []*string{
aws.String("Tag"), // Required
// More values...
},
TaskList: &swf.TaskList{
Name: aws.String("Name"), // Required
},
TaskPriority: aws.String("TaskPriority"),
TaskStartToCloseTimeout: aws.String("DurationInSecondsOptional"),
},
//.........这里部分代码省略.........
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:101,代码来源:examples_test.go
示例17: TestInterface
func TestInterface(t *testing.T) {
assert.Implements(t, (*swfiface.SWFAPI)(nil), swf.New(nil))
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:3,代码来源:interface_test.go
示例18: init
func init() {
Before("@swf", func() {
World["client"] = swf.New(nil)
})
}
开发者ID:nehadhamija,项目名称:aws-sdk-go,代码行数:5,代码来源:client.go
注:本文中的github.com/upstartmobile/aws-sdk-go/service/swf.New函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论