-
Notifications
You must be signed in to change notification settings - Fork 6
/
interface.go
141 lines (96 loc) · 9.51 KB
/
interface.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
// Generated by github.com/temporalio/temporal-aws-sdk-generator
// from github.com/aws/aws-sdk-go version 1.35.7
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
package emrstub
import (
"github.com/aws/aws-sdk-go/service/emr"
"go.temporal.io/sdk/workflow"
"go.temporal.io/aws-sdk/clients"
)
// ensure that imports are valid even if not used by the generated code
var _ clients.VoidFuture
type Client interface {
AddInstanceFleet(ctx workflow.Context, input *emr.AddInstanceFleetInput) (*emr.AddInstanceFleetOutput, error)
AddInstanceFleetAsync(ctx workflow.Context, input *emr.AddInstanceFleetInput) *AddInstanceFleetFuture
AddInstanceGroups(ctx workflow.Context, input *emr.AddInstanceGroupsInput) (*emr.AddInstanceGroupsOutput, error)
AddInstanceGroupsAsync(ctx workflow.Context, input *emr.AddInstanceGroupsInput) *AddInstanceGroupsFuture
AddJobFlowSteps(ctx workflow.Context, input *emr.AddJobFlowStepsInput) (*emr.AddJobFlowStepsOutput, error)
AddJobFlowStepsAsync(ctx workflow.Context, input *emr.AddJobFlowStepsInput) *AddJobFlowStepsFuture
AddTags(ctx workflow.Context, input *emr.AddTagsInput) (*emr.AddTagsOutput, error)
AddTagsAsync(ctx workflow.Context, input *emr.AddTagsInput) *AddTagsFuture
CancelSteps(ctx workflow.Context, input *emr.CancelStepsInput) (*emr.CancelStepsOutput, error)
CancelStepsAsync(ctx workflow.Context, input *emr.CancelStepsInput) *CancelStepsFuture
CreateSecurityConfiguration(ctx workflow.Context, input *emr.CreateSecurityConfigurationInput) (*emr.CreateSecurityConfigurationOutput, error)
CreateSecurityConfigurationAsync(ctx workflow.Context, input *emr.CreateSecurityConfigurationInput) *CreateSecurityConfigurationFuture
DeleteSecurityConfiguration(ctx workflow.Context, input *emr.DeleteSecurityConfigurationInput) (*emr.DeleteSecurityConfigurationOutput, error)
DeleteSecurityConfigurationAsync(ctx workflow.Context, input *emr.DeleteSecurityConfigurationInput) *DeleteSecurityConfigurationFuture
DescribeCluster(ctx workflow.Context, input *emr.DescribeClusterInput) (*emr.DescribeClusterOutput, error)
DescribeClusterAsync(ctx workflow.Context, input *emr.DescribeClusterInput) *DescribeClusterFuture
DescribeJobFlows(ctx workflow.Context, input *emr.DescribeJobFlowsInput) (*emr.DescribeJobFlowsOutput, error)
DescribeJobFlowsAsync(ctx workflow.Context, input *emr.DescribeJobFlowsInput) *DescribeJobFlowsFuture
DescribeNotebookExecution(ctx workflow.Context, input *emr.DescribeNotebookExecutionInput) (*emr.DescribeNotebookExecutionOutput, error)
DescribeNotebookExecutionAsync(ctx workflow.Context, input *emr.DescribeNotebookExecutionInput) *DescribeNotebookExecutionFuture
DescribeSecurityConfiguration(ctx workflow.Context, input *emr.DescribeSecurityConfigurationInput) (*emr.DescribeSecurityConfigurationOutput, error)
DescribeSecurityConfigurationAsync(ctx workflow.Context, input *emr.DescribeSecurityConfigurationInput) *DescribeSecurityConfigurationFuture
DescribeStep(ctx workflow.Context, input *emr.DescribeStepInput) (*emr.DescribeStepOutput, error)
DescribeStepAsync(ctx workflow.Context, input *emr.DescribeStepInput) *DescribeStepFuture
GetBlockPublicAccessConfiguration(ctx workflow.Context, input *emr.GetBlockPublicAccessConfigurationInput) (*emr.GetBlockPublicAccessConfigurationOutput, error)
GetBlockPublicAccessConfigurationAsync(ctx workflow.Context, input *emr.GetBlockPublicAccessConfigurationInput) *GetBlockPublicAccessConfigurationFuture
GetManagedScalingPolicy(ctx workflow.Context, input *emr.GetManagedScalingPolicyInput) (*emr.GetManagedScalingPolicyOutput, error)
GetManagedScalingPolicyAsync(ctx workflow.Context, input *emr.GetManagedScalingPolicyInput) *GetManagedScalingPolicyFuture
ListBootstrapActions(ctx workflow.Context, input *emr.ListBootstrapActionsInput) (*emr.ListBootstrapActionsOutput, error)
ListBootstrapActionsAsync(ctx workflow.Context, input *emr.ListBootstrapActionsInput) *ListBootstrapActionsFuture
ListClusters(ctx workflow.Context, input *emr.ListClustersInput) (*emr.ListClustersOutput, error)
ListClustersAsync(ctx workflow.Context, input *emr.ListClustersInput) *ListClustersFuture
ListInstanceFleets(ctx workflow.Context, input *emr.ListInstanceFleetsInput) (*emr.ListInstanceFleetsOutput, error)
ListInstanceFleetsAsync(ctx workflow.Context, input *emr.ListInstanceFleetsInput) *ListInstanceFleetsFuture
ListInstanceGroups(ctx workflow.Context, input *emr.ListInstanceGroupsInput) (*emr.ListInstanceGroupsOutput, error)
ListInstanceGroupsAsync(ctx workflow.Context, input *emr.ListInstanceGroupsInput) *ListInstanceGroupsFuture
ListInstances(ctx workflow.Context, input *emr.ListInstancesInput) (*emr.ListInstancesOutput, error)
ListInstancesAsync(ctx workflow.Context, input *emr.ListInstancesInput) *ListInstancesFuture
ListNotebookExecutions(ctx workflow.Context, input *emr.ListNotebookExecutionsInput) (*emr.ListNotebookExecutionsOutput, error)
ListNotebookExecutionsAsync(ctx workflow.Context, input *emr.ListNotebookExecutionsInput) *ListNotebookExecutionsFuture
ListSecurityConfigurations(ctx workflow.Context, input *emr.ListSecurityConfigurationsInput) (*emr.ListSecurityConfigurationsOutput, error)
ListSecurityConfigurationsAsync(ctx workflow.Context, input *emr.ListSecurityConfigurationsInput) *ListSecurityConfigurationsFuture
ListSteps(ctx workflow.Context, input *emr.ListStepsInput) (*emr.ListStepsOutput, error)
ListStepsAsync(ctx workflow.Context, input *emr.ListStepsInput) *ListStepsFuture
ModifyCluster(ctx workflow.Context, input *emr.ModifyClusterInput) (*emr.ModifyClusterOutput, error)
ModifyClusterAsync(ctx workflow.Context, input *emr.ModifyClusterInput) *ModifyClusterFuture
ModifyInstanceFleet(ctx workflow.Context, input *emr.ModifyInstanceFleetInput) (*emr.ModifyInstanceFleetOutput, error)
ModifyInstanceFleetAsync(ctx workflow.Context, input *emr.ModifyInstanceFleetInput) *ModifyInstanceFleetFuture
ModifyInstanceGroups(ctx workflow.Context, input *emr.ModifyInstanceGroupsInput) (*emr.ModifyInstanceGroupsOutput, error)
ModifyInstanceGroupsAsync(ctx workflow.Context, input *emr.ModifyInstanceGroupsInput) *ModifyInstanceGroupsFuture
PutAutoScalingPolicy(ctx workflow.Context, input *emr.PutAutoScalingPolicyInput) (*emr.PutAutoScalingPolicyOutput, error)
PutAutoScalingPolicyAsync(ctx workflow.Context, input *emr.PutAutoScalingPolicyInput) *PutAutoScalingPolicyFuture
PutBlockPublicAccessConfiguration(ctx workflow.Context, input *emr.PutBlockPublicAccessConfigurationInput) (*emr.PutBlockPublicAccessConfigurationOutput, error)
PutBlockPublicAccessConfigurationAsync(ctx workflow.Context, input *emr.PutBlockPublicAccessConfigurationInput) *PutBlockPublicAccessConfigurationFuture
PutManagedScalingPolicy(ctx workflow.Context, input *emr.PutManagedScalingPolicyInput) (*emr.PutManagedScalingPolicyOutput, error)
PutManagedScalingPolicyAsync(ctx workflow.Context, input *emr.PutManagedScalingPolicyInput) *PutManagedScalingPolicyFuture
RemoveAutoScalingPolicy(ctx workflow.Context, input *emr.RemoveAutoScalingPolicyInput) (*emr.RemoveAutoScalingPolicyOutput, error)
RemoveAutoScalingPolicyAsync(ctx workflow.Context, input *emr.RemoveAutoScalingPolicyInput) *RemoveAutoScalingPolicyFuture
RemoveManagedScalingPolicy(ctx workflow.Context, input *emr.RemoveManagedScalingPolicyInput) (*emr.RemoveManagedScalingPolicyOutput, error)
RemoveManagedScalingPolicyAsync(ctx workflow.Context, input *emr.RemoveManagedScalingPolicyInput) *RemoveManagedScalingPolicyFuture
RemoveTags(ctx workflow.Context, input *emr.RemoveTagsInput) (*emr.RemoveTagsOutput, error)
RemoveTagsAsync(ctx workflow.Context, input *emr.RemoveTagsInput) *RemoveTagsFuture
RunJobFlow(ctx workflow.Context, input *emr.RunJobFlowInput) (*emr.RunJobFlowOutput, error)
RunJobFlowAsync(ctx workflow.Context, input *emr.RunJobFlowInput) *RunJobFlowFuture
SetTerminationProtection(ctx workflow.Context, input *emr.SetTerminationProtectionInput) (*emr.SetTerminationProtectionOutput, error)
SetTerminationProtectionAsync(ctx workflow.Context, input *emr.SetTerminationProtectionInput) *SetTerminationProtectionFuture
SetVisibleToAllUsers(ctx workflow.Context, input *emr.SetVisibleToAllUsersInput) (*emr.SetVisibleToAllUsersOutput, error)
SetVisibleToAllUsersAsync(ctx workflow.Context, input *emr.SetVisibleToAllUsersInput) *SetVisibleToAllUsersFuture
StartNotebookExecution(ctx workflow.Context, input *emr.StartNotebookExecutionInput) (*emr.StartNotebookExecutionOutput, error)
StartNotebookExecutionAsync(ctx workflow.Context, input *emr.StartNotebookExecutionInput) *StartNotebookExecutionFuture
StopNotebookExecution(ctx workflow.Context, input *emr.StopNotebookExecutionInput) (*emr.StopNotebookExecutionOutput, error)
StopNotebookExecutionAsync(ctx workflow.Context, input *emr.StopNotebookExecutionInput) *StopNotebookExecutionFuture
TerminateJobFlows(ctx workflow.Context, input *emr.TerminateJobFlowsInput) (*emr.TerminateJobFlowsOutput, error)
TerminateJobFlowsAsync(ctx workflow.Context, input *emr.TerminateJobFlowsInput) *TerminateJobFlowsFuture
WaitUntilClusterRunning(ctx workflow.Context, input *emr.DescribeClusterInput) error
WaitUntilClusterRunningAsync(ctx workflow.Context, input *emr.DescribeClusterInput) *clients.VoidFuture
WaitUntilClusterTerminated(ctx workflow.Context, input *emr.DescribeClusterInput) error
WaitUntilClusterTerminatedAsync(ctx workflow.Context, input *emr.DescribeClusterInput) *clients.VoidFuture
WaitUntilStepComplete(ctx workflow.Context, input *emr.DescribeStepInput) error
WaitUntilStepCompleteAsync(ctx workflow.Context, input *emr.DescribeStepInput) *clients.VoidFuture
}
func NewClient() Client {
return &stub{}
}