Skip to content
GitLab
Commit d36d9445 authored by Scarlett Perry's avatar Scarlett Perry
Browse files

Merge branch 'main' into sperry-SubmitFeedback-API

parents 56c89a39 82dfb3c2
Expand all Hide whitespace changes
Inline Side-by-side
Showing
with 993 additions and 515 deletions
+993 -515
api/aws/dynamodb/v1/dynamodb.proto
+ 8
- 2
View file @ d36d9445
......@@ -31,7 +31,7 @@ service DDBAPI {
message Table {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.dynamodb.v1.Table",
pattern : "{region}/{name}"
pattern : "{account}/{region}/{name}"
};
// Enum representing the status of a table.
......@@ -101,6 +101,9 @@ message Table {
// Table billing mode.
BillingMode billing_mode = 6;
// The aws acccount
string account = 7;
}
// A global secondary index.
......@@ -152,6 +155,7 @@ message Throughput {
message DescribeTableRequest {
string table_name = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
string account = 3 [ (validate.rules).string = {min_bytes : 1} ];
}
// The result of requesting a table.
......@@ -167,13 +171,15 @@ message DescribeTableResponse {
message UpdateCapacityRequest {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.dynamodb.v1.Table",
pattern : "{region}/{table_name}"
pattern : "{account}/{region}/{table_name}"
};
string table_name = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
Throughput table_throughput = 3;
repeated IndexUpdateAction gsi_updates = 4;
bool ignore_maximums = 5;
string account = 6 [ (validate.rules).string = {min_bytes : 1} ];
}
// The result of requesting a capacity update.
......
api/aws/ec2/v1/ec2.proto
+ 12
- 6
View file @ d36d9445
......@@ -52,13 +52,14 @@ message AutoscalingGroupSize {
message ResizeAutoscalingGroupRequest {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.ec2.v1.AutoscalingGroup",
pattern : "{region}/{name}"
pattern : "{account}/{region}/{name}"
};
string name = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
AutoscalingGroupSize size = 3 [ (validate.rules).message = {required : true} ];
string account = 4 [ (validate.rules).string = {min_bytes : 1} ];
}
message ResizeAutoscalingGroupResponse {
......@@ -67,7 +68,7 @@ message ResizeAutoscalingGroupResponse {
message AutoscalingGroup {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.ec2.v1.AutoscalingGroup",
pattern : "{region}/{name}"
pattern : "{account}/{region}/{name}"
};
string name = 1;
......@@ -118,16 +119,18 @@ message AutoscalingGroup {
}
repeated Instance instances = 6;
string account = 7;
}
message GetInstanceRequest {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.ec2.v1.Instance",
pattern : "{region}/{instance_id}"
pattern : "{account}{region}/{instance_id}"
};
string instance_id = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
string account = 3 [ (validate.rules).string = {min_bytes : 1} ];
}
message GetInstanceResponse {
......@@ -139,11 +142,12 @@ message GetInstanceResponse {
message TerminateInstanceRequest {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.ec2.v1.Instance",
pattern : "{region}/{instance_id}"
pattern : "{account}/{region}/{instance_id}"
};
string instance_id = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
string account = 3 [ (validate.rules).string = {min_bytes : 1} ];
}
message TerminateInstanceResponse {
......@@ -152,11 +156,12 @@ message TerminateInstanceResponse {
message RebootInstanceRequest {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.ec2.v1.Instance",
pattern : "{region}/{instance_id}"
pattern : "{account}/{region}/{instance_id}"
};
string instance_id = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
string account = 3 [ (validate.rules).string = {min_bytes : 1} ];
}
message RebootInstanceResponse {
......@@ -165,7 +170,7 @@ message RebootInstanceResponse {
message Instance {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.ec2.v1.Instance",
pattern : "{region}/{instance_id}"
pattern : "{account}/{region}/{instance_id}"
};
string instance_id = 1;
......@@ -192,4 +197,5 @@ message Instance {
string availability_zone = 7;
map<string, string> tags = 8;
string account = 9;
}
api/aws/kinesis/v1/kinesis.proto
+ 9
- 5
View file @ d36d9445
......@@ -5,6 +5,7 @@ package clutch.aws.kinesis.v1;
option go_package = "github.com/lyft/clutch/backend/api/aws/kinesis/v1;kinesisv1";
import "google/api/annotations.proto";
import "validate/validate.proto";
import "api/v1/annotations.proto";
......@@ -27,8 +28,9 @@ service KinesisAPI {
}
message GetStreamRequest {
string stream_name = 1;
string region = 2;
string stream_name = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
string account = 3 [ (validate.rules).string = {min_bytes : 1} ];
}
message GetStreamResponse {
......@@ -38,9 +40,10 @@ message GetStreamResponse {
}
message UpdateShardCountRequest {
string stream_name = 1;
string region = 2;
string stream_name = 1 [ (validate.rules).string = {min_bytes : 1} ];
string region = 2 [ (validate.rules).string = {min_bytes : 1} ];
int32 target_shard_count = 3;
string account = 4 [ (validate.rules).string = {min_bytes : 1} ];
}
message UpdateShardCountResponse {
......@@ -49,10 +52,11 @@ message UpdateShardCountResponse {
message Stream {
option (clutch.api.v1.id).patterns = {
type_url : "clutch.aws.kinesis.v1.Stream",
pattern : "{region}/{stream_name}"
pattern : "{account}/{region}/{stream_name}"
};
string stream_name = 1;
string region = 2;
int32 current_shard_count = 3;
string account = 4;
}
api/chaos/serverexperimentation/v1/serverexperimentation.proto
+ 25
- 3
View file @ d36d9445
......@@ -111,9 +111,31 @@ message ClusterPercentage {
// The fault percentage controlling what percentage of requests considered for a fault injection
// should have the fault applied.
message FaultPercentage {
// The numerator of a percentage with a fixed denumerator equal to 100
// (i.e. percentage equal to 50 results in 50/100 = 50%)
uint32 percentage = 1 [ (validate.rules).uint32 = {gt : 0, lte : 100} ];
// Fraction percentages support several fixed denominator values.
enum DenominatorType {
// Unspecified.
DENOMINATOR_UNSPECIFIED = 0;
// 100.
//
// **Example**: 1/100 = 1%.
DENOMINATOR_HUNDRED = 1;
// 10,000.
//
// **Example**: 1/10000 = 0.01%.
DENOMINATOR_TEN_THOUSAND = 2;
// 1,000,000.
//
// **Example**: 1/1000000 = 0.0001%.
DENOMINATOR_MILLION = 3;
}
// The numerator of a percentage.
// (i.e. percentage equal to 50 with denominator set to HUNDRED results in 50/100 = 50%)
uint32 percentage = 1 [ (validate.rules).uint32 = {gt : 0, lte : 1000000} ];
// Specifies the denominator. If the denominator specified is less than the numerator, the final
// fractional percentage is capped at 1 (100%). Unspecified denominator will be handled as 100.
DenominatorType denominator = 2;
}
// The abort status to apply as part of an abort fault.
......
api/resolver/aws/v1/aws.proto
+ 22
- 1
View file @ d36d9445
......@@ -21,10 +21,16 @@ message InstanceID {
placeholder : "i-1234567890",
},
} ];
string region = 2 [ (clutch.resolver.v1.schema_field) = {
display_name : "Region",
option_field : {include_all_option : true, include_dynamic_options : "regions"},
} ];
string account = 3 [ (clutch.resolver.v1.schema_field) = {
display_name : "Account",
option_field : {include_all_option : true, include_dynamic_options : "accounts"},
} ];
}
message AutoscalingGroupName {
......@@ -45,6 +51,11 @@ message AutoscalingGroupName {
display_name : "Region",
option_field : {include_all_option : true, include_dynamic_options : "regions"},
} ];
string account = 3 [ (clutch.resolver.v1.schema_field) = {
display_name : "Account",
option_field : {include_all_option : true, include_dynamic_options : "accounts"},
} ];
}
message KinesisStreamName {
......@@ -65,6 +76,11 @@ message KinesisStreamName {
display_name : "Region",
option_field : {include_all_option : true, include_dynamic_options : "regions"},
} ];
string account = 3 [ (clutch.resolver.v1.schema_field) = {
display_name : "Account",
option_field : {include_all_option : true, include_dynamic_options : "accounts"},
} ];
}
message DynamodbTableName {
......@@ -85,4 +101,9 @@ message DynamodbTableName {
display_name : "Region",
option_field : {include_all_option : true, include_dynamic_options : "regions"},
} ];
}
\ No newline at end of file
string account = 3 [ (clutch.resolver.v1.schema_field) = {
display_name : "Account",
option_field : {include_all_option : true, include_dynamic_options : "accounts"},
} ];
}
api/timeseries/v1/timeseries.proto
+ 1
- 0
View file @ d36d9445
......@@ -23,4 +23,5 @@ message Point {
}
google.protobuf.Any pb = 3;
string description = 4;
string href = 5;
}
backend/api/aws/dynamodb/v1/dynamodb.pb.go
+ 152
- 120
View file @ d36d9445
This diff is collapsed.
backend/api/aws/dynamodb/v1/dynamodb.pb.validate.go
+ 24
- 0
View file @ d36d9445
......@@ -127,6 +127,8 @@ func (m *Table) validate(all bool) error {
// no validation rules for BillingMode
// no validation rules for Account
if len(errors) > 0 {
return TableMultiError(errors)
}
......@@ -615,6 +617,17 @@ func (m *DescribeTableRequest) validate(all bool) error {
errors = append(errors, err)
}
if len(m.GetAccount()) < 1 {
err := DescribeTableRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return DescribeTableRequestMultiError(errors)
}
......@@ -933,6 +946,17 @@ func (m *UpdateCapacityRequest) validate(all bool) error {
// no validation rules for IgnoreMaximums
if len(m.GetAccount()) < 1 {
err := UpdateCapacityRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return UpdateCapacityRequestMultiError(errors)
}
......
backend/api/aws/ec2/v1/ec2.pb.go
+ 259
- 195
View file @ d36d9445
This diff is collapsed.
backend/api/aws/ec2/v1/ec2.pb.validate.go
+ 48
- 0
View file @ d36d9445
......@@ -226,6 +226,17 @@ func (m *ResizeAutoscalingGroupRequest) validate(all bool) error {
}
}
if len(m.GetAccount()) < 1 {
err := ResizeAutoscalingGroupRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return ResizeAutoscalingGroupRequestMultiError(errors)
}
......@@ -497,6 +508,8 @@ func (m *AutoscalingGroup) validate(all bool) error {
}
// no validation rules for Account
if len(errors) > 0 {
return AutoscalingGroupMultiError(errors)
}
......@@ -618,6 +631,17 @@ func (m *GetInstanceRequest) validate(all bool) error {
errors = append(errors, err)
}
if len(m.GetAccount()) < 1 {
err := GetInstanceRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return GetInstanceRequestMultiError(errors)
}
......@@ -871,6 +895,17 @@ func (m *TerminateInstanceRequest) validate(all bool) error {
errors = append(errors, err)
}
if len(m.GetAccount()) < 1 {
err := TerminateInstanceRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return TerminateInstanceRequestMultiError(errors)
}
......@@ -1095,6 +1130,17 @@ func (m *RebootInstanceRequest) validate(all bool) error {
errors = append(errors, err)
}
if len(m.GetAccount()) < 1 {
err := RebootInstanceRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return RebootInstanceRequestMultiError(errors)
}
......@@ -1313,6 +1359,8 @@ func (m *Instance) validate(all bool) error {
// no validation rules for Tags
// no validation rules for Account
if len(errors) > 0 {
return InstanceMultiError(errors)
}
......
backend/api/aws/kinesis/v1/kinesis.pb.go
+ 93
- 58
View file @ d36d9445
......@@ -7,6 +7,7 @@
package kinesisv1
import (
_ "github.com/envoyproxy/protoc-gen-validate/validate"
_ "github.com/lyft/clutch/backend/api/api/v1"
_ "google.golang.org/genproto/googleapis/api/annotations"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
......@@ -29,6 +30,7 @@ type GetStreamRequest struct {
StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *GetStreamRequest) Reset() {
......@@ -77,6 +79,13 @@ func (x *GetStreamRequest) GetRegion() string {
return ""
}
func (x *GetStreamRequest) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
type GetStreamResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
......@@ -132,6 +141,7 @@ type UpdateShardCountRequest struct {
StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
TargetShardCount int32 `protobuf:"varint,3,opt,name=target_shard_count,json=targetShardCount,proto3" json:"target_shard_count,omitempty"`
Account string `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *UpdateShardCountRequest) Reset() {
......@@ -187,6 +197,13 @@ func (x *UpdateShardCountRequest) GetTargetShardCount() int32 {
return 0
}
func (x *UpdateShardCountRequest) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
type UpdateShardCountResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
......@@ -233,6 +250,7 @@ type Stream struct {
StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
CurrentShardCount int32 `protobuf:"varint,3,opt,name=current_shard_count,json=currentShardCount,proto3" json:"current_shard_count,omitempty"`
Account string `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *Stream) Reset() {
......@@ -288,6 +306,13 @@ func (x *Stream) GetCurrentShardCount() int32 {
return 0
}
func (x *Stream) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
var File_aws_kinesis_v1_kinesis_proto protoreflect.FileDescriptor
var file_aws_kinesis_v1_kinesis_proto_rawDesc = []byte{
......@@ -296,65 +321,75 @@ var file_aws_kinesis_v1_kinesis_proto_rawDesc = []byte{
0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73,
0x69, 0x73, 0x2e, 0x76, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,
0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72,
0x6f, 0x74, 0x6f, 0x1a, 0x18, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x6e, 0x6e, 0x6f,
0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x4b, 0x0a,
0x10, 0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61,
0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0x58, 0x0a, 0x11, 0x47, 0x65,
0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
0x35, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
0x1d, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e,
0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x06,
0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x3a, 0x0c, 0xaa, 0xe1, 0x1c, 0x08, 0x0a, 0x06, 0x73, 0x74,
0x72, 0x65, 0x61, 0x6d, 0x22, 0x80, 0x01, 0x0a, 0x17, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53,
0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18,
0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d,
0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28,
0x09, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x2c, 0x0a, 0x12, 0x74, 0x61, 0x72,
0x67, 0x65, 0x74, 0x5f, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18,
0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x10, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x53, 0x68, 0x61,
0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x1a, 0x0a, 0x18, 0x55, 0x70, 0x64, 0x61, 0x74,
0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x22, 0xaf, 0x01, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x1f,
0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20,
0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12,
0x16, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x2e, 0x0a, 0x13, 0x63, 0x75, 0x72, 0x72, 0x65,
0x6e, 0x74, 0x5f, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03,
0x20, 0x01, 0x28, 0x05, 0x52, 0x11, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x53, 0x68, 0x61,
0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x3a, 0x3c, 0xb2, 0xe1, 0x1c, 0x38, 0x0a, 0x36, 0x0a,
0x1c, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65,
0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x16, 0x7b,
0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f,
0x6e, 0x61, 0x6d, 0x65, 0x7d, 0x32, 0xc2, 0x02, 0x0a, 0x0a, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69,
0x73, 0x41, 0x50, 0x49, 0x12, 0x8a, 0x01, 0x0a, 0x09, 0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65,
0x61, 0x6d, 0x12, 0x27, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e,
0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74,
0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x63, 0x6c,
0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73,
0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73,
0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2a, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1e, 0x22, 0x19, 0x2f,
0x76, 0x31, 0x2f, 0x61, 0x77, 0x73, 0x2f, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2f, 0x67,
0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x3a, 0x01, 0x2a, 0xaa, 0xe1, 0x1c, 0x02, 0x08,
0x02, 0x12, 0xa6, 0x01, 0x0a, 0x10, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61, 0x72,
0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x2e, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e,
0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x55,
0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e,
0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x55,
0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61,
0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x18, 0x61, 0x70,
0x69, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x80, 0x01, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x53, 0x74,
0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x28, 0x0a, 0x0b, 0x73,
0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x20, 0x01, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61,
0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18,
0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x20, 0x01, 0x52, 0x06,
0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x21, 0x0a, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e,
0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x20, 0x01,
0x52, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x58, 0x0a, 0x11, 0x47, 0x65, 0x74,
0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35,
0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d,
0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65,
0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x06, 0x73,
0x74, 0x72, 0x65, 0x61, 0x6d, 0x3a, 0x0c, 0xaa, 0xe1, 0x1c, 0x08, 0x0a, 0x06, 0x73, 0x74, 0x72,
0x65, 0x61, 0x6d, 0x22, 0xb5, 0x01, 0x0a, 0x17, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68,
0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
0x28, 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01,
0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x20, 0x01, 0x52, 0x0a, 0x73,
0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x06, 0x72, 0x65, 0x67,
0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02,
0x20, 0x01, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x2c, 0x0a, 0x12, 0x74, 0x61,
0x72, 0x67, 0x65, 0x74, 0x5f, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74,
0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x10, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x53, 0x68,
0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x21, 0x0a, 0x07, 0x61, 0x63, 0x63, 0x6f,
0x75, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02,
0x20, 0x01, 0x52, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x1a, 0x0a, 0x18, 0x55,
0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52,
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x31, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x25, 0x22,
0x20, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x77, 0x73, 0x2f, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73,
0x2f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e,
0x74, 0x3a, 0x01, 0x2a, 0xaa, 0xe1, 0x1c, 0x02, 0x08, 0x03, 0x42, 0x3d, 0x5a, 0x3b, 0x67, 0x69,
0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c,
0x75, 0x74, 0x63, 0x68, 0x2f, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69,
0x2f, 0x61, 0x77, 0x73, 0x2f, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2f, 0x76, 0x31, 0x3b,
0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x33,
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xd3, 0x01, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x65,
0x61, 0x6d, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d,
0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e,
0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x2e, 0x0a, 0x13, 0x63,
0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, 0x63, 0x6f, 0x75,
0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x11, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e,
0x74, 0x53, 0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x61,
0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x63,
0x63, 0x6f, 0x75, 0x6e, 0x74, 0x3a, 0x46, 0xb2, 0xe1, 0x1c, 0x42, 0x0a, 0x40, 0x0a, 0x1c, 0x63,
0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69,
0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x20, 0x7b, 0x61, 0x63,
0x63, 0x6f, 0x75, 0x6e, 0x74, 0x7d, 0x2f, 0x7b, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x7d, 0x2f,
0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x7d, 0x32, 0xc2, 0x02,
0x0a, 0x0a, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x41, 0x50, 0x49, 0x12, 0x8a, 0x01, 0x0a,
0x09, 0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x27, 0x2e, 0x63, 0x6c, 0x75,
0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e,
0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73,
0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53,
0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2a, 0x82,
0xd3, 0xe4, 0x93, 0x02, 0x1e, 0x22, 0x19, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x77, 0x73, 0x2f, 0x6b,
0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2f, 0x67, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
0x3a, 0x01, 0x2a, 0xaa, 0xe1, 0x1c, 0x02, 0x08, 0x02, 0x12, 0xa6, 0x01, 0x0a, 0x10, 0x55, 0x70,
0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x2e,
0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65,
0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61,
0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f,
0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x61, 0x77, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65,
0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x68, 0x61,
0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
0x31, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x25, 0x22, 0x20, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x77, 0x73,
0x2f, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53,
0x68, 0x61, 0x72, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x3a, 0x01, 0x2a, 0xaa, 0xe1, 0x1c, 0x02,
0x08, 0x03, 0x42, 0x3d, 0x5a, 0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d,
0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2f, 0x62, 0x61, 0x63,
0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x77, 0x73, 0x2f, 0x6b, 0x69, 0x6e,
0x65, 0x73, 0x69, 0x73, 0x2f, 0x76, 0x31, 0x3b, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x76,
0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
......
backend/api/aws/kinesis/v1/kinesis.pb.validate.go
+ 64
- 4
View file @ d36d9445
......@@ -57,9 +57,38 @@ func (m *GetStreamRequest) validate(all bool) error {
var errors []error
// no validation rules for StreamName
if len(m.GetStreamName()) < 1 {
err := GetStreamRequestValidationError{
field: "StreamName",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
// no validation rules for Region
if len(m.GetRegion()) < 1 {
err := GetStreamRequestValidationError{
field: "Region",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(m.GetAccount()) < 1 {
err := GetStreamRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return GetStreamRequestMultiError(errors)
......@@ -290,12 +319,41 @@ func (m *UpdateShardCountRequest) validate(all bool) error {
var errors []error
// no validation rules for StreamName
if len(m.GetStreamName()) < 1 {
err := UpdateShardCountRequestValidationError{
field: "StreamName",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
// no validation rules for Region
if len(m.GetRegion()) < 1 {
err := UpdateShardCountRequestValidationError{
field: "Region",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
// no validation rules for TargetShardCount
if len(m.GetAccount()) < 1 {
err := UpdateShardCountRequestValidationError{
field: "Account",
reason: "value length must be at least 1 bytes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return UpdateShardCountRequestMultiError(errors)
}
......@@ -503,6 +561,8 @@ func (m *Stream) validate(all bool) error {
// no validation rules for CurrentShardCount
// no validation rules for Account
if len(errors) > 0 {
return StreamMultiError(errors)
}
......
backend/api/chaos/serverexperimentation/v1/serverexperimentation.pb.go
+ 144
- 52
View file @ d36d9445
......@@ -21,6 +21,69 @@ const (
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// Fraction percentages support several fixed denominator values.
type FaultPercentage_DenominatorType int32
const (
// Unspecified.
FaultPercentage_DENOMINATOR_UNSPECIFIED FaultPercentage_DenominatorType = 0
// 100.
//
// **Example**: 1/100 = 1%.
FaultPercentage_DENOMINATOR_HUNDRED FaultPercentage_DenominatorType = 1
// 10,000.
//
// **Example**: 1/10000 = 0.01%.
FaultPercentage_DENOMINATOR_TEN_THOUSAND FaultPercentage_DenominatorType = 2
// 1,000,000.
//
// **Example**: 1/1000000 = 0.0001%.
FaultPercentage_DENOMINATOR_MILLION FaultPercentage_DenominatorType = 3
)
// Enum value maps for FaultPercentage_DenominatorType.
var (
FaultPercentage_DenominatorType_name = map[int32]string{
0: "DENOMINATOR_UNSPECIFIED",
1: "DENOMINATOR_HUNDRED",
2: "DENOMINATOR_TEN_THOUSAND",
3: "DENOMINATOR_MILLION",
}
FaultPercentage_DenominatorType_value = map[string]int32{
"DENOMINATOR_UNSPECIFIED": 0,
"DENOMINATOR_HUNDRED": 1,
"DENOMINATOR_TEN_THOUSAND": 2,
"DENOMINATOR_MILLION": 3,
}
)
func (x FaultPercentage_DenominatorType) Enum() *FaultPercentage_DenominatorType {
p := new(FaultPercentage_DenominatorType)
*p = x
return p
}
func (x FaultPercentage_DenominatorType) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (FaultPercentage_DenominatorType) Descriptor() protoreflect.EnumDescriptor {
return file_chaos_serverexperimentation_v1_serverexperimentation_proto_enumTypes[0].Descriptor()
}
func (FaultPercentage_DenominatorType) Type() protoreflect.EnumType {
return &file_chaos_serverexperimentation_v1_serverexperimentation_proto_enumTypes[0]
}
func (x FaultPercentage_DenominatorType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use FaultPercentage_DenominatorType.Descriptor instead.
func (FaultPercentage_DenominatorType) EnumDescriptor() ([]byte, []int) {
return file_chaos_serverexperimentation_v1_serverexperimentation_proto_rawDescGZIP(), []int{8, 0}
}
// The configuration of an HTTP fault.
type HTTPFaultConfig struct {
state protoimpl.MessageState
......@@ -627,9 +690,12 @@ type FaultPercentage struct {
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The numerator of a percentage with a fixed denumerator equal to 100
// (i.e. percentage equal to 50 results in 50/100 = 50%)
// The numerator of a percentage.
// (i.e. percentage equal to 50 with denominator set to HUNDRED results in 50/100 = 50%)
Percentage uint32 `protobuf:"varint,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
// Specifies the denominator. If the denominator specified is less than the numerator, the final
// fractional percentage is capped at 1 (100%). Unspecified denominator will be handled as 100.
Denominator FaultPercentage_DenominatorType `protobuf:"varint,2,opt,name=denominator,proto3,enum=clutch.chaos.serverexperimentation.v1.FaultPercentage_DenominatorType" json:"denominator,omitempty"`
}
func (x *FaultPercentage) Reset() {
......@@ -671,6 +737,13 @@ func (x *FaultPercentage) GetPercentage() uint32 {
return 0
}
func (x *FaultPercentage) GetDenominator() FaultPercentage_DenominatorType {
if x != nil {
return x.Denominator
}
return FaultPercentage_DENOMINATOR_UNSPECIFIED
}
// The abort status to apply as part of an abort fault.
type FaultAbortStatus struct {
state protoimpl.MessageState
......@@ -884,26 +957,41 @@ var file_chaos_serverexperimentation_v1_serverexperimentation_proto_rawDesc = []
0x63, 0x65, 0x6e, 0x74, 0x61, 0x67, 0x65, 0x12, 0x29, 0x0a, 0x0a, 0x70, 0x65, 0x72, 0x63, 0x65,
0x6e, 0x74, 0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x09, 0xfa, 0x42, 0x06,
0x2a, 0x04, 0x18, 0x64, 0x20, 0x00, 0x52, 0x0a, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x61,
0x67, 0x65, 0x22, 0x3c, 0x0a, 0x0f, 0x46, 0x61, 0x75, 0x6c, 0x74, 0x50, 0x65, 0x72, 0x63, 0x65,
0x6e, 0x74, 0x61, 0x67, 0x65, 0x12, 0x29, 0x0a, 0x0a, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74,
0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x09, 0xfa, 0x42, 0x06, 0x2a, 0x04,
0x18, 0x64, 0x20, 0x00, 0x52, 0x0a, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x61, 0x67, 0x65,
0x22, 0x48, 0x0a, 0x10, 0x46, 0x61, 0x75, 0x6c, 0x74, 0x41, 0x62, 0x6f, 0x72, 0x74, 0x53, 0x74,
0x61, 0x74, 0x75, 0x73, 0x12, 0x34, 0x0a, 0x10, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x73, 0x74, 0x61,
0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x0a,
0xfa, 0x42, 0x07, 0x2a, 0x05, 0x10, 0xd8, 0x04, 0x20, 0x63, 0x52, 0x0e, 0x68, 0x74, 0x74, 0x70,
0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x22, 0x4b, 0x0a, 0x14, 0x46, 0x61,
0x75, 0x6c, 0x74, 0x4c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x12, 0x33, 0x0a, 0x11, 0x66, 0x69, 0x78, 0x65, 0x64, 0x5f, 0x64, 0x75, 0x72, 0x61,
0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x07, 0xfa,
0x42, 0x04, 0x2a, 0x02, 0x20, 0x00, 0x52, 0x0f, 0x66, 0x69, 0x78, 0x65, 0x64, 0x44, 0x75, 0x72,
0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x73, 0x42, 0x5b, 0x5a, 0x59, 0x67, 0x69, 0x74, 0x68, 0x75,
0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c, 0x75, 0x74, 0x63,
0x68, 0x2f, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x68,
0x61, 0x6f, 0x73, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x65, 0x78, 0x70, 0x65, 0x72, 0x69,
0x6d, 0x65, 0x6e, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 0x31, 0x3b, 0x73, 0x65, 0x72,
0x76, 0x65, 0x72, 0x65, 0x78, 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x67, 0x65, 0x22, 0xa8, 0x02, 0x0a, 0x0f, 0x46, 0x61, 0x75, 0x6c, 0x74, 0x50, 0x65, 0x72, 0x63,
0x65, 0x6e, 0x74, 0x61, 0x67, 0x65, 0x12, 0x2b, 0x0a, 0x0a, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e,
0x74, 0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x0b, 0xfa, 0x42, 0x08, 0x2a,
0x06, 0x18, 0xc0, 0x84, 0x3d, 0x20, 0x00, 0x52, 0x0a, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74,
0x61, 0x67, 0x65, 0x12, 0x68, 0x0a, 0x0b, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x6e, 0x61, 0x74,
0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x46, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63,
0x68, 0x2e, 0x63, 0x68, 0x61, 0x6f, 0x73, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x65, 0x78,
0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x76, 0x31,
0x2e, 0x46, 0x61, 0x75, 0x6c, 0x74, 0x50, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x61, 0x67, 0x65,
0x2e, 0x44, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65,
0x52, 0x0b, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x6f, 0x72, 0x22, 0x7e, 0x0a,
0x0f, 0x44, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65,
0x12, 0x1b, 0x0a, 0x17, 0x44, 0x45, 0x4e, 0x4f, 0x4d, 0x49, 0x4e, 0x41, 0x54, 0x4f, 0x52, 0x5f,
0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x17, 0x0a,
0x13, 0x44, 0x45, 0x4e, 0x4f, 0x4d, 0x49, 0x4e, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x48, 0x55, 0x4e,
0x44, 0x52, 0x45, 0x44, 0x10, 0x01, 0x12, 0x1c, 0x0a, 0x18, 0x44, 0x45, 0x4e, 0x4f, 0x4d, 0x49,
0x4e, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x45, 0x4e, 0x5f, 0x54, 0x48, 0x4f, 0x55, 0x53, 0x41,
0x4e, 0x44, 0x10, 0x02, 0x12, 0x17, 0x0a, 0x13, 0x44, 0x45, 0x4e, 0x4f, 0x4d, 0x49, 0x4e, 0x41,
0x54, 0x4f, 0x52, 0x5f, 0x4d, 0x49, 0x4c, 0x4c, 0x49, 0x4f, 0x4e, 0x10, 0x03, 0x22, 0x48, 0x0a,
0x10, 0x46, 0x61, 0x75, 0x6c, 0x74, 0x41, 0x62, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75,
0x73, 0x12, 0x34, 0x0a, 0x10, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x0a, 0xfa, 0x42, 0x07,
0x2a, 0x05, 0x10, 0xd8, 0x04, 0x20, 0x63, 0x52, 0x0e, 0x68, 0x74, 0x74, 0x70, 0x53, 0x74, 0x61,
0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x22, 0x4b, 0x0a, 0x14, 0x46, 0x61, 0x75, 0x6c, 0x74,
0x4c, 0x61, 0x74, 0x65, 0x6e, 0x63, 0x79, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12,
0x33, 0x0a, 0x11, 0x66, 0x69, 0x78, 0x65, 0x64, 0x5f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f,
0x6e, 0x5f, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x2a,
0x02, 0x20, 0x00, 0x52, 0x0f, 0x66, 0x69, 0x78, 0x65, 0x64, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69,
0x6f, 0x6e, 0x4d, 0x73, 0x42, 0x5b, 0x5a, 0x59, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
0x6f, 0x6d, 0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2f, 0x62,
0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x68, 0x61, 0x6f, 0x73,
0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x65, 0x78, 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e,
0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x76, 0x31, 0x3b, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
0x65, 0x78, 0x70, 0x65, 0x72, 0x69, 0x6d, 0x65, 0x6e, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x76,
0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
......@@ -918,39 +1006,42 @@ func file_chaos_serverexperimentation_v1_serverexperimentation_proto_rawDescGZIP
return file_chaos_serverexperimentation_v1_serverexperimentation_proto_rawDescData
}
var file_chaos_serverexperimentation_v1_serverexperimentation_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_chaos_serverexperimentation_v1_serverexperimentation_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
var file_chaos_serverexperimentation_v1_serverexperimentation_proto_goTypes = []interface{}{
(*HTTPFaultConfig)(nil), // 0: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig
(*AbortFault)(nil), // 1: clutch.chaos.serverexperimentation.v1.AbortFault
(*LatencyFault)(nil), // 2: clutch.chaos.serverexperimentation.v1.LatencyFault
(*FaultTargeting)(nil), // 3: clutch.chaos.serverexperimentation.v1.FaultTargeting
(*UpstreamEnforcing)(nil), // 4: clutch.chaos.serverexperimentation.v1.UpstreamEnforcing
(*DownstreamEnforcing)(nil), // 5: clutch.chaos.serverexperimentation.v1.DownstreamEnforcing
(*SingleCluster)(nil), // 6: clutch.chaos.serverexperimentation.v1.SingleCluster
(*ClusterPercentage)(nil), // 7: clutch.chaos.serverexperimentation.v1.ClusterPercentage
(*FaultPercentage)(nil), // 8: clutch.chaos.serverexperimentation.v1.FaultPercentage
(*FaultAbortStatus)(nil), // 9: clutch.chaos.serverexperimentation.v1.FaultAbortStatus
(*FaultLatencyDuration)(nil), // 10: clutch.chaos.serverexperimentation.v1.FaultLatencyDuration
(FaultPercentage_DenominatorType)(0), // 0: clutch.chaos.serverexperimentation.v1.FaultPercentage.DenominatorType
(*HTTPFaultConfig)(nil), // 1: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig
(*AbortFault)(nil), // 2: clutch.chaos.serverexperimentation.v1.AbortFault
(*LatencyFault)(nil), // 3: clutch.chaos.serverexperimentation.v1.LatencyFault
(*FaultTargeting)(nil), // 4: clutch.chaos.serverexperimentation.v1.FaultTargeting
(*UpstreamEnforcing)(nil), // 5: clutch.chaos.serverexperimentation.v1.UpstreamEnforcing
(*DownstreamEnforcing)(nil), // 6: clutch.chaos.serverexperimentation.v1.DownstreamEnforcing
(*SingleCluster)(nil), // 7: clutch.chaos.serverexperimentation.v1.SingleCluster
(*ClusterPercentage)(nil), // 8: clutch.chaos.serverexperimentation.v1.ClusterPercentage
(*FaultPercentage)(nil), // 9: clutch.chaos.serverexperimentation.v1.FaultPercentage
(*FaultAbortStatus)(nil), // 10: clutch.chaos.serverexperimentation.v1.FaultAbortStatus
(*FaultLatencyDuration)(nil), // 11: clutch.chaos.serverexperimentation.v1.FaultLatencyDuration
}
var file_chaos_serverexperimentation_v1_serverexperimentation_proto_depIdxs = []int32{
3, // 0: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig.fault_targeting:type_name -> clutch.chaos.serverexperimentation.v1.FaultTargeting
1, // 1: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig.abort_fault:type_name -> clutch.chaos.serverexperimentation.v1.AbortFault
2, // 2: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig.latency_fault:type_name -> clutch.chaos.serverexperimentation.v1.LatencyFault
8, // 3: clutch.chaos.serverexperimentation.v1.AbortFault.percentage:type_name -> clutch.chaos.serverexperimentation.v1.FaultPercentage
9, // 4: clutch.chaos.serverexperimentation.v1.AbortFault.abort_status:type_name -> clutch.chaos.serverexperimentation.v1.FaultAbortStatus
8, // 5: clutch.chaos.serverexperimentation.v1.LatencyFault.percentage:type_name -> clutch.chaos.serverexperimentation.v1.FaultPercentage
10, // 6: clutch.chaos.serverexperimentation.v1.LatencyFault.latency_duration:type_name -> clutch.chaos.serverexperimentation.v1.FaultLatencyDuration
4, // 7: clutch.chaos.serverexperimentation.v1.FaultTargeting.upstream_enforcing:type_name -> clutch.chaos.serverexperimentation.v1.UpstreamEnforcing
5, // 8: clutch.chaos.serverexperimentation.v1.FaultTargeting.downstream_enforcing:type_name -> clutch.chaos.serverexperimentation.v1.DownstreamEnforcing
6, // 9: clutch.chaos.serverexperimentation.v1.UpstreamEnforcing.upstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
6, // 10: clutch.chaos.serverexperimentation.v1.UpstreamEnforcing.downstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
6, // 11: clutch.chaos.serverexperimentation.v1.DownstreamEnforcing.upstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
6, // 12: clutch.chaos.serverexperimentation.v1.DownstreamEnforcing.downstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
13, // [13:13] is the sub-list for method output_type
13, // [13:13] is the sub-list for method input_type
13, // [13:13] is the sub-list for extension type_name
13, // [13:13] is the sub-list for extension extendee
0, // [0:13] is the sub-list for field type_name
4, // 0: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig.fault_targeting:type_name -> clutch.chaos.serverexperimentation.v1.FaultTargeting
2, // 1: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig.abort_fault:type_name -> clutch.chaos.serverexperimentation.v1.AbortFault
3, // 2: clutch.chaos.serverexperimentation.v1.HTTPFaultConfig.latency_fault:type_name -> clutch.chaos.serverexperimentation.v1.LatencyFault
9, // 3: clutch.chaos.serverexperimentation.v1.AbortFault.percentage:type_name -> clutch.chaos.serverexperimentation.v1.FaultPercentage
10, // 4: clutch.chaos.serverexperimentation.v1.AbortFault.abort_status:type_name -> clutch.chaos.serverexperimentation.v1.FaultAbortStatus
9, // 5: clutch.chaos.serverexperimentation.v1.LatencyFault.percentage:type_name -> clutch.chaos.serverexperimentation.v1.FaultPercentage
11, // 6: clutch.chaos.serverexperimentation.v1.LatencyFault.latency_duration:type_name -> clutch.chaos.serverexperimentation.v1.FaultLatencyDuration
5, // 7: clutch.chaos.serverexperimentation.v1.FaultTargeting.upstream_enforcing:type_name -> clutch.chaos.serverexperimentation.v1.UpstreamEnforcing
6, // 8: clutch.chaos.serverexperimentation.v1.FaultTargeting.downstream_enforcing:type_name -> clutch.chaos.serverexperimentation.v1.DownstreamEnforcing
7, // 9: clutch.chaos.serverexperimentation.v1.UpstreamEnforcing.upstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
7, // 10: clutch.chaos.serverexperimentation.v1.UpstreamEnforcing.downstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
7, // 11: clutch.chaos.serverexperimentation.v1.DownstreamEnforcing.upstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
7, // 12: clutch.chaos.serverexperimentation.v1.DownstreamEnforcing.downstream_cluster:type_name -> clutch.chaos.serverexperimentation.v1.SingleCluster
0, // 13: clutch.chaos.serverexperimentation.v1.FaultPercentage.denominator:type_name -> clutch.chaos.serverexperimentation.v1.FaultPercentage.DenominatorType
14, // [14:14] is the sub-list for method output_type
14, // [14:14] is the sub-list for method input_type
14, // [14:14] is the sub-list for extension type_name
14, // [14:14] is the sub-list for extension extendee
0, // [0:14] is the sub-list for field type_name
}
func init() { file_chaos_serverexperimentation_v1_serverexperimentation_proto_init() }
......@@ -1113,13 +1204,14 @@ func file_chaos_serverexperimentation_v1_serverexperimentation_proto_init() {
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_chaos_serverexperimentation_v1_serverexperimentation_proto_rawDesc,
NumEnums: 0,
NumEnums: 1,
NumMessages: 11,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_chaos_serverexperimentation_v1_serverexperimentation_proto_goTypes,
DependencyIndexes: file_chaos_serverexperimentation_v1_serverexperimentation_proto_depIdxs,
EnumInfos: file_chaos_serverexperimentation_v1_serverexperimentation_proto_enumTypes,
MessageInfos: file_chaos_serverexperimentation_v1_serverexperimentation_proto_msgTypes,
}.Build()
File_chaos_serverexperimentation_v1_serverexperimentation_proto = out.File
......
backend/api/chaos/serverexperimentation/v1/serverexperimentation.pb.validate.go
+ 4
- 2
View file @ d36d9445
......@@ -1407,10 +1407,10 @@ func (m *FaultPercentage) validate(all bool) error {
var errors []error
if val := m.GetPercentage(); val <= 0 || val > 100 {
if val := m.GetPercentage(); val <= 0 || val > 1000000 {
err := FaultPercentageValidationError{
field: "Percentage",
reason: "value must be inside range (0, 100]",
reason: "value must be inside range (0, 1000000]",
}
if !all {
return err
......@@ -1418,6 +1418,8 @@ func (m *FaultPercentage) validate(all bool) error {
errors = append(errors, err)
}
// no validation rules for Denominator
if len(errors) > 0 {
return FaultPercentageMultiError(errors)
}
......
backend/api/resolver/aws/v1/aws.pb.go
+ 89
- 44
View file @ d36d9445
......@@ -27,8 +27,9 @@ type InstanceID struct {
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *InstanceID) Reset() {
......@@ -77,13 +78,21 @@ func (x *InstanceID) GetRegion() string {
return ""
}
func (x *InstanceID) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
type AutoscalingGroupName struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *AutoscalingGroupName) Reset() {
......@@ -132,13 +141,21 @@ func (x *AutoscalingGroupName) GetRegion() string {
return ""
}
func (x *AutoscalingGroupName) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
type KinesisStreamName struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *KinesisStreamName) Reset() {
......@@ -187,13 +204,21 @@ func (x *KinesisStreamName) GetRegion() string {
return ""
}
func (x *KinesisStreamName) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
type DynamodbTableName struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
Account string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
}
func (x *DynamodbTableName) Reset() {
......@@ -242,6 +267,13 @@ func (x *DynamodbTableName) GetRegion() string {
return ""
}
func (x *DynamodbTableName) GetAccount() string {
if x != nil {
return x.Account
}
return ""
}
var File_resolver_aws_v1_aws_proto protoreflect.FileDescriptor
var file_resolver_aws_v1_aws_proto_rawDesc = []byte{
......@@ -252,48 +284,61 @@ var file_resolver_aws_v1_aws_proto_rawDesc = []byte{
0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x6f, 0x72, 0x2e,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x72, 0x65, 0x73, 0x6f, 0x6c, 0x76, 0x65, 0x72, 0x2f,
0x76, 0x31, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70,
0x72, 0x6f, 0x74, 0x6f, 0x22, 0x82, 0x01, 0x0a, 0x0a, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
0x72, 0x6f, 0x74, 0x6f, 0x22, 0xb9, 0x01, 0x0a, 0x0a, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
0x65, 0x49, 0x44, 0x12, 0x2a, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42,
0x1a, 0xea, 0x9f, 0x1d, 0x16, 0x0a, 0x02, 0x49, 0x44, 0x10, 0x01, 0x1a, 0x0e, 0x0a, 0x0c, 0x69,
0x2d, 0x31, 0x32, 0x33, 0x34, 0x35, 0x36, 0x37, 0x38, 0x39, 0x30, 0x52, 0x02, 0x69, 0x64, 0x12,
0x31, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42,
0x19, 0xea, 0x9f, 0x1d, 0x15, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0x0b, 0x08,
0x01, 0x12, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69,
0x6f, 0x6e, 0x3a, 0x15, 0xea, 0x9f, 0x1d, 0x11, 0x0a, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
0x63, 0x65, 0x20, 0x49, 0x44, 0x1a, 0x02, 0x08, 0x01, 0x22, 0x98, 0x01, 0x0a, 0x14, 0x41, 0x75,
0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x4e, 0x61,
0x6d, 0x65, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
0x42, 0x29, 0xea, 0x9f, 0x1d, 0x25, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x10, 0x01, 0x1a, 0x1b,
0x0a, 0x19, 0x6d, 0x79, 0x2d, 0x61, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67,
0x2d, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x2d, 0x6e, 0x61, 0x6d, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d,
0x65, 0x12, 0x31, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28,
0x09, 0x42, 0x19, 0xea, 0x9f, 0x1d, 0x15, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22,
0x0b, 0x08, 0x01, 0x12, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x06, 0x72, 0x65,
0x67, 0x69, 0x6f, 0x6e, 0x3a, 0x0e, 0xea, 0x9f, 0x1d, 0x0a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
0x1a, 0x02, 0x08, 0x01, 0x22, 0x92, 0x01, 0x0a, 0x11, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73,
0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x04, 0x6e, 0x61,
0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xea, 0x9f, 0x1d, 0x22, 0x0a, 0x04,
0x4e, 0x61, 0x6d, 0x65, 0x10, 0x01, 0x1a, 0x18, 0x0a, 0x16, 0x6d, 0x79, 0x2d, 0x6b, 0x69, 0x6e,
0x65, 0x73, 0x69, 0x73, 0x2d, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2d, 0x6e, 0x61, 0x6d, 0x65,
0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e,
0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x19, 0xea, 0x9f, 0x1d, 0x15, 0x0a, 0x06, 0x52, 0x65,
0x67, 0x69, 0x6f, 0x6e, 0x22, 0x0b, 0x08, 0x01, 0x12, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e,
0x73, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x3a, 0x0e, 0xea, 0x9f, 0x1d, 0x0a, 0x0a,
0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x02, 0x08, 0x01, 0x22, 0x92, 0x01, 0x0a, 0x11, 0x44, 0x79,
0x6e, 0x61, 0x6d, 0x6f, 0x64, 0x62, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12,
0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xea,
0x9f, 0x1d, 0x22, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x10, 0x01, 0x1a, 0x18, 0x0a, 0x16, 0x6d,
0x79, 0x2d, 0x64, 0x79, 0x6e, 0x61, 0x6d, 0x6f, 0x64, 0x62, 0x2d, 0x74, 0x61, 0x62, 0x6c, 0x65,
0x2d, 0x6e, 0x61, 0x6d, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x06, 0x72,
0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x19, 0xea, 0x9f, 0x1d,
0x15, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0x0b, 0x08, 0x01, 0x12, 0x07, 0x72,
0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x3a, 0x0e,
0xea, 0x9f, 0x1d, 0x0a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x02, 0x08, 0x01, 0x42, 0x3a,
0x5a, 0x38, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x79, 0x66,
0x74, 0x2f, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2f, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64,
0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x6c, 0x76, 0x65, 0x72, 0x2f, 0x61, 0x77,
0x73, 0x2f, 0x76, 0x31, 0x3b, 0x61, 0x77, 0x73, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x33,
0x6f, 0x6e, 0x12, 0x35, 0x0a, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20,
0x01, 0x28, 0x09, 0x42, 0x1b, 0xea, 0x9f, 0x1d, 0x17, 0x0a, 0x07, 0x41, 0x63, 0x63, 0x6f, 0x75,
0x6e, 0x74, 0x22, 0x0c, 0x08, 0x01, 0x12, 0x08, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x73,
0x52, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x3a, 0x15, 0xea, 0x9f, 0x1d, 0x11, 0x0a,
0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x20, 0x49, 0x44, 0x1a, 0x02, 0x08, 0x01,
0x22, 0xcf, 0x01, 0x0a, 0x14, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67,
0x47, 0x72, 0x6f, 0x75, 0x70, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x61, 0x6d,
0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x29, 0xea, 0x9f, 0x1d, 0x25, 0x0a, 0x04, 0x4e,
0x61, 0x6d, 0x65, 0x10, 0x01, 0x1a, 0x1b, 0x0a, 0x19, 0x6d, 0x79, 0x2d, 0x61, 0x75, 0x74, 0x6f,
0x73, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x2d, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x2d, 0x6e, 0x61,
0x6d, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69,
0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x19, 0xea, 0x9f, 0x1d, 0x15, 0x0a, 0x06,
0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0x0b, 0x08, 0x01, 0x12, 0x07, 0x72, 0x65, 0x67, 0x69,
0x6f, 0x6e, 0x73, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x35, 0x0a, 0x07, 0x61,
0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x1b, 0xea, 0x9f,
0x1d, 0x17, 0x0a, 0x07, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x0c, 0x08, 0x01, 0x12,
0x08, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x52, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75,
0x6e, 0x74, 0x3a, 0x0e, 0xea, 0x9f, 0x1d, 0x0a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x02,
0x08, 0x01, 0x22, 0xc9, 0x01, 0x0a, 0x11, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x53, 0x74,
0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xea, 0x9f, 0x1d, 0x22, 0x0a, 0x04, 0x4e, 0x61,
0x6d, 0x65, 0x10, 0x01, 0x1a, 0x18, 0x0a, 0x16, 0x6d, 0x79, 0x2d, 0x6b, 0x69, 0x6e, 0x65, 0x73,
0x69, 0x73, 0x2d, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2d, 0x6e, 0x61, 0x6d, 0x65, 0x52, 0x04,
0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02,
0x20, 0x01, 0x28, 0x09, 0x42, 0x19, 0xea, 0x9f, 0x1d, 0x15, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69,
0x6f, 0x6e, 0x22, 0x0b, 0x08, 0x01, 0x12, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x52,
0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x35, 0x0a, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75,
0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x42, 0x1b, 0xea, 0x9f, 0x1d, 0x17, 0x0a, 0x07,
0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x0c, 0x08, 0x01, 0x12, 0x08, 0x61, 0x63, 0x63,
0x6f, 0x75, 0x6e, 0x74, 0x73, 0x52, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x3a, 0x0e,
0xea, 0x9f, 0x1d, 0x0a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x02, 0x08, 0x01, 0x22, 0xc9,
0x01, 0x0a, 0x11, 0x44, 0x79, 0x6e, 0x61, 0x6d, 0x6f, 0x64, 0x62, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x4e, 0x61, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,
0x28, 0x09, 0x42, 0x26, 0xea, 0x9f, 0x1d, 0x22, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x10, 0x01,
0x1a, 0x18, 0x0a, 0x16, 0x6d, 0x79, 0x2d, 0x64, 0x79, 0x6e, 0x61, 0x6d, 0x6f, 0x64, 0x62, 0x2d,
0x74, 0x61, 0x62, 0x6c, 0x65, 0x2d, 0x6e, 0x61, 0x6d, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65,
0x12, 0x31, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
0x42, 0x19, 0xea, 0x9f, 0x1d, 0x15, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0x0b,
0x08, 0x01, 0x12, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x06, 0x72, 0x65, 0x67,
0x69, 0x6f, 0x6e, 0x12, 0x35, 0x0a, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03,
0x20, 0x01, 0x28, 0x09, 0x42, 0x1b, 0xea, 0x9f, 0x1d, 0x17, 0x0a, 0x07, 0x41, 0x63, 0x63, 0x6f,
0x75, 0x6e, 0x74, 0x22, 0x0c, 0x08, 0x01, 0x12, 0x08, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74,
0x73, 0x52, 0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x3a, 0x0e, 0xea, 0x9f, 0x1d, 0x0a,
0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x02, 0x08, 0x01, 0x42, 0x3a, 0x5a, 0x38, 0x67, 0x69,
0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c,
0x75, 0x74, 0x63, 0x68, 0x2f, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69,
0x2f, 0x72, 0x65, 0x73, 0x6f, 0x6c, 0x76, 0x65, 0x72, 0x2f, 0x61, 0x77, 0x73, 0x2f, 0x76, 0x31,
0x3b, 0x61, 0x77, 0x73, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
......
backend/api/resolver/aws/v1/aws.pb.validate.go
+ 8
- 0
View file @ d36d9445
......@@ -61,6 +61,8 @@ func (m *InstanceID) validate(all bool) error {
// no validation rules for Region
// no validation rules for Account
if len(errors) > 0 {
return InstanceIDMultiError(errors)
}
......@@ -163,6 +165,8 @@ func (m *AutoscalingGroupName) validate(all bool) error {
// no validation rules for Region
// no validation rules for Account
if len(errors) > 0 {
return AutoscalingGroupNameMultiError(errors)
}
......@@ -268,6 +272,8 @@ func (m *KinesisStreamName) validate(all bool) error {
// no validation rules for Region
// no validation rules for Account
if len(errors) > 0 {
return KinesisStreamNameMultiError(errors)
}
......@@ -373,6 +379,8 @@ func (m *DynamodbTableName) validate(all bool) error {
// no validation rules for Region
// no validation rules for Account
if len(errors) > 0 {
return DynamodbTableNameMultiError(errors)
}
......
backend/api/timeseries/v1/timeseries.pb.go
+ 16
- 7
View file @ d36d9445
......@@ -91,6 +91,7 @@ type Point struct {
Timestamp isPoint_Timestamp `protobuf_oneof:"timestamp"`
Pb *anypb.Any `protobuf:"bytes,3,opt,name=pb,proto3" json:"pb,omitempty"`
Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
Href string `protobuf:"bytes,5,opt,name=href,proto3" json:"href,omitempty"`
}
func (x *Point) Reset() {
......@@ -160,6 +161,13 @@ func (x *Point) GetDescription() string {
return ""
}
func (x *Point) GetHref() string {
if x != nil {
return x.Href
}
return ""
}
type isPoint_Timestamp interface {
isPoint_Timestamp()
}
......@@ -191,7 +199,7 @@ var file_timeseries_v1_timeseries_proto_rawDesc = []byte{
0x42, 0x04, 0x22, 0x02, 0x20, 0x00, 0x52, 0x0b, 0x73, 0x74, 0x61, 0x72, 0x74, 0x4d, 0x69, 0x6c,
0x6c, 0x69, 0x73, 0x12, 0x26, 0x0a, 0x0a, 0x65, 0x6e, 0x64, 0x5f, 0x6d, 0x69, 0x6c, 0x6c, 0x69,
0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x22, 0x02, 0x20, 0x00,
0x52, 0x09, 0x65, 0x6e, 0x64, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x22, 0xb4, 0x01, 0x0a, 0x05,
0x52, 0x09, 0x65, 0x6e, 0x64, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x22, 0xc8, 0x01, 0x0a, 0x05,
0x50, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x37, 0x0a, 0x05, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x18, 0x01,
0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2e, 0x74, 0x69,
0x6d, 0x65, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x69, 0x6d, 0x65,
......@@ -202,12 +210,13 @@ var file_timeseries_v1_timeseries_proto_rawDesc = []byte{
0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x41, 0x6e, 0x79, 0x52, 0x02, 0x70, 0x62, 0x12, 0x20,
0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20,
0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e,
0x42, 0x10, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x03, 0xf8,
0x42, 0x01, 0x42, 0x3f, 0x5a, 0x3d, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d,
0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68, 0x2f, 0x62, 0x61, 0x63,
0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x65, 0x72,
0x69, 0x65, 0x73, 0x2f, 0x76, 0x31, 0x3b, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x65, 0x72, 0x69, 0x65,
0x73, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x12, 0x12, 0x0a, 0x04, 0x68, 0x72, 0x65, 0x66, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
0x68, 0x72, 0x65, 0x66, 0x42, 0x10, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
0x70, 0x12, 0x03, 0xf8, 0x42, 0x01, 0x42, 0x3f, 0x5a, 0x3d, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62,
0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6c, 0x79, 0x66, 0x74, 0x2f, 0x63, 0x6c, 0x75, 0x74, 0x63, 0x68,
0x2f, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x74, 0x69, 0x6d,
0x65, 0x73, 0x65, 0x72, 0x69, 0x65, 0x73, 0x2f, 0x76, 0x31, 0x3b, 0x74, 0x69, 0x6d, 0x65, 0x73,
0x65, 0x72, 0x69, 0x65, 0x73, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
......
backend/api/timeseries/v1/timeseries.pb.validate.go
+ 2
- 0
View file @ d36d9445
......@@ -207,6 +207,8 @@ func (m *Point) validate(all bool) error {
// no validation rules for Description
// no validation rules for Href
switch m.Timestamp.(type) {
case *Point_Range:
......
backend/gateway/meta/meta_test.go
+ 12
- 16
View file @ d36d9445
......@@ -49,9 +49,10 @@ func TestGetAction(t *testing.T) {
func TestResourceNames(t *testing.T) {
t.Parallel()
account := "default"
instanceID := "i-1234567890abcdef0"
region := "iad"
expectedName := "iad/i-1234567890abcdef0"
expectedName := "default/iad/i-1234567890abcdef0"
typeUrl := "clutch.aws.ec2.v1.Instance"
tests := []struct {
......@@ -68,6 +69,7 @@ func TestResourceNames(t *testing.T) {
message: &ec2v1.TerminateInstanceRequest{
InstanceId: instanceID,
Region: region,
Account: account,
},
names: []*auditv1.Resource{{
TypeUrl: typeUrl,
......@@ -80,6 +82,7 @@ func TestResourceNames(t *testing.T) {
Instance: &ec2v1.Instance{
InstanceId: instanceID,
Region: region,
Account: account,
},
},
names: []*auditv1.Resource{{
......@@ -270,10 +273,11 @@ func TestExtractProtoPatternsValues(t *testing.T) {
{
id: "ec2 instance",
pb: &ec2v1.Instance{
Account: "default",
Region: "us-east-1",
InstanceId: "i-000000000",
},
expect: "us-east-1/i-000000000",
expect: "default/us-east-1/i-000000000",
shouldError: false,
},
{
......@@ -313,33 +317,25 @@ func TestPatternValueMapping(t *testing.T) {
{
id: "aws asg",
pb: &ec2v1.AutoscalingGroup{},
search: "us-east-1/my-asg-name",
search: "default/us-east-1/my-asg-name",
result: map[string]string{
"region": "us-east-1",
"name": "my-asg-name",
"account": "default",
"region": "us-east-1",
"name": "my-asg-name",
},
ok: true,
},
{
id: "aws instance",
pb: &ec2v1.Instance{},
search: "us-east-1/i-0000000",
search: "default/us-east-1/i-0000000",
result: map[string]string{
"account": "default",
"region": "us-east-1",
"instance_id": "i-0000000",
},
ok: true,
},
{
id: "test for partial match",
pb: &ec2v1.Instance{},
search: "us-east-1/i-0000000/meow",
result: map[string]string{
"region": "us-east-1/i-0000000",
"instance_id": "meow",
},
ok: true,
},
{
id: "k8s deployment",
pb: &k8sapiv1.Deployment{},
......
backend/gateway/mux/mux.go
+ 1
- 0
View file @ d36d9445
......@@ -125,6 +125,7 @@ func (a *assetHandler) assetProviderHandler(ctx context.Context, urlPath string)
return awsClient.S3StreamingGet(
ctx,
awsClient.GetPrimaryAccountAlias(),
a.assetCfg.GetS3().Region,
a.assetCfg.GetS3().Bucket,
path.Join(a.assetCfg.GetS3().Key, strings.TrimPrefix(urlPath, "/static")),
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

免费DevSecOps平台，让您的项目体验完整的DevSecOps流程，让项目更安全