Skip to content

Commit 9029e9f

Browse files
authored
Add missing sink name flag (#220)
1 parent 6ebcd76 commit 9029e9f

2 files changed

Lines changed: 14 additions & 7 deletions

File tree

app/namespace.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1280,6 +1280,7 @@ func NewNamespaceCommand(getNamespaceClientFn GetNamespaceClientFn) (CommandOut,
12801280
Usage: "Update export sink",
12811281
Flags: []cli.Flag{
12821282
NamespaceFlag,
1283+
sinkNameFlag,
12831284
sinkEnabledFlag,
12841285
sinkAssumedRoleFlagOptional,
12851286
s3BucketFlagOptional,

app/namespace_test.go

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1660,24 +1660,30 @@ func (s *NamespaceTestSuite) TestUpdateExportSink() {
16601660
}{
16611661
{
16621662
name: "update export sink succeeds with no input",
1663-
args: []string{"namespace", "es", "update", "--namespace", ns},
1663+
args: []string{"namespace", "es", "update", "--namespace", ns, "--sink-name", "testSink"},
16641664
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
16651665
},
16661666
{
16671667
name: "update export sink succeeds with no updates",
1668-
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::123456789012:role/TestRole", "--s3-bucket-name", "testBucket", "--enabled", "true"},
1668+
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::123456789012:role/TestRole", "--s3-bucket-name", "testBucket", "--enabled", "true", "--sink-name", "testSink"},
16691669
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
16701670
},
1671+
{
1672+
name: "update export sink succeeds with no updates",
1673+
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::123456789012:role/TestRole", "--s3-bucket-name", "testBucket", "--enabled", "true"},
1674+
expectErr: true,
1675+
expectErrMsg: "Required flag \"sink-name\" not set",
1676+
},
16711677
{
16721678
name: "update export sink succeeds with not valid enabled value",
1673-
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::123456789012:role/TestRole", "--s3-bucket-name", "testBucket", "--enabled", ""},
1679+
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::123456789012:role/TestRole", "--s3-bucket-name", "testBucket", "--sink-name", "testSink", "--enabled", ""},
16741680
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
16751681
expectErr: true,
16761682
expectErrMsg: "invalid value for enabled flag",
16771683
},
16781684
{
16791685
name: "update export sink succeeds with enable flag",
1680-
args: []string{"namespace", "es", "update", "--namespace", ns, "--enabled", "false"},
1686+
args: []string{"namespace", "es", "update", "--namespace", ns, "--enabled", "false", "--sink-name", "testSink"},
16811687
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
16821688
expectRequest: func(r *namespaceservice.UpdateExportSinkRequest) {
16831689
r.Namespace = ns
@@ -1697,7 +1703,7 @@ func (s *NamespaceTestSuite) TestUpdateExportSink() {
16971703
},
16981704
{
16991705
name: "update export sink succeeds with role arn and enabled flag",
1700-
args: []string{"namespace", "es", "update", "--namespace", ns, "--enabled", "false", "--role-arn", "arn:aws:iam::923456789012:role/newTestRole"},
1706+
args: []string{"namespace", "es", "update", "--namespace", ns, "--enabled", "false", "--role-arn", "arn:aws:iam::923456789012:role/newTestRole", "--sink-name", "testSink"},
17011707
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
17021708
expectRequest: func(r *namespaceservice.UpdateExportSinkRequest) {
17031709
r.Namespace = ns
@@ -1717,7 +1723,7 @@ func (s *NamespaceTestSuite) TestUpdateExportSink() {
17171723
},
17181724
{
17191725
name: "update export sink succeeds with role arn, bucket name and enabled flag",
1720-
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::923456789012:role/newTestRole", "--s3-bucket-name", "newTestBucket", "--enabled", "false"},
1726+
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::923456789012:role/newTestRole", "--s3-bucket-name", "newTestBucket", "--enabled", "false", "--sink-name", "testSink"},
17211727
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
17221728
expectRequest: func(r *namespaceservice.UpdateExportSinkRequest) {
17231729
r.Namespace = ns
@@ -1737,7 +1743,7 @@ func (s *NamespaceTestSuite) TestUpdateExportSink() {
17371743
},
17381744
{
17391745
name: "update export sink succeeds with role arn, bucket name, kms arn and enabled flag",
1740-
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::923456789012:role/newTestRole", "--s3-bucket-name", "newTestBucket", "--kms-arn", "arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab", "--enabled", "false"},
1746+
args: []string{"namespace", "es", "update", "--namespace", ns, "--role-arn", "arn:aws:iam::923456789012:role/newTestRole", "--s3-bucket-name", "newTestBucket", "--kms-arn", "arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab", "--enabled", "false", "--sink-name", "testSink"},
17411747
expectGetSinkResponse: func(r *namespaceservice.GetExportSinkResponse) {},
17421748
expectRequest: func(r *namespaceservice.UpdateExportSinkRequest) {
17431749
r.Namespace = ns

0 commit comments

Comments
 (0)