-
Notifications
You must be signed in to change notification settings - Fork 10
/
integration.go
129 lines (108 loc) · 3.06 KB
/
integration.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
package option
import "github.com/rockset/rockset-go-client/openapi"
type AWSCredentials struct {
*openapi.AwsAccessKey
*openapi.AwsRole
}
type AWSCredentialsFn func(o *AWSCredentials)
func AWSKeys(accessKey, secretKey string) AWSCredentialsFn {
return func(o *AWSCredentials) {
o.AwsAccessKey = &openapi.AwsAccessKey{
AwsAccessKeyId: accessKey,
AwsSecretAccessKey: secretKey,
}
}
}
func AWSRole(roleARN string) AWSCredentialsFn {
return func(o *AWSCredentials) {
o.AwsRole = &openapi.AwsRole{
AwsRoleArn: roleARN,
}
}
}
type S3Integration struct {
openapi.S3Integration
Description *string
}
type S3IntegrationOption func(request *S3Integration)
func WithS3IntegrationDescription(desc string) S3IntegrationOption {
return func(o *S3Integration) {
o.Description = &desc
}
}
type KinesisIntegration struct {
openapi.KinesisIntegration
Description *string
}
type KinesisIntegrationOption func(request *KinesisIntegration)
func WithKinesisIntegrationDescription(desc string) KinesisIntegrationOption {
return func(o *KinesisIntegration) {
o.Description = &desc
}
}
type DynamoDBIntegration struct {
openapi.DynamodbIntegration
Description *string
}
type DynamoDBIntegrationOption func(request *DynamoDBIntegration)
func WithDynamoDBIntegrationDescription(desc string) DynamoDBIntegrationOption {
return func(o *DynamoDBIntegration) {
o.Description = &desc
}
}
type GCSIntegration struct {
Description *string
}
type GCSIntegrationOption func(request *GCSIntegration)
func WithGCSIntegrationDescription(desc string) GCSIntegrationOption {
return func(o *GCSIntegration) {
o.Description = &desc
}
}
type RedshiftIntegration struct {
openapi.RedshiftIntegration
Description *string
}
type RedshiftIntegrationOption func(request *RedshiftIntegration)
func WithRedshiftIntegrationDescription(desc string) RedshiftIntegrationOption {
return func(o *RedshiftIntegration) {
o.Description = &desc
}
}
func WithRedshiftIntegrationConfig(s3BucketPath, username, password, host string,
port int32) RedshiftIntegrationOption {
return func(o *RedshiftIntegration) {
o.RedshiftIntegration.Username = username
o.RedshiftIntegration.Password = password
o.RedshiftIntegration.Host = host
o.RedshiftIntegration.Port = port
o.RedshiftIntegration.S3BucketPath = s3BucketPath
}
}
type SegmentIntegration struct {
Description *string
}
type SegmentIntegrationOption func(request *SegmentIntegration)
func WithSegmentIntegrationDescription(desc string) SegmentIntegrationOption {
return func(o *SegmentIntegration) {
o.Description = &desc
}
}
type KafkaIntegration struct {
Description *string
}
type KafkaIntegrationOption func(request *KafkaIntegration)
func WithKafkaIntegrationDescription(desc string) KafkaIntegrationOption {
return func(o *KafkaIntegration) {
o.Description = &desc
}
}
type MongoDBIntegration struct {
Description *string
}
type MongoDBIntegrationOption func(request *MongoDBIntegration)
func WithMongoDBIntegrationDescription(desc string) MongoDBIntegrationOption {
return func(o *MongoDBIntegration) {
o.Description = &desc
}
}