/
stub.go
127 lines (102 loc) · 5.57 KB
/
stub.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
// 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 kinesisvideoarchivedmediastub
import (
"github.com/aws/aws-sdk-go/service/kinesisvideoarchivedmedia"
"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 stub struct{}
type GetClipFuture struct {
// public to support Selector.addFuture
Future workflow.Future
}
func (r *GetClipFuture) Get(ctx workflow.Context) (*kinesisvideoarchivedmedia.GetClipOutput, error) {
var output kinesisvideoarchivedmedia.GetClipOutput
err := r.Future.Get(ctx, &output)
return &output, err
}
type GetDASHStreamingSessionURLFuture struct {
// public to support Selector.addFuture
Future workflow.Future
}
func (r *GetDASHStreamingSessionURLFuture) Get(ctx workflow.Context) (*kinesisvideoarchivedmedia.GetDASHStreamingSessionURLOutput, error) {
var output kinesisvideoarchivedmedia.GetDASHStreamingSessionURLOutput
err := r.Future.Get(ctx, &output)
return &output, err
}
type GetHLSStreamingSessionURLFuture struct {
// public to support Selector.addFuture
Future workflow.Future
}
func (r *GetHLSStreamingSessionURLFuture) Get(ctx workflow.Context) (*kinesisvideoarchivedmedia.GetHLSStreamingSessionURLOutput, error) {
var output kinesisvideoarchivedmedia.GetHLSStreamingSessionURLOutput
err := r.Future.Get(ctx, &output)
return &output, err
}
type GetMediaForFragmentListFuture struct {
// public to support Selector.addFuture
Future workflow.Future
}
func (r *GetMediaForFragmentListFuture) Get(ctx workflow.Context) (*kinesisvideoarchivedmedia.GetMediaForFragmentListOutput, error) {
var output kinesisvideoarchivedmedia.GetMediaForFragmentListOutput
err := r.Future.Get(ctx, &output)
return &output, err
}
type ListFragmentsFuture struct {
// public to support Selector.addFuture
Future workflow.Future
}
func (r *ListFragmentsFuture) Get(ctx workflow.Context) (*kinesisvideoarchivedmedia.ListFragmentsOutput, error) {
var output kinesisvideoarchivedmedia.ListFragmentsOutput
err := r.Future.Get(ctx, &output)
return &output, err
}
func (a *stub) GetClip(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetClipInput) (*kinesisvideoarchivedmedia.GetClipOutput, error) {
var output kinesisvideoarchivedmedia.GetClipOutput
err := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetClip", input).Get(ctx, &output)
return &output, err
}
func (a *stub) GetClipAsync(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetClipInput) *GetClipFuture {
future := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetClip", input)
return &GetClipFuture{Future: future}
}
func (a *stub) GetDASHStreamingSessionURL(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetDASHStreamingSessionURLInput) (*kinesisvideoarchivedmedia.GetDASHStreamingSessionURLOutput, error) {
var output kinesisvideoarchivedmedia.GetDASHStreamingSessionURLOutput
err := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetDASHStreamingSessionURL", input).Get(ctx, &output)
return &output, err
}
func (a *stub) GetDASHStreamingSessionURLAsync(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetDASHStreamingSessionURLInput) *GetDASHStreamingSessionURLFuture {
future := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetDASHStreamingSessionURL", input)
return &GetDASHStreamingSessionURLFuture{Future: future}
}
func (a *stub) GetHLSStreamingSessionURL(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetHLSStreamingSessionURLInput) (*kinesisvideoarchivedmedia.GetHLSStreamingSessionURLOutput, error) {
var output kinesisvideoarchivedmedia.GetHLSStreamingSessionURLOutput
err := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetHLSStreamingSessionURL", input).Get(ctx, &output)
return &output, err
}
func (a *stub) GetHLSStreamingSessionURLAsync(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetHLSStreamingSessionURLInput) *GetHLSStreamingSessionURLFuture {
future := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetHLSStreamingSessionURL", input)
return &GetHLSStreamingSessionURLFuture{Future: future}
}
func (a *stub) GetMediaForFragmentList(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetMediaForFragmentListInput) (*kinesisvideoarchivedmedia.GetMediaForFragmentListOutput, error) {
var output kinesisvideoarchivedmedia.GetMediaForFragmentListOutput
err := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetMediaForFragmentList", input).Get(ctx, &output)
return &output, err
}
func (a *stub) GetMediaForFragmentListAsync(ctx workflow.Context, input *kinesisvideoarchivedmedia.GetMediaForFragmentListInput) *GetMediaForFragmentListFuture {
future := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.GetMediaForFragmentList", input)
return &GetMediaForFragmentListFuture{Future: future}
}
func (a *stub) ListFragments(ctx workflow.Context, input *kinesisvideoarchivedmedia.ListFragmentsInput) (*kinesisvideoarchivedmedia.ListFragmentsOutput, error) {
var output kinesisvideoarchivedmedia.ListFragmentsOutput
err := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.ListFragments", input).Get(ctx, &output)
return &output, err
}
func (a *stub) ListFragmentsAsync(ctx workflow.Context, input *kinesisvideoarchivedmedia.ListFragmentsInput) *ListFragmentsFuture {
future := workflow.ExecuteActivity(ctx, "aws.kinesisvideoarchivedmedia.ListFragments", input)
return &ListFragmentsFuture{Future: future}
}