From c7bbcba5def12143caeb5667ab42bc5a66bf709a Mon Sep 17 00:00:00 2001 From: Superblocks Admin Date: Mon, 9 Sep 2024 16:00:13 +0000 Subject: [PATCH] syncing up to 4a6dea824a73cfb6173d305348ad8d408d596b5b Co-authored-by: Joey Greco <57115019+joeyagreco@users.noreply.github.com> --- types/api/api/v1/service.swagger.json | 126 +++---- types/api/security/v1/service.swagger.json | 126 +++---- types/gen/go/plugins/kinesis/v1/plugin.pb.go | 319 +++++++++--------- .../plugins/kinesis/v1/plugin.pb.validate.go | 138 ++++---- .../gen/js/plugins/kinesis/v1/plugin_pb.d.ts | 68 ++-- types/gen/js/plugins/kinesis/v1/plugin_pb.js | 264 +++++++-------- .../plugins/kinesis/v1/plugin_pb2.py | 24 +- types/proto/plugins/kinesis/v1/plugin.proto | 8 +- workers/javascript/package-lock.json | 1 + .../packages/plugins/kinesis/src/index.ts | 4 +- .../plugins/kinesis/src/utils.test.ts | 8 +- .../packages/plugins/kinesis/src/utils.ts | 6 +- .../types/src/plugins/kinesis/v1/plugin_pb.ts | 64 ++-- 13 files changed, 582 insertions(+), 574 deletions(-) diff --git a/types/api/api/v1/service.swagger.json b/types/api/api/v1/service.swagger.json index e5c6b94d..83928605 100644 --- a/types/api/api/v1/service.swagger.json +++ b/types/api/api/v1/service.swagger.json @@ -1769,6 +1769,14 @@ } } }, + "PluginGet": { + "type": "object", + "properties": { + "key": { + "type": "string" + } + } + }, "PluginHdel": { "type": "object", "properties": { @@ -1879,6 +1887,58 @@ } } }, + "PluginKinesisGet": { + "type": "object", + "properties": { + "shardId": { + "type": "string" + }, + "shardIteratorType": { + "$ref": "#/definitions/PluginShardIteratorType" + }, + "limit": { + "type": "integer", + "format": "int32" + }, + "pollingCooldownMs": { + "type": "integer", + "format": "int32", + "title": "not required by kinesis, but something we want to allow users to configure\nthis is the amount of time in milliseconds between asking kinesis to get records when polling in a loop" + }, + "startingSequenceNumber": { + "type": "string", + "title": "these 2 are required depending on the shard iterator type selected" + }, + "timestamp": { + "type": "string" + }, + "streamName": { + "type": "string" + }, + "streamArn": { + "type": "string" + } + }, + "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html\nwe will need to get a shard iterator first\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html" + }, + "PluginKinesisPut": { + "type": "object", + "properties": { + "data": { + "type": "string" + }, + "partitionKey": { + "type": "string" + }, + "streamName": { + "type": "string" + }, + "streamArn": { + "type": "string" + } + }, + "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html" + }, "PluginLindex": { "type": "object", "properties": { @@ -2098,24 +2158,6 @@ } } }, - "PluginPut": { - "type": "object", - "properties": { - "data": { - "type": "string" - }, - "partitionKey": { - "type": "string" - }, - "streamName": { - "type": "string" - }, - "streamArn": { - "type": "string" - } - }, - "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html" - }, "PluginQuery": { "type": "object", "properties": { @@ -2322,7 +2364,7 @@ "type": "object", "properties": { "get": { - "$ref": "#/definitions/pluginsredisv1PluginGet" + "$ref": "#/definitions/PluginGet" }, "set": { "$ref": "#/definitions/PluginSet" @@ -3689,50 +3731,16 @@ "$ref": "#/definitions/PluginKinesisConnection" }, "put": { - "$ref": "#/definitions/PluginPut" + "$ref": "#/definitions/PluginKinesisPut" }, "get": { - "$ref": "#/definitions/pluginskinesisv1PluginGet" + "$ref": "#/definitions/PluginKinesisGet" }, "dynamicWorkflowConfiguration": { "$ref": "#/definitions/v1DynamicWorkflowConfiguration" } } }, - "pluginskinesisv1PluginGet": { - "type": "object", - "properties": { - "shardId": { - "type": "string" - }, - "shardIteratorType": { - "$ref": "#/definitions/PluginShardIteratorType" - }, - "limit": { - "type": "integer", - "format": "int32" - }, - "pollingCooldownMs": { - "type": "integer", - "format": "int32", - "title": "not required by kinesis, but something we want to allow users to configure\nthis is the amount of time in milliseconds between asking kinesis to get records when polling in a loop" - }, - "startingSequenceNumber": { - "type": "string", - "title": "these 2 are required depending on the shard iterator type selected" - }, - "timestamp": { - "type": "string" - }, - "streamName": { - "type": "string" - }, - "streamArn": { - "type": "string" - } - }, - "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html\nwe will need to get a shard iterator first\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html" - }, "pluginsmariadbv1MappedColumns": { "type": "object", "properties": { @@ -4341,14 +4349,6 @@ }, "title": "NOTE: (joey) this does not have to be a separate message right now\n1. this follows the \"connection\" pattern\n2. this lets us easily add shared connection fields in the future" }, - "pluginsredisv1PluginGet": { - "type": "object", - "properties": { - "key": { - "type": "string" - } - } - }, "pluginsredshiftv1MappedColumns": { "type": "object", "properties": { diff --git a/types/api/security/v1/service.swagger.json b/types/api/security/v1/service.swagger.json index 95b54abc..22268852 100644 --- a/types/api/security/v1/service.swagger.json +++ b/types/api/security/v1/service.swagger.json @@ -833,6 +833,14 @@ } } }, + "PluginGet": { + "type": "object", + "properties": { + "key": { + "type": "string" + } + } + }, "PluginHdel": { "type": "object", "properties": { @@ -943,6 +951,58 @@ } } }, + "PluginKinesisGet": { + "type": "object", + "properties": { + "shardId": { + "type": "string" + }, + "shardIteratorType": { + "$ref": "#/definitions/PluginShardIteratorType" + }, + "limit": { + "type": "integer", + "format": "int32" + }, + "pollingCooldownMs": { + "type": "integer", + "format": "int32", + "title": "not required by kinesis, but something we want to allow users to configure\nthis is the amount of time in milliseconds between asking kinesis to get records when polling in a loop" + }, + "startingSequenceNumber": { + "type": "string", + "title": "these 2 are required depending on the shard iterator type selected" + }, + "timestamp": { + "type": "string" + }, + "streamName": { + "type": "string" + }, + "streamArn": { + "type": "string" + } + }, + "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html\nwe will need to get a shard iterator first\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html" + }, + "PluginKinesisPut": { + "type": "object", + "properties": { + "data": { + "type": "string" + }, + "partitionKey": { + "type": "string" + }, + "streamName": { + "type": "string" + }, + "streamArn": { + "type": "string" + } + }, + "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html" + }, "PluginLindex": { "type": "object", "properties": { @@ -1162,24 +1222,6 @@ } } }, - "PluginPut": { - "type": "object", - "properties": { - "data": { - "type": "string" - }, - "partitionKey": { - "type": "string" - }, - "streamName": { - "type": "string" - }, - "streamArn": { - "type": "string" - } - }, - "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html" - }, "PluginQuery": { "type": "object", "properties": { @@ -1386,7 +1428,7 @@ "type": "object", "properties": { "get": { - "$ref": "#/definitions/pluginsredisv1PluginGet" + "$ref": "#/definitions/PluginGet" }, "set": { "$ref": "#/definitions/PluginSet" @@ -2673,50 +2715,16 @@ "$ref": "#/definitions/PluginKinesisConnection" }, "put": { - "$ref": "#/definitions/PluginPut" + "$ref": "#/definitions/PluginKinesisPut" }, "get": { - "$ref": "#/definitions/pluginskinesisv1PluginGet" + "$ref": "#/definitions/PluginKinesisGet" }, "dynamicWorkflowConfiguration": { "$ref": "#/definitions/v1DynamicWorkflowConfiguration" } } }, - "pluginskinesisv1PluginGet": { - "type": "object", - "properties": { - "shardId": { - "type": "string" - }, - "shardIteratorType": { - "$ref": "#/definitions/PluginShardIteratorType" - }, - "limit": { - "type": "integer", - "format": "int32" - }, - "pollingCooldownMs": { - "type": "integer", - "format": "int32", - "title": "not required by kinesis, but something we want to allow users to configure\nthis is the amount of time in milliseconds between asking kinesis to get records when polling in a loop" - }, - "startingSequenceNumber": { - "type": "string", - "title": "these 2 are required depending on the shard iterator type selected" - }, - "timestamp": { - "type": "string" - }, - "streamName": { - "type": "string" - }, - "streamArn": { - "type": "string" - } - }, - "title": "https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html\nwe will need to get a shard iterator first\nhttps://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html" - }, "pluginsmariadbv1MappedColumns": { "type": "object", "properties": { @@ -3325,14 +3333,6 @@ }, "title": "NOTE: (joey) this does not have to be a separate message right now\n1. this follows the \"connection\" pattern\n2. this lets us easily add shared connection fields in the future" }, - "pluginsredisv1PluginGet": { - "type": "object", - "properties": { - "key": { - "type": "string" - } - } - }, "pluginsredshiftv1MappedColumns": { "type": "object", "properties": { diff --git a/types/gen/go/plugins/kinesis/v1/plugin.pb.go b/types/gen/go/plugins/kinesis/v1/plugin.pb.go index 9fa0e906..3d4dc952 100644 --- a/types/gen/go/plugins/kinesis/v1/plugin.pb.go +++ b/types/gen/go/plugins/kinesis/v1/plugin.pb.go @@ -89,8 +89,8 @@ type Plugin struct { Connection *Plugin_KinesisConnection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` // Types that are assignable to Operation: // - // *Plugin_Put_ - // *Plugin_Get_ + // *Plugin_Put + // *Plugin_Get Operation isPlugin_Operation `protobuf_oneof:"operation"` DynamicWorkflowConfiguration *v1.DynamicWorkflowConfiguration `protobuf:"bytes,5,opt,name=dynamic_workflow_configuration,json=dynamicWorkflowConfiguration,proto3,oneof" json:"dynamic_workflow_configuration,omitempty"` } @@ -148,15 +148,15 @@ func (m *Plugin) GetOperation() isPlugin_Operation { return nil } -func (x *Plugin) GetPut() *Plugin_Put { - if x, ok := x.GetOperation().(*Plugin_Put_); ok { +func (x *Plugin) GetPut() *Plugin_KinesisPut { + if x, ok := x.GetOperation().(*Plugin_Put); ok { return x.Put } return nil } -func (x *Plugin) GetGet() *Plugin_Get { - if x, ok := x.GetOperation().(*Plugin_Get_); ok { +func (x *Plugin) GetGet() *Plugin_KinesisGet { + if x, ok := x.GetOperation().(*Plugin_Get); ok { return x.Get } return nil @@ -173,17 +173,17 @@ type isPlugin_Operation interface { isPlugin_Operation() } -type Plugin_Put_ struct { - Put *Plugin_Put `protobuf:"bytes,3,opt,name=put,proto3,oneof"` +type Plugin_Put struct { + Put *Plugin_KinesisPut `protobuf:"bytes,3,opt,name=put,proto3,oneof"` } -type Plugin_Get_ struct { - Get *Plugin_Get `protobuf:"bytes,4,opt,name=get,proto3,oneof"` +type Plugin_Get struct { + Get *Plugin_KinesisGet `protobuf:"bytes,4,opt,name=get,proto3,oneof"` } -func (*Plugin_Put_) isPlugin_Operation() {} +func (*Plugin_Put) isPlugin_Operation() {} -func (*Plugin_Get_) isPlugin_Operation() {} +func (*Plugin_Get) isPlugin_Operation() {} type Metadata struct { state protoimpl.MessageState @@ -281,7 +281,7 @@ func (x *Plugin_KinesisConnection) GetAwsConfig() *v1.AWSConfig { // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html -type Plugin_Put struct { +type Plugin_KinesisPut struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields @@ -290,13 +290,13 @@ type Plugin_Put struct { PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"` // Types that are assignable to StreamIdentifier: // - // *Plugin_Put_StreamName - // *Plugin_Put_StreamArn - StreamIdentifier isPlugin_Put_StreamIdentifier `protobuf_oneof:"stream_identifier"` + // *Plugin_KinesisPut_StreamName + // *Plugin_KinesisPut_StreamArn + StreamIdentifier isPlugin_KinesisPut_StreamIdentifier `protobuf_oneof:"stream_identifier"` } -func (x *Plugin_Put) Reset() { - *x = Plugin_Put{} +func (x *Plugin_KinesisPut) Reset() { + *x = Plugin_KinesisPut{} if protoimpl.UnsafeEnabled { mi := &file_plugins_kinesis_v1_plugin_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -304,13 +304,13 @@ func (x *Plugin_Put) Reset() { } } -func (x *Plugin_Put) String() string { +func (x *Plugin_KinesisPut) String() string { return protoimpl.X.MessageStringOf(x) } -func (*Plugin_Put) ProtoMessage() {} +func (*Plugin_KinesisPut) ProtoMessage() {} -func (x *Plugin_Put) ProtoReflect() protoreflect.Message { +func (x *Plugin_KinesisPut) ProtoReflect() protoreflect.Message { mi := &file_plugins_kinesis_v1_plugin_proto_msgTypes[3] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -322,66 +322,66 @@ func (x *Plugin_Put) ProtoReflect() protoreflect.Message { return mi.MessageOf(x) } -// Deprecated: Use Plugin_Put.ProtoReflect.Descriptor instead. -func (*Plugin_Put) Descriptor() ([]byte, []int) { +// Deprecated: Use Plugin_KinesisPut.ProtoReflect.Descriptor instead. +func (*Plugin_KinesisPut) Descriptor() ([]byte, []int) { return file_plugins_kinesis_v1_plugin_proto_rawDescGZIP(), []int{0, 1} } -func (x *Plugin_Put) GetData() string { +func (x *Plugin_KinesisPut) GetData() string { if x != nil { return x.Data } return "" } -func (x *Plugin_Put) GetPartitionKey() string { +func (x *Plugin_KinesisPut) GetPartitionKey() string { if x != nil { return x.PartitionKey } return "" } -func (m *Plugin_Put) GetStreamIdentifier() isPlugin_Put_StreamIdentifier { +func (m *Plugin_KinesisPut) GetStreamIdentifier() isPlugin_KinesisPut_StreamIdentifier { if m != nil { return m.StreamIdentifier } return nil } -func (x *Plugin_Put) GetStreamName() string { - if x, ok := x.GetStreamIdentifier().(*Plugin_Put_StreamName); ok { +func (x *Plugin_KinesisPut) GetStreamName() string { + if x, ok := x.GetStreamIdentifier().(*Plugin_KinesisPut_StreamName); ok { return x.StreamName } return "" } -func (x *Plugin_Put) GetStreamArn() string { - if x, ok := x.GetStreamIdentifier().(*Plugin_Put_StreamArn); ok { +func (x *Plugin_KinesisPut) GetStreamArn() string { + if x, ok := x.GetStreamIdentifier().(*Plugin_KinesisPut_StreamArn); ok { return x.StreamArn } return "" } -type isPlugin_Put_StreamIdentifier interface { - isPlugin_Put_StreamIdentifier() +type isPlugin_KinesisPut_StreamIdentifier interface { + isPlugin_KinesisPut_StreamIdentifier() } -type Plugin_Put_StreamName struct { +type Plugin_KinesisPut_StreamName struct { StreamName string `protobuf:"bytes,3,opt,name=stream_name,json=streamName,proto3,oneof"` } -type Plugin_Put_StreamArn struct { +type Plugin_KinesisPut_StreamArn struct { StreamArn string `protobuf:"bytes,4,opt,name=stream_arn,json=streamArn,proto3,oneof"` } -func (*Plugin_Put_StreamName) isPlugin_Put_StreamIdentifier() {} +func (*Plugin_KinesisPut_StreamName) isPlugin_KinesisPut_StreamIdentifier() {} -func (*Plugin_Put_StreamArn) isPlugin_Put_StreamIdentifier() {} +func (*Plugin_KinesisPut_StreamArn) isPlugin_KinesisPut_StreamIdentifier() {} // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html // we will need to get a shard iterator first // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html -type Plugin_Get struct { +type Plugin_KinesisGet struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields @@ -397,13 +397,13 @@ type Plugin_Get struct { Timestamp *string `protobuf:"bytes,7,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"` // Types that are assignable to StreamIdentifier: // - // *Plugin_Get_StreamName - // *Plugin_Get_StreamArn - StreamIdentifier isPlugin_Get_StreamIdentifier `protobuf_oneof:"stream_identifier"` + // *Plugin_KinesisGet_StreamName + // *Plugin_KinesisGet_StreamArn + StreamIdentifier isPlugin_KinesisGet_StreamIdentifier `protobuf_oneof:"stream_identifier"` } -func (x *Plugin_Get) Reset() { - *x = Plugin_Get{} +func (x *Plugin_KinesisGet) Reset() { + *x = Plugin_KinesisGet{} if protoimpl.UnsafeEnabled { mi := &file_plugins_kinesis_v1_plugin_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -411,13 +411,13 @@ func (x *Plugin_Get) Reset() { } } -func (x *Plugin_Get) String() string { +func (x *Plugin_KinesisGet) String() string { return protoimpl.X.MessageStringOf(x) } -func (*Plugin_Get) ProtoMessage() {} +func (*Plugin_KinesisGet) ProtoMessage() {} -func (x *Plugin_Get) ProtoReflect() protoreflect.Message { +func (x *Plugin_KinesisGet) ProtoReflect() protoreflect.Message { mi := &file_plugins_kinesis_v1_plugin_proto_msgTypes[4] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -429,89 +429,89 @@ func (x *Plugin_Get) ProtoReflect() protoreflect.Message { return mi.MessageOf(x) } -// Deprecated: Use Plugin_Get.ProtoReflect.Descriptor instead. -func (*Plugin_Get) Descriptor() ([]byte, []int) { +// Deprecated: Use Plugin_KinesisGet.ProtoReflect.Descriptor instead. +func (*Plugin_KinesisGet) Descriptor() ([]byte, []int) { return file_plugins_kinesis_v1_plugin_proto_rawDescGZIP(), []int{0, 2} } -func (x *Plugin_Get) GetShardId() string { +func (x *Plugin_KinesisGet) GetShardId() string { if x != nil { return x.ShardId } return "" } -func (x *Plugin_Get) GetShardIteratorType() Plugin_ShardIteratorType { +func (x *Plugin_KinesisGet) GetShardIteratorType() Plugin_ShardIteratorType { if x != nil { return x.ShardIteratorType } return Plugin_SHARD_ITERATOR_TYPE_UNSPECIFIED } -func (x *Plugin_Get) GetLimit() int32 { +func (x *Plugin_KinesisGet) GetLimit() int32 { if x != nil { return x.Limit } return 0 } -func (x *Plugin_Get) GetPollingCooldownMs() int32 { +func (x *Plugin_KinesisGet) GetPollingCooldownMs() int32 { if x != nil { return x.PollingCooldownMs } return 0 } -func (x *Plugin_Get) GetStartingSequenceNumber() string { +func (x *Plugin_KinesisGet) GetStartingSequenceNumber() string { if x != nil && x.StartingSequenceNumber != nil { return *x.StartingSequenceNumber } return "" } -func (x *Plugin_Get) GetTimestamp() string { +func (x *Plugin_KinesisGet) GetTimestamp() string { if x != nil && x.Timestamp != nil { return *x.Timestamp } return "" } -func (m *Plugin_Get) GetStreamIdentifier() isPlugin_Get_StreamIdentifier { +func (m *Plugin_KinesisGet) GetStreamIdentifier() isPlugin_KinesisGet_StreamIdentifier { if m != nil { return m.StreamIdentifier } return nil } -func (x *Plugin_Get) GetStreamName() string { - if x, ok := x.GetStreamIdentifier().(*Plugin_Get_StreamName); ok { +func (x *Plugin_KinesisGet) GetStreamName() string { + if x, ok := x.GetStreamIdentifier().(*Plugin_KinesisGet_StreamName); ok { return x.StreamName } return "" } -func (x *Plugin_Get) GetStreamArn() string { - if x, ok := x.GetStreamIdentifier().(*Plugin_Get_StreamArn); ok { +func (x *Plugin_KinesisGet) GetStreamArn() string { + if x, ok := x.GetStreamIdentifier().(*Plugin_KinesisGet_StreamArn); ok { return x.StreamArn } return "" } -type isPlugin_Get_StreamIdentifier interface { - isPlugin_Get_StreamIdentifier() +type isPlugin_KinesisGet_StreamIdentifier interface { + isPlugin_KinesisGet_StreamIdentifier() } -type Plugin_Get_StreamName struct { +type Plugin_KinesisGet_StreamName struct { StreamName string `protobuf:"bytes,8,opt,name=stream_name,json=streamName,proto3,oneof"` } -type Plugin_Get_StreamArn struct { +type Plugin_KinesisGet_StreamArn struct { StreamArn string `protobuf:"bytes,9,opt,name=stream_arn,json=streamArn,proto3,oneof"` } -func (*Plugin_Get_StreamName) isPlugin_Get_StreamIdentifier() {} +func (*Plugin_KinesisGet_StreamName) isPlugin_KinesisGet_StreamIdentifier() {} -func (*Plugin_Get_StreamArn) isPlugin_Get_StreamIdentifier() {} +func (*Plugin_KinesisGet_StreamArn) isPlugin_KinesisGet_StreamIdentifier() {} var File_plugins_kinesis_v1_plugin_proto protoreflect.FileDescriptor @@ -521,97 +521,98 @@ var file_plugins_kinesis_v1_plugin_proto_rawDesc = []byte{ 0x6f, 0x12, 0x12, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x1a, 0x1e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2e, - 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa7, 0x0a, 0x0a, 0x06, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, + 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xc3, 0x0a, 0x0a, 0x06, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x88, 0x01, 0x01, 0x12, 0x4c, 0x0a, 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2e, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x63, 0x6f, 0x6e, - 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x03, 0x70, 0x75, 0x74, 0x18, 0x03, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x6b, + 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x39, 0x0a, 0x03, 0x70, 0x75, 0x74, 0x18, 0x03, + 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, - 0x2e, 0x50, 0x75, 0x74, 0x48, 0x00, 0x52, 0x03, 0x70, 0x75, 0x74, 0x12, 0x32, 0x0a, 0x03, 0x67, - 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, - 0x6e, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c, - 0x75, 0x67, 0x69, 0x6e, 0x2e, 0x47, 0x65, 0x74, 0x48, 0x00, 0x52, 0x03, 0x67, 0x65, 0x74, 0x12, - 0x7a, 0x0a, 0x1e, 0x64, 0x79, 0x6e, 0x61, 0x6d, 0x69, 0x63, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, - 0x6c, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, - 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, - 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x79, 0x6e, 0x61, - 0x6d, 0x69, 0x63, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x43, 0x6f, 0x6e, 0x66, 0x69, - 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x48, 0x02, 0x52, 0x1c, 0x64, 0x79, 0x6e, 0x61, - 0x6d, 0x69, 0x63, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x43, 0x6f, 0x6e, 0x66, 0x69, - 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x1a, 0x50, 0x0a, 0x11, 0x4b, - 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, - 0x12, 0x3b, 0x0a, 0x0a, 0x61, 0x77, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x63, - 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x57, 0x53, 0x43, 0x6f, 0x6e, 0x66, - 0x69, 0x67, 0x52, 0x09, 0x61, 0x77, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x1a, 0x97, 0x01, - 0x0a, 0x03, 0x50, 0x75, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x23, 0x0a, 0x0d, 0x70, 0x61, 0x72, - 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x0c, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x4b, 0x65, 0x79, 0x12, 0x21, - 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, - 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d, - 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x61, 0x72, 0x6e, 0x18, - 0x04, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x09, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, - 0x72, 0x6e, 0x42, 0x13, 0x0a, 0x11, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x65, - 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x1a, 0xaa, 0x03, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, - 0x19, 0x0a, 0x08, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x07, 0x73, 0x68, 0x61, 0x72, 0x64, 0x49, 0x64, 0x12, 0x5c, 0x0a, 0x13, 0x73, 0x68, - 0x61, 0x72, 0x64, 0x5f, 0x69, 0x74, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x5f, 0x74, 0x79, 0x70, - 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, - 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c, 0x75, - 0x67, 0x69, 0x6e, 0x2e, 0x53, 0x68, 0x61, 0x72, 0x64, 0x49, 0x74, 0x65, 0x72, 0x61, 0x74, 0x6f, - 0x72, 0x54, 0x79, 0x70, 0x65, 0x52, 0x11, 0x73, 0x68, 0x61, 0x72, 0x64, 0x49, 0x74, 0x65, 0x72, - 0x61, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, - 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x2e, - 0x0a, 0x13, 0x70, 0x6f, 0x6c, 0x6c, 0x69, 0x6e, 0x67, 0x5f, 0x63, 0x6f, 0x6f, 0x6c, 0x64, 0x6f, - 0x77, 0x6e, 0x5f, 0x6d, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x11, 0x70, 0x6f, 0x6c, - 0x6c, 0x69, 0x6e, 0x67, 0x43, 0x6f, 0x6f, 0x6c, 0x64, 0x6f, 0x77, 0x6e, 0x4d, 0x73, 0x12, 0x3d, - 0x0a, 0x18, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x65, 0x71, 0x75, 0x65, - 0x6e, 0x63, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, - 0x48, 0x01, 0x52, 0x16, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x71, 0x75, - 0x65, 0x6e, 0x63, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x88, 0x01, 0x01, 0x12, 0x21, 0x0a, - 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, - 0x48, 0x02, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x88, 0x01, 0x01, - 0x12, 0x21, 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, - 0x08, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, - 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x61, 0x72, - 0x6e, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x09, 0x73, 0x74, 0x72, 0x65, 0x61, - 0x6d, 0x41, 0x72, 0x6e, 0x42, 0x13, 0x0a, 0x11, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, - 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x42, 0x1b, 0x0a, 0x19, 0x5f, 0x73, 0x74, + 0x2e, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x50, 0x75, 0x74, 0x48, 0x00, 0x52, 0x03, 0x70, + 0x75, 0x74, 0x12, 0x39, 0x0a, 0x03, 0x67, 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, + 0x25, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x6b, 0x69, 0x6e, 0x65, 0x73, 0x69, + 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2e, 0x4b, 0x69, 0x6e, 0x65, + 0x73, 0x69, 0x73, 0x47, 0x65, 0x74, 0x48, 0x00, 0x52, 0x03, 0x67, 0x65, 0x74, 0x12, 0x7a, 0x0a, + 0x1e, 0x64, 0x79, 0x6e, 0x61, 0x6d, 0x69, 0x63, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, + 0x77, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, + 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, + 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x79, 0x6e, 0x61, 0x6d, 0x69, + 0x63, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x75, + 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x48, 0x02, 0x52, 0x1c, 0x64, 0x79, 0x6e, 0x61, 0x6d, 0x69, + 0x63, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x75, + 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x88, 0x01, 0x01, 0x1a, 0x50, 0x0a, 0x11, 0x4b, 0x69, 0x6e, + 0x65, 0x73, 0x69, 0x73, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3b, + 0x0a, 0x0a, 0x61, 0x77, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x63, 0x6f, 0x6d, + 0x6d, 0x6f, 0x6e, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x57, 0x53, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, + 0x52, 0x09, 0x61, 0x77, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x1a, 0x9e, 0x01, 0x0a, 0x0a, + 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x50, 0x75, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, + 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x23, + 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6b, 0x65, 0x79, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, + 0x4b, 0x65, 0x79, 0x12, 0x21, 0x0a, 0x0b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, + 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, + 0x61, 0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, + 0x5f, 0x61, 0x72, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x09, 0x73, 0x74, + 0x72, 0x65, 0x61, 0x6d, 0x41, 0x72, 0x6e, 0x42, 0x13, 0x0a, 0x11, 0x73, 0x74, 0x72, 0x65, 0x61, + 0x6d, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x1a, 0xb1, 0x03, 0x0a, + 0x0a, 0x4b, 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x47, 0x65, 0x74, 0x12, 0x19, 0x0a, 0x08, 0x73, + 0x68, 0x61, 0x72, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, + 0x68, 0x61, 0x72, 0x64, 0x49, 0x64, 0x12, 0x5c, 0x0a, 0x13, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, + 0x69, 0x74, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, + 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2e, 0x6b, 0x69, + 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x2e, + 0x53, 0x68, 0x61, 0x72, 0x64, 0x49, 0x74, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, + 0x65, 0x52, 0x11, 0x73, 0x68, 0x61, 0x72, 0x64, 0x49, 0x74, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, + 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x04, 0x20, + 0x01, 0x28, 0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x2e, 0x0a, 0x13, 0x70, 0x6f, + 0x6c, 0x6c, 0x69, 0x6e, 0x67, 0x5f, 0x63, 0x6f, 0x6f, 0x6c, 0x64, 0x6f, 0x77, 0x6e, 0x5f, 0x6d, + 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x11, 0x70, 0x6f, 0x6c, 0x6c, 0x69, 0x6e, 0x67, + 0x43, 0x6f, 0x6f, 0x6c, 0x64, 0x6f, 0x77, 0x6e, 0x4d, 0x73, 0x12, 0x3d, 0x0a, 0x18, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x5f, - 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x42, 0x0c, 0x0a, 0x0a, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x73, - 0x74, 0x61, 0x6d, 0x70, 0x22, 0xff, 0x01, 0x0a, 0x11, 0x53, 0x68, 0x61, 0x72, 0x64, 0x49, 0x74, - 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x23, 0x0a, 0x1f, 0x53, 0x48, - 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, - 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, - 0x2a, 0x0a, 0x26, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, - 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x41, 0x54, 0x5f, 0x53, 0x45, 0x51, 0x55, 0x45, 0x4e, - 0x43, 0x45, 0x5f, 0x4e, 0x55, 0x4d, 0x42, 0x45, 0x52, 0x10, 0x01, 0x12, 0x2d, 0x0a, 0x29, 0x53, + 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x01, 0x52, 0x16, + 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x53, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, + 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x88, 0x01, 0x01, 0x12, 0x21, 0x0a, 0x09, 0x74, 0x69, 0x6d, + 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x48, 0x02, 0x52, 0x09, + 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x88, 0x01, 0x01, 0x12, 0x21, 0x0a, 0x0b, + 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, + 0x09, 0x48, 0x00, 0x52, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x1f, 0x0a, 0x0a, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x61, 0x72, 0x6e, 0x18, 0x09, 0x20, + 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x09, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x72, 0x6e, + 0x42, 0x13, 0x0a, 0x11, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, + 0x69, 0x66, 0x69, 0x65, 0x72, 0x42, 0x1b, 0x0a, 0x19, 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, + 0x6e, 0x67, 0x5f, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, + 0x65, 0x72, 0x42, 0x0c, 0x0a, 0x0a, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, + 0x22, 0xff, 0x01, 0x0a, 0x11, 0x53, 0x68, 0x61, 0x72, 0x64, 0x49, 0x74, 0x65, 0x72, 0x61, 0x74, + 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x23, 0x0a, 0x1f, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, + 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, + 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x2a, 0x0a, 0x26, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, - 0x50, 0x45, 0x5f, 0x41, 0x46, 0x54, 0x45, 0x52, 0x5f, 0x53, 0x45, 0x51, 0x55, 0x45, 0x4e, 0x43, - 0x45, 0x5f, 0x4e, 0x55, 0x4d, 0x42, 0x45, 0x52, 0x10, 0x02, 0x12, 0x24, 0x0a, 0x20, 0x53, 0x48, - 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, - 0x45, 0x5f, 0x41, 0x54, 0x5f, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x10, 0x03, - 0x12, 0x24, 0x0a, 0x20, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, - 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x54, 0x52, 0x49, 0x4d, 0x5f, 0x48, 0x4f, 0x52, - 0x49, 0x5a, 0x4f, 0x4e, 0x10, 0x04, 0x12, 0x1e, 0x0a, 0x1a, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, - 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x4c, 0x41, - 0x54, 0x45, 0x53, 0x54, 0x10, 0x05, 0x42, 0x0b, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, - 0x69, 0x6f, 0x6e, 0x42, 0x07, 0x0a, 0x05, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x42, 0x21, 0x0a, 0x1f, - 0x5f, 0x64, 0x79, 0x6e, 0x61, 0x6d, 0x69, 0x63, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, - 0x77, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, - 0x24, 0x0a, 0x08, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x18, 0x0a, 0x07, 0x73, - 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x73, 0x74, - 0x72, 0x65, 0x61, 0x6d, 0x73, 0x42, 0x42, 0x5a, 0x40, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, - 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x75, 0x70, 0x65, 0x72, 0x62, 0x6c, 0x6f, 0x63, 0x6b, 0x73, 0x74, - 0x65, 0x61, 0x6d, 0x2f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, - 0x67, 0x65, 0x6e, 0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2f, 0x6b, - 0x69, 0x6e, 0x65, 0x73, 0x69, 0x73, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x33, + 0x50, 0x45, 0x5f, 0x41, 0x54, 0x5f, 0x53, 0x45, 0x51, 0x55, 0x45, 0x4e, 0x43, 0x45, 0x5f, 0x4e, + 0x55, 0x4d, 0x42, 0x45, 0x52, 0x10, 0x01, 0x12, 0x2d, 0x0a, 0x29, 0x53, 0x48, 0x41, 0x52, 0x44, + 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x41, + 0x46, 0x54, 0x45, 0x52, 0x5f, 0x53, 0x45, 0x51, 0x55, 0x45, 0x4e, 0x43, 0x45, 0x5f, 0x4e, 0x55, + 0x4d, 0x42, 0x45, 0x52, 0x10, 0x02, 0x12, 0x24, 0x0a, 0x20, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, + 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x41, 0x54, + 0x5f, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x10, 0x03, 0x12, 0x24, 0x0a, 0x20, + 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, + 0x59, 0x50, 0x45, 0x5f, 0x54, 0x52, 0x49, 0x4d, 0x5f, 0x48, 0x4f, 0x52, 0x49, 0x5a, 0x4f, 0x4e, + 0x10, 0x04, 0x12, 0x1e, 0x0a, 0x1a, 0x53, 0x48, 0x41, 0x52, 0x44, 0x5f, 0x49, 0x54, 0x45, 0x52, + 0x41, 0x54, 0x4f, 0x52, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x4c, 0x41, 0x54, 0x45, 0x53, 0x54, + 0x10, 0x05, 0x42, 0x0b, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, + 0x07, 0x0a, 0x05, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x42, 0x21, 0x0a, 0x1f, 0x5f, 0x64, 0x79, 0x6e, + 0x61, 0x6d, 0x69, 0x63, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x63, 0x6f, + 0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x24, 0x0a, 0x08, 0x4d, + 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, + 0x6d, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, + 0x73, 0x42, 0x42, 0x5a, 0x40, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, + 0x73, 0x75, 0x70, 0x65, 0x72, 0x62, 0x6c, 0x6f, 0x63, 0x6b, 0x73, 0x74, 0x65, 0x61, 0x6d, 0x2f, + 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x67, 0x65, 0x6e, 0x2f, + 0x67, 0x6f, 0x2f, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x73, 0x2f, 0x6b, 0x69, 0x6e, 0x65, 0x73, + 0x69, 0x73, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -633,18 +634,18 @@ var file_plugins_kinesis_v1_plugin_proto_goTypes = []interface{}{ (*Plugin)(nil), // 1: plugins.kinesis.v1.Plugin (*Metadata)(nil), // 2: plugins.kinesis.v1.Metadata (*Plugin_KinesisConnection)(nil), // 3: plugins.kinesis.v1.Plugin.KinesisConnection - (*Plugin_Put)(nil), // 4: plugins.kinesis.v1.Plugin.Put - (*Plugin_Get)(nil), // 5: plugins.kinesis.v1.Plugin.Get + (*Plugin_KinesisPut)(nil), // 4: plugins.kinesis.v1.Plugin.KinesisPut + (*Plugin_KinesisGet)(nil), // 5: plugins.kinesis.v1.Plugin.KinesisGet (*v1.DynamicWorkflowConfiguration)(nil), // 6: plugins.common.v1.DynamicWorkflowConfiguration (*v1.AWSConfig)(nil), // 7: plugins.common.v1.AWSConfig } var file_plugins_kinesis_v1_plugin_proto_depIdxs = []int32{ 3, // 0: plugins.kinesis.v1.Plugin.connection:type_name -> plugins.kinesis.v1.Plugin.KinesisConnection - 4, // 1: plugins.kinesis.v1.Plugin.put:type_name -> plugins.kinesis.v1.Plugin.Put - 5, // 2: plugins.kinesis.v1.Plugin.get:type_name -> plugins.kinesis.v1.Plugin.Get + 4, // 1: plugins.kinesis.v1.Plugin.put:type_name -> plugins.kinesis.v1.Plugin.KinesisPut + 5, // 2: plugins.kinesis.v1.Plugin.get:type_name -> plugins.kinesis.v1.Plugin.KinesisGet 6, // 3: plugins.kinesis.v1.Plugin.dynamic_workflow_configuration:type_name -> plugins.common.v1.DynamicWorkflowConfiguration 7, // 4: plugins.kinesis.v1.Plugin.KinesisConnection.aws_config:type_name -> plugins.common.v1.AWSConfig - 0, // 5: plugins.kinesis.v1.Plugin.Get.shard_iterator_type:type_name -> plugins.kinesis.v1.Plugin.ShardIteratorType + 0, // 5: plugins.kinesis.v1.Plugin.KinesisGet.shard_iterator_type:type_name -> plugins.kinesis.v1.Plugin.ShardIteratorType 6, // [6:6] is the sub-list for method output_type 6, // [6:6] is the sub-list for method input_type 6, // [6:6] is the sub-list for extension type_name @@ -695,7 +696,7 @@ func file_plugins_kinesis_v1_plugin_proto_init() { } } file_plugins_kinesis_v1_plugin_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*Plugin_Put); i { + switch v := v.(*Plugin_KinesisPut); i { case 0: return &v.state case 1: @@ -707,7 +708,7 @@ func file_plugins_kinesis_v1_plugin_proto_init() { } } file_plugins_kinesis_v1_plugin_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*Plugin_Get); i { + switch v := v.(*Plugin_KinesisGet); i { case 0: return &v.state case 1: @@ -720,16 +721,16 @@ func file_plugins_kinesis_v1_plugin_proto_init() { } } file_plugins_kinesis_v1_plugin_proto_msgTypes[0].OneofWrappers = []interface{}{ - (*Plugin_Put_)(nil), - (*Plugin_Get_)(nil), + (*Plugin_Put)(nil), + (*Plugin_Get)(nil), } file_plugins_kinesis_v1_plugin_proto_msgTypes[3].OneofWrappers = []interface{}{ - (*Plugin_Put_StreamName)(nil), - (*Plugin_Put_StreamArn)(nil), + (*Plugin_KinesisPut_StreamName)(nil), + (*Plugin_KinesisPut_StreamArn)(nil), } file_plugins_kinesis_v1_plugin_proto_msgTypes[4].OneofWrappers = []interface{}{ - (*Plugin_Get_StreamName)(nil), - (*Plugin_Get_StreamArn)(nil), + (*Plugin_KinesisGet_StreamName)(nil), + (*Plugin_KinesisGet_StreamArn)(nil), } type x struct{} out := protoimpl.TypeBuilder{ diff --git a/types/gen/go/plugins/kinesis/v1/plugin.pb.validate.go b/types/gen/go/plugins/kinesis/v1/plugin.pb.validate.go index 31ada269..c236dd04 100644 --- a/types/gen/go/plugins/kinesis/v1/plugin.pb.validate.go +++ b/types/gen/go/plugins/kinesis/v1/plugin.pb.validate.go @@ -86,7 +86,7 @@ func (m *Plugin) validate(all bool) error { } switch v := m.Operation.(type) { - case *Plugin_Put_: + case *Plugin_Put: if v == nil { err := PluginValidationError{ field: "Operation", @@ -127,7 +127,7 @@ func (m *Plugin) validate(all bool) error { } } - case *Plugin_Get_: + case *Plugin_Get: if v == nil { err := PluginValidationError{ field: "Operation", @@ -516,22 +516,22 @@ var _ interface { ErrorName() string } = Plugin_KinesisConnectionValidationError{} -// Validate checks the field values on Plugin_Put with the rules defined in the -// proto definition for this message. If any rules are violated, the first -// error encountered is returned, or nil if there are no violations. -func (m *Plugin_Put) Validate() error { +// Validate checks the field values on Plugin_KinesisPut with the rules defined +// in the proto definition for this message. If any rules are violated, the +// first error encountered is returned, or nil if there are no violations. +func (m *Plugin_KinesisPut) Validate() error { return m.validate(false) } -// ValidateAll checks the field values on Plugin_Put with the rules defined in -// the proto definition for this message. If any rules are violated, the -// result is a list of violation errors wrapped in Plugin_PutMultiError, or -// nil if none found. -func (m *Plugin_Put) ValidateAll() error { +// ValidateAll checks the field values on Plugin_KinesisPut with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// Plugin_KinesisPutMultiError, or nil if none found. +func (m *Plugin_KinesisPut) ValidateAll() error { return m.validate(true) } -func (m *Plugin_Put) validate(all bool) error { +func (m *Plugin_KinesisPut) validate(all bool) error { if m == nil { return nil } @@ -543,9 +543,9 @@ func (m *Plugin_Put) validate(all bool) error { // no validation rules for PartitionKey switch v := m.StreamIdentifier.(type) { - case *Plugin_Put_StreamName: + case *Plugin_KinesisPut_StreamName: if v == nil { - err := Plugin_PutValidationError{ + err := Plugin_KinesisPutValidationError{ field: "StreamIdentifier", reason: "oneof value cannot be a typed-nil", } @@ -555,9 +555,9 @@ func (m *Plugin_Put) validate(all bool) error { errors = append(errors, err) } // no validation rules for StreamName - case *Plugin_Put_StreamArn: + case *Plugin_KinesisPut_StreamArn: if v == nil { - err := Plugin_PutValidationError{ + err := Plugin_KinesisPutValidationError{ field: "StreamIdentifier", reason: "oneof value cannot be a typed-nil", } @@ -572,18 +572,19 @@ func (m *Plugin_Put) validate(all bool) error { } if len(errors) > 0 { - return Plugin_PutMultiError(errors) + return Plugin_KinesisPutMultiError(errors) } return nil } -// Plugin_PutMultiError is an error wrapping multiple validation errors -// returned by Plugin_Put.ValidateAll() if the designated constraints aren't met. -type Plugin_PutMultiError []error +// Plugin_KinesisPutMultiError is an error wrapping multiple validation errors +// returned by Plugin_KinesisPut.ValidateAll() if the designated constraints +// aren't met. +type Plugin_KinesisPutMultiError []error // Error returns a concatenation of all the error messages it wraps. -func (m Plugin_PutMultiError) Error() string { +func (m Plugin_KinesisPutMultiError) Error() string { var msgs []string for _, err := range m { msgs = append(msgs, err.Error()) @@ -592,11 +593,11 @@ func (m Plugin_PutMultiError) Error() string { } // AllErrors returns a list of validation violation errors. -func (m Plugin_PutMultiError) AllErrors() []error { return m } +func (m Plugin_KinesisPutMultiError) AllErrors() []error { return m } -// Plugin_PutValidationError is the validation error returned by -// Plugin_Put.Validate if the designated constraints aren't met. -type Plugin_PutValidationError struct { +// Plugin_KinesisPutValidationError is the validation error returned by +// Plugin_KinesisPut.Validate if the designated constraints aren't met. +type Plugin_KinesisPutValidationError struct { field string reason string cause error @@ -604,22 +605,24 @@ type Plugin_PutValidationError struct { } // Field function returns field value. -func (e Plugin_PutValidationError) Field() string { return e.field } +func (e Plugin_KinesisPutValidationError) Field() string { return e.field } // Reason function returns reason value. -func (e Plugin_PutValidationError) Reason() string { return e.reason } +func (e Plugin_KinesisPutValidationError) Reason() string { return e.reason } // Cause function returns cause value. -func (e Plugin_PutValidationError) Cause() error { return e.cause } +func (e Plugin_KinesisPutValidationError) Cause() error { return e.cause } // Key function returns key value. -func (e Plugin_PutValidationError) Key() bool { return e.key } +func (e Plugin_KinesisPutValidationError) Key() bool { return e.key } // ErrorName returns error name. -func (e Plugin_PutValidationError) ErrorName() string { return "Plugin_PutValidationError" } +func (e Plugin_KinesisPutValidationError) ErrorName() string { + return "Plugin_KinesisPutValidationError" +} // Error satisfies the builtin error interface -func (e Plugin_PutValidationError) Error() string { +func (e Plugin_KinesisPutValidationError) Error() string { cause := "" if e.cause != nil { cause = fmt.Sprintf(" | caused by: %v", e.cause) @@ -631,14 +634,14 @@ func (e Plugin_PutValidationError) Error() string { } return fmt.Sprintf( - "invalid %sPlugin_Put.%s: %s%s", + "invalid %sPlugin_KinesisPut.%s: %s%s", key, e.field, e.reason, cause) } -var _ error = Plugin_PutValidationError{} +var _ error = Plugin_KinesisPutValidationError{} var _ interface { Field() string @@ -646,24 +649,24 @@ var _ interface { Key() bool Cause() error ErrorName() string -} = Plugin_PutValidationError{} +} = Plugin_KinesisPutValidationError{} -// Validate checks the field values on Plugin_Get with the rules defined in the -// proto definition for this message. If any rules are violated, the first -// error encountered is returned, or nil if there are no violations. -func (m *Plugin_Get) Validate() error { +// Validate checks the field values on Plugin_KinesisGet with the rules defined +// in the proto definition for this message. If any rules are violated, the +// first error encountered is returned, or nil if there are no violations. +func (m *Plugin_KinesisGet) Validate() error { return m.validate(false) } -// ValidateAll checks the field values on Plugin_Get with the rules defined in -// the proto definition for this message. If any rules are violated, the -// result is a list of violation errors wrapped in Plugin_GetMultiError, or -// nil if none found. -func (m *Plugin_Get) ValidateAll() error { +// ValidateAll checks the field values on Plugin_KinesisGet with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// Plugin_KinesisGetMultiError, or nil if none found. +func (m *Plugin_KinesisGet) ValidateAll() error { return m.validate(true) } -func (m *Plugin_Get) validate(all bool) error { +func (m *Plugin_KinesisGet) validate(all bool) error { if m == nil { return nil } @@ -679,9 +682,9 @@ func (m *Plugin_Get) validate(all bool) error { // no validation rules for PollingCooldownMs switch v := m.StreamIdentifier.(type) { - case *Plugin_Get_StreamName: + case *Plugin_KinesisGet_StreamName: if v == nil { - err := Plugin_GetValidationError{ + err := Plugin_KinesisGetValidationError{ field: "StreamIdentifier", reason: "oneof value cannot be a typed-nil", } @@ -691,9 +694,9 @@ func (m *Plugin_Get) validate(all bool) error { errors = append(errors, err) } // no validation rules for StreamName - case *Plugin_Get_StreamArn: + case *Plugin_KinesisGet_StreamArn: if v == nil { - err := Plugin_GetValidationError{ + err := Plugin_KinesisGetValidationError{ field: "StreamIdentifier", reason: "oneof value cannot be a typed-nil", } @@ -716,18 +719,19 @@ func (m *Plugin_Get) validate(all bool) error { } if len(errors) > 0 { - return Plugin_GetMultiError(errors) + return Plugin_KinesisGetMultiError(errors) } return nil } -// Plugin_GetMultiError is an error wrapping multiple validation errors -// returned by Plugin_Get.ValidateAll() if the designated constraints aren't met. -type Plugin_GetMultiError []error +// Plugin_KinesisGetMultiError is an error wrapping multiple validation errors +// returned by Plugin_KinesisGet.ValidateAll() if the designated constraints +// aren't met. +type Plugin_KinesisGetMultiError []error // Error returns a concatenation of all the error messages it wraps. -func (m Plugin_GetMultiError) Error() string { +func (m Plugin_KinesisGetMultiError) Error() string { var msgs []string for _, err := range m { msgs = append(msgs, err.Error()) @@ -736,11 +740,11 @@ func (m Plugin_GetMultiError) Error() string { } // AllErrors returns a list of validation violation errors. -func (m Plugin_GetMultiError) AllErrors() []error { return m } +func (m Plugin_KinesisGetMultiError) AllErrors() []error { return m } -// Plugin_GetValidationError is the validation error returned by -// Plugin_Get.Validate if the designated constraints aren't met. -type Plugin_GetValidationError struct { +// Plugin_KinesisGetValidationError is the validation error returned by +// Plugin_KinesisGet.Validate if the designated constraints aren't met. +type Plugin_KinesisGetValidationError struct { field string reason string cause error @@ -748,22 +752,24 @@ type Plugin_GetValidationError struct { } // Field function returns field value. -func (e Plugin_GetValidationError) Field() string { return e.field } +func (e Plugin_KinesisGetValidationError) Field() string { return e.field } // Reason function returns reason value. -func (e Plugin_GetValidationError) Reason() string { return e.reason } +func (e Plugin_KinesisGetValidationError) Reason() string { return e.reason } // Cause function returns cause value. -func (e Plugin_GetValidationError) Cause() error { return e.cause } +func (e Plugin_KinesisGetValidationError) Cause() error { return e.cause } // Key function returns key value. -func (e Plugin_GetValidationError) Key() bool { return e.key } +func (e Plugin_KinesisGetValidationError) Key() bool { return e.key } // ErrorName returns error name. -func (e Plugin_GetValidationError) ErrorName() string { return "Plugin_GetValidationError" } +func (e Plugin_KinesisGetValidationError) ErrorName() string { + return "Plugin_KinesisGetValidationError" +} // Error satisfies the builtin error interface -func (e Plugin_GetValidationError) Error() string { +func (e Plugin_KinesisGetValidationError) Error() string { cause := "" if e.cause != nil { cause = fmt.Sprintf(" | caused by: %v", e.cause) @@ -775,14 +781,14 @@ func (e Plugin_GetValidationError) Error() string { } return fmt.Sprintf( - "invalid %sPlugin_Get.%s: %s%s", + "invalid %sPlugin_KinesisGet.%s: %s%s", key, e.field, e.reason, cause) } -var _ error = Plugin_GetValidationError{} +var _ error = Plugin_KinesisGetValidationError{} var _ interface { Field() string @@ -790,4 +796,4 @@ var _ interface { Key() bool Cause() error ErrorName() string -} = Plugin_GetValidationError{} +} = Plugin_KinesisGetValidationError{} diff --git a/types/gen/js/plugins/kinesis/v1/plugin_pb.d.ts b/types/gen/js/plugins/kinesis/v1/plugin_pb.d.ts index 23b4f991..72d58c30 100644 --- a/types/gen/js/plugins/kinesis/v1/plugin_pb.d.ts +++ b/types/gen/js/plugins/kinesis/v1/plugin_pb.d.ts @@ -21,13 +21,13 @@ export class Plugin extends jspb.Message { hasPut(): boolean; clearPut(): void; - getPut(): Plugin.Put | undefined; - setPut(value?: Plugin.Put): Plugin; + getPut(): Plugin.KinesisPut | undefined; + setPut(value?: Plugin.KinesisPut): Plugin; hasGet(): boolean; clearGet(): void; - getGet(): Plugin.Get | undefined; - setGet(value?: Plugin.Get): Plugin; + getGet(): Plugin.KinesisGet | undefined; + setGet(value?: Plugin.KinesisGet): Plugin; hasDynamicWorkflowConfiguration(): boolean; clearDynamicWorkflowConfiguration(): void; @@ -50,8 +50,8 @@ export namespace Plugin { export type AsObject = { name?: string, connection?: Plugin.KinesisConnection.AsObject, - put?: Plugin.Put.AsObject, - get?: Plugin.Get.AsObject, + put?: Plugin.KinesisPut.AsObject, + get?: Plugin.KinesisGet.AsObject, dynamicWorkflowConfiguration?: plugins_common_v1_plugin_pb.DynamicWorkflowConfiguration.AsObject, } @@ -79,35 +79,35 @@ export namespace Plugin { } } - export class Put extends jspb.Message { + export class KinesisPut extends jspb.Message { getData(): string; - setData(value: string): Put; + setData(value: string): KinesisPut; getPartitionKey(): string; - setPartitionKey(value: string): Put; + setPartitionKey(value: string): KinesisPut; hasStreamName(): boolean; clearStreamName(): void; getStreamName(): string; - setStreamName(value: string): Put; + setStreamName(value: string): KinesisPut; hasStreamArn(): boolean; clearStreamArn(): void; getStreamArn(): string; - setStreamArn(value: string): Put; + setStreamArn(value: string): KinesisPut; - getStreamIdentifierCase(): Put.StreamIdentifierCase; + getStreamIdentifierCase(): KinesisPut.StreamIdentifierCase; serializeBinary(): Uint8Array; - toObject(includeInstance?: boolean): Put.AsObject; - static toObject(includeInstance: boolean, msg: Put): Put.AsObject; + toObject(includeInstance?: boolean): KinesisPut.AsObject; + static toObject(includeInstance: boolean, msg: KinesisPut): KinesisPut.AsObject; static extensions: {[key: number]: jspb.ExtensionFieldInfo}; static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; - static serializeBinaryToWriter(message: Put, writer: jspb.BinaryWriter): void; - static deserializeBinary(bytes: Uint8Array): Put; - static deserializeBinaryFromReader(message: Put, reader: jspb.BinaryReader): Put; + static serializeBinaryToWriter(message: KinesisPut, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): KinesisPut; + static deserializeBinaryFromReader(message: KinesisPut, reader: jspb.BinaryReader): KinesisPut; } - export namespace Put { + export namespace KinesisPut { export type AsObject = { data: string, partitionKey: string, @@ -123,49 +123,49 @@ export namespace Plugin { } - export class Get extends jspb.Message { + export class KinesisGet extends jspb.Message { getShardId(): string; - setShardId(value: string): Get; + setShardId(value: string): KinesisGet; getShardIteratorType(): Plugin.ShardIteratorType; - setShardIteratorType(value: Plugin.ShardIteratorType): Get; + setShardIteratorType(value: Plugin.ShardIteratorType): KinesisGet; getLimit(): number; - setLimit(value: number): Get; + setLimit(value: number): KinesisGet; getPollingCooldownMs(): number; - setPollingCooldownMs(value: number): Get; + setPollingCooldownMs(value: number): KinesisGet; hasStartingSequenceNumber(): boolean; clearStartingSequenceNumber(): void; getStartingSequenceNumber(): string | undefined; - setStartingSequenceNumber(value: string): Get; + setStartingSequenceNumber(value: string): KinesisGet; hasTimestamp(): boolean; clearTimestamp(): void; getTimestamp(): string | undefined; - setTimestamp(value: string): Get; + setTimestamp(value: string): KinesisGet; hasStreamName(): boolean; clearStreamName(): void; getStreamName(): string; - setStreamName(value: string): Get; + setStreamName(value: string): KinesisGet; hasStreamArn(): boolean; clearStreamArn(): void; getStreamArn(): string; - setStreamArn(value: string): Get; + setStreamArn(value: string): KinesisGet; - getStreamIdentifierCase(): Get.StreamIdentifierCase; + getStreamIdentifierCase(): KinesisGet.StreamIdentifierCase; serializeBinary(): Uint8Array; - toObject(includeInstance?: boolean): Get.AsObject; - static toObject(includeInstance: boolean, msg: Get): Get.AsObject; + toObject(includeInstance?: boolean): KinesisGet.AsObject; + static toObject(includeInstance: boolean, msg: KinesisGet): KinesisGet.AsObject; static extensions: {[key: number]: jspb.ExtensionFieldInfo}; static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo}; - static serializeBinaryToWriter(message: Get, writer: jspb.BinaryWriter): void; - static deserializeBinary(bytes: Uint8Array): Get; - static deserializeBinaryFromReader(message: Get, reader: jspb.BinaryReader): Get; + static serializeBinaryToWriter(message: KinesisGet, writer: jspb.BinaryWriter): void; + static deserializeBinary(bytes: Uint8Array): KinesisGet; + static deserializeBinaryFromReader(message: KinesisGet, reader: jspb.BinaryReader): KinesisGet; } - export namespace Get { + export namespace KinesisGet { export type AsObject = { shardId: string, shardIteratorType: Plugin.ShardIteratorType, diff --git a/types/gen/js/plugins/kinesis/v1/plugin_pb.js b/types/gen/js/plugins/kinesis/v1/plugin_pb.js index c162282c..68d1275a 100644 --- a/types/gen/js/plugins/kinesis/v1/plugin_pb.js +++ b/types/gen/js/plugins/kinesis/v1/plugin_pb.js @@ -25,12 +25,12 @@ var plugins_common_v1_plugin_pb = require('../../../plugins/common/v1/plugin_pb' goog.object.extend(proto, plugins_common_v1_plugin_pb); goog.exportSymbol('proto.plugins.kinesis.v1.Metadata', null, global); goog.exportSymbol('proto.plugins.kinesis.v1.Plugin', null, global); -goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.Get', null, global); -goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.Get.StreamIdentifierCase', null, global); goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.KinesisConnection', null, global); +goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.KinesisGet', null, global); +goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.KinesisGet.StreamIdentifierCase', null, global); +goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.KinesisPut', null, global); +goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.KinesisPut.StreamIdentifierCase', null, global); goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.OperationCase', null, global); -goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.Put', null, global); -goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.Put.StreamIdentifierCase', null, global); goog.exportSymbol('proto.plugins.kinesis.v1.Plugin.ShardIteratorType', null, global); /** * Generated by JsPbCodeGenerator. @@ -84,16 +84,16 @@ if (goog.DEBUG && !COMPILED) { * @extends {jspb.Message} * @constructor */ -proto.plugins.kinesis.v1.Plugin.Put = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_); +proto.plugins.kinesis.v1.Plugin.KinesisPut = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_); }; -goog.inherits(proto.plugins.kinesis.v1.Plugin.Put, jspb.Message); +goog.inherits(proto.plugins.kinesis.v1.Plugin.KinesisPut, jspb.Message); if (goog.DEBUG && !COMPILED) { /** * @public * @override */ - proto.plugins.kinesis.v1.Plugin.Put.displayName = 'proto.plugins.kinesis.v1.Plugin.Put'; + proto.plugins.kinesis.v1.Plugin.KinesisPut.displayName = 'proto.plugins.kinesis.v1.Plugin.KinesisPut'; } /** * Generated by JsPbCodeGenerator. @@ -105,16 +105,16 @@ if (goog.DEBUG && !COMPILED) { * @extends {jspb.Message} * @constructor */ -proto.plugins.kinesis.v1.Plugin.Get = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_); +proto.plugins.kinesis.v1.Plugin.KinesisGet = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_); }; -goog.inherits(proto.plugins.kinesis.v1.Plugin.Get, jspb.Message); +goog.inherits(proto.plugins.kinesis.v1.Plugin.KinesisGet, jspb.Message); if (goog.DEBUG && !COMPILED) { /** * @public * @override */ - proto.plugins.kinesis.v1.Plugin.Get.displayName = 'proto.plugins.kinesis.v1.Plugin.Get'; + proto.plugins.kinesis.v1.Plugin.KinesisGet.displayName = 'proto.plugins.kinesis.v1.Plugin.KinesisGet'; } /** * Generated by JsPbCodeGenerator. @@ -197,8 +197,8 @@ proto.plugins.kinesis.v1.Plugin.toObject = function(includeInstance, msg) { var f, obj = { name: (f = jspb.Message.getField(msg, 1)) == null ? undefined : f, connection: (f = msg.getConnection()) && proto.plugins.kinesis.v1.Plugin.KinesisConnection.toObject(includeInstance, f), -put: (f = msg.getPut()) && proto.plugins.kinesis.v1.Plugin.Put.toObject(includeInstance, f), -get: (f = msg.getGet()) && proto.plugins.kinesis.v1.Plugin.Get.toObject(includeInstance, f), +put: (f = msg.getPut()) && proto.plugins.kinesis.v1.Plugin.KinesisPut.toObject(includeInstance, f), +get: (f = msg.getGet()) && proto.plugins.kinesis.v1.Plugin.KinesisGet.toObject(includeInstance, f), dynamicWorkflowConfiguration: (f = msg.getDynamicWorkflowConfiguration()) && plugins_common_v1_plugin_pb.DynamicWorkflowConfiguration.toObject(includeInstance, f) }; @@ -246,13 +246,13 @@ proto.plugins.kinesis.v1.Plugin.deserializeBinaryFromReader = function(msg, read msg.setConnection(value); break; case 3: - var value = new proto.plugins.kinesis.v1.Plugin.Put; - reader.readMessage(value,proto.plugins.kinesis.v1.Plugin.Put.deserializeBinaryFromReader); + var value = new proto.plugins.kinesis.v1.Plugin.KinesisPut; + reader.readMessage(value,proto.plugins.kinesis.v1.Plugin.KinesisPut.deserializeBinaryFromReader); msg.setPut(value); break; case 4: - var value = new proto.plugins.kinesis.v1.Plugin.Get; - reader.readMessage(value,proto.plugins.kinesis.v1.Plugin.Get.deserializeBinaryFromReader); + var value = new proto.plugins.kinesis.v1.Plugin.KinesisGet; + reader.readMessage(value,proto.plugins.kinesis.v1.Plugin.KinesisGet.deserializeBinaryFromReader); msg.setGet(value); break; case 5: @@ -309,7 +309,7 @@ proto.plugins.kinesis.v1.Plugin.serializeBinaryToWriter = function(message, writ writer.writeMessage( 3, f, - proto.plugins.kinesis.v1.Plugin.Put.serializeBinaryToWriter + proto.plugins.kinesis.v1.Plugin.KinesisPut.serializeBinaryToWriter ); } f = message.getGet(); @@ -317,7 +317,7 @@ proto.plugins.kinesis.v1.Plugin.serializeBinaryToWriter = function(message, writ writer.writeMessage( 4, f, - proto.plugins.kinesis.v1.Plugin.Get.serializeBinaryToWriter + proto.plugins.kinesis.v1.Plugin.KinesisGet.serializeBinaryToWriter ); } f = message.getDynamicWorkflowConfiguration(); @@ -503,22 +503,22 @@ proto.plugins.kinesis.v1.Plugin.KinesisConnection.prototype.hasAwsConfig = funct * @private {!Array>} * @const */ -proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_ = [[3,4]]; +proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_ = [[3,4]]; /** * @enum {number} */ -proto.plugins.kinesis.v1.Plugin.Put.StreamIdentifierCase = { +proto.plugins.kinesis.v1.Plugin.KinesisPut.StreamIdentifierCase = { STREAM_IDENTIFIER_NOT_SET: 0, STREAM_NAME: 3, STREAM_ARN: 4 }; /** - * @return {proto.plugins.kinesis.v1.Plugin.Put.StreamIdentifierCase} + * @return {proto.plugins.kinesis.v1.Plugin.KinesisPut.StreamIdentifierCase} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.getStreamIdentifierCase = function() { - return /** @type {proto.plugins.kinesis.v1.Plugin.Put.StreamIdentifierCase} */(jspb.Message.computeOneofCase(this, proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_[0])); +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.getStreamIdentifierCase = function() { + return /** @type {proto.plugins.kinesis.v1.Plugin.KinesisPut.StreamIdentifierCase} */(jspb.Message.computeOneofCase(this, proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_[0])); }; @@ -536,8 +536,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.toObject = function(opt_includeInstance) { - return proto.plugins.kinesis.v1.Plugin.Put.toObject(opt_includeInstance, this); +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.toObject = function(opt_includeInstance) { + return proto.plugins.kinesis.v1.Plugin.KinesisPut.toObject(opt_includeInstance, this); }; @@ -546,11 +546,11 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.toObject = function(opt_includeIns * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.plugins.kinesis.v1.Plugin.Put} msg The msg instance to transform. + * @param {!proto.plugins.kinesis.v1.Plugin.KinesisPut} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.plugins.kinesis.v1.Plugin.Put.toObject = function(includeInstance, msg) { +proto.plugins.kinesis.v1.Plugin.KinesisPut.toObject = function(includeInstance, msg) { var f, obj = { data: jspb.Message.getFieldWithDefault(msg, 1, ""), partitionKey: jspb.Message.getFieldWithDefault(msg, 2, ""), @@ -569,23 +569,23 @@ streamArn: (f = jspb.Message.getField(msg, 4)) == null ? undefined : f /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.plugins.kinesis.v1.Plugin.Put} + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} */ -proto.plugins.kinesis.v1.Plugin.Put.deserializeBinary = function(bytes) { +proto.plugins.kinesis.v1.Plugin.KinesisPut.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.plugins.kinesis.v1.Plugin.Put; - return proto.plugins.kinesis.v1.Plugin.Put.deserializeBinaryFromReader(msg, reader); + var msg = new proto.plugins.kinesis.v1.Plugin.KinesisPut; + return proto.plugins.kinesis.v1.Plugin.KinesisPut.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.plugins.kinesis.v1.Plugin.Put} msg The message object to deserialize into. + * @param {!proto.plugins.kinesis.v1.Plugin.KinesisPut} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.plugins.kinesis.v1.Plugin.Put} + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} */ -proto.plugins.kinesis.v1.Plugin.Put.deserializeBinaryFromReader = function(msg, reader) { +proto.plugins.kinesis.v1.Plugin.KinesisPut.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -621,9 +621,9 @@ proto.plugins.kinesis.v1.Plugin.Put.deserializeBinaryFromReader = function(msg, * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.serializeBinary = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.plugins.kinesis.v1.Plugin.Put.serializeBinaryToWriter(this, writer); + proto.plugins.kinesis.v1.Plugin.KinesisPut.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -631,11 +631,11 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.plugins.kinesis.v1.Plugin.Put} message + * @param {!proto.plugins.kinesis.v1.Plugin.KinesisPut} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.plugins.kinesis.v1.Plugin.Put.serializeBinaryToWriter = function(message, writer) { +proto.plugins.kinesis.v1.Plugin.KinesisPut.serializeBinaryToWriter = function(message, writer) { var f = undefined; f = message.getData(); if (f.length > 0) { @@ -672,16 +672,16 @@ proto.plugins.kinesis.v1.Plugin.Put.serializeBinaryToWriter = function(message, * optional string data = 1; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.getData = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.getData = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Put} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} returns this */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.setData = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.setData = function(value) { return jspb.Message.setProto3StringField(this, 1, value); }; @@ -690,16 +690,16 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.setData = function(value) { * optional string partition_key = 2; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.getPartitionKey = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.getPartitionKey = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Put} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} returns this */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.setPartitionKey = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.setPartitionKey = function(value) { return jspb.Message.setProto3StringField(this, 2, value); }; @@ -708,26 +708,26 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.setPartitionKey = function(value) * optional string stream_name = 3; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.getStreamName = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.getStreamName = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Put} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} returns this */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.setStreamName = function(value) { - return jspb.Message.setOneofField(this, 3, proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_[0], value); +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.setStreamName = function(value) { + return jspb.Message.setOneofField(this, 3, proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_[0], value); }; /** * Clears the field making it undefined. - * @return {!proto.plugins.kinesis.v1.Plugin.Put} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} returns this */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.clearStreamName = function() { - return jspb.Message.setOneofField(this, 3, proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_[0], undefined); +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.clearStreamName = function() { + return jspb.Message.setOneofField(this, 3, proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_[0], undefined); }; @@ -735,7 +735,7 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.clearStreamName = function() { * Returns whether this field is set. * @return {boolean} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.hasStreamName = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.hasStreamName = function() { return jspb.Message.getField(this, 3) != null; }; @@ -744,26 +744,26 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.hasStreamName = function() { * optional string stream_arn = 4; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.getStreamArn = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.getStreamArn = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 4, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Put} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} returns this */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.setStreamArn = function(value) { - return jspb.Message.setOneofField(this, 4, proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_[0], value); +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.setStreamArn = function(value) { + return jspb.Message.setOneofField(this, 4, proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_[0], value); }; /** * Clears the field making it undefined. - * @return {!proto.plugins.kinesis.v1.Plugin.Put} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisPut} returns this */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.clearStreamArn = function() { - return jspb.Message.setOneofField(this, 4, proto.plugins.kinesis.v1.Plugin.Put.oneofGroups_[0], undefined); +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.clearStreamArn = function() { + return jspb.Message.setOneofField(this, 4, proto.plugins.kinesis.v1.Plugin.KinesisPut.oneofGroups_[0], undefined); }; @@ -771,7 +771,7 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.clearStreamArn = function() { * Returns whether this field is set. * @return {boolean} */ -proto.plugins.kinesis.v1.Plugin.Put.prototype.hasStreamArn = function() { +proto.plugins.kinesis.v1.Plugin.KinesisPut.prototype.hasStreamArn = function() { return jspb.Message.getField(this, 4) != null; }; @@ -785,22 +785,22 @@ proto.plugins.kinesis.v1.Plugin.Put.prototype.hasStreamArn = function() { * @private {!Array>} * @const */ -proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_ = [[8,9]]; +proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_ = [[8,9]]; /** * @enum {number} */ -proto.plugins.kinesis.v1.Plugin.Get.StreamIdentifierCase = { +proto.plugins.kinesis.v1.Plugin.KinesisGet.StreamIdentifierCase = { STREAM_IDENTIFIER_NOT_SET: 0, STREAM_NAME: 8, STREAM_ARN: 9 }; /** - * @return {proto.plugins.kinesis.v1.Plugin.Get.StreamIdentifierCase} + * @return {proto.plugins.kinesis.v1.Plugin.KinesisGet.StreamIdentifierCase} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getStreamIdentifierCase = function() { - return /** @type {proto.plugins.kinesis.v1.Plugin.Get.StreamIdentifierCase} */(jspb.Message.computeOneofCase(this, proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_[0])); +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getStreamIdentifierCase = function() { + return /** @type {proto.plugins.kinesis.v1.Plugin.KinesisGet.StreamIdentifierCase} */(jspb.Message.computeOneofCase(this, proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_[0])); }; @@ -818,8 +818,8 @@ if (jspb.Message.GENERATE_TO_OBJECT) { * http://goto/soy-param-migration * @return {!Object} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.toObject = function(opt_includeInstance) { - return proto.plugins.kinesis.v1.Plugin.Get.toObject(opt_includeInstance, this); +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.toObject = function(opt_includeInstance) { + return proto.plugins.kinesis.v1.Plugin.KinesisGet.toObject(opt_includeInstance, this); }; @@ -828,11 +828,11 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.toObject = function(opt_includeIns * @param {boolean|undefined} includeInstance Deprecated. Whether to include * the JSPB instance for transitional soy proto support: * http://goto/soy-param-migration - * @param {!proto.plugins.kinesis.v1.Plugin.Get} msg The msg instance to transform. + * @param {!proto.plugins.kinesis.v1.Plugin.KinesisGet} msg The msg instance to transform. * @return {!Object} * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.plugins.kinesis.v1.Plugin.Get.toObject = function(includeInstance, msg) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.toObject = function(includeInstance, msg) { var f, obj = { shardId: jspb.Message.getFieldWithDefault(msg, 2, ""), shardIteratorType: jspb.Message.getFieldWithDefault(msg, 3, 0), @@ -855,23 +855,23 @@ streamArn: (f = jspb.Message.getField(msg, 9)) == null ? undefined : f /** * Deserializes binary data (in protobuf wire format). * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.plugins.kinesis.v1.Plugin.Get} + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} */ -proto.plugins.kinesis.v1.Plugin.Get.deserializeBinary = function(bytes) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.deserializeBinary = function(bytes) { var reader = new jspb.BinaryReader(bytes); - var msg = new proto.plugins.kinesis.v1.Plugin.Get; - return proto.plugins.kinesis.v1.Plugin.Get.deserializeBinaryFromReader(msg, reader); + var msg = new proto.plugins.kinesis.v1.Plugin.KinesisGet; + return proto.plugins.kinesis.v1.Plugin.KinesisGet.deserializeBinaryFromReader(msg, reader); }; /** * Deserializes binary data (in protobuf wire format) from the * given reader into the given message object. - * @param {!proto.plugins.kinesis.v1.Plugin.Get} msg The message object to deserialize into. + * @param {!proto.plugins.kinesis.v1.Plugin.KinesisGet} msg The message object to deserialize into. * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.plugins.kinesis.v1.Plugin.Get} + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} */ -proto.plugins.kinesis.v1.Plugin.Get.deserializeBinaryFromReader = function(msg, reader) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.deserializeBinaryFromReader = function(msg, reader) { while (reader.nextField()) { if (reader.isEndGroup()) { break; @@ -923,9 +923,9 @@ proto.plugins.kinesis.v1.Plugin.Get.deserializeBinaryFromReader = function(msg, * Serializes the message to binary data (in protobuf wire format). * @return {!Uint8Array} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.serializeBinary = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.serializeBinary = function() { var writer = new jspb.BinaryWriter(); - proto.plugins.kinesis.v1.Plugin.Get.serializeBinaryToWriter(this, writer); + proto.plugins.kinesis.v1.Plugin.KinesisGet.serializeBinaryToWriter(this, writer); return writer.getResultBuffer(); }; @@ -933,11 +933,11 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.serializeBinary = function() { /** * Serializes the given message to binary data (in protobuf wire * format), writing to the given BinaryWriter. - * @param {!proto.plugins.kinesis.v1.Plugin.Get} message + * @param {!proto.plugins.kinesis.v1.Plugin.KinesisGet} message * @param {!jspb.BinaryWriter} writer * @suppress {unusedLocalVariables} f is only used for nested messages */ -proto.plugins.kinesis.v1.Plugin.Get.serializeBinaryToWriter = function(message, writer) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.serializeBinaryToWriter = function(message, writer) { var f = undefined; f = message.getShardId(); if (f.length > 0) { @@ -1002,16 +1002,16 @@ proto.plugins.kinesis.v1.Plugin.Get.serializeBinaryToWriter = function(message, * optional string shard_id = 2; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getShardId = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getShardId = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setShardId = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setShardId = function(value) { return jspb.Message.setProto3StringField(this, 2, value); }; @@ -1020,16 +1020,16 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.setShardId = function(value) { * optional ShardIteratorType shard_iterator_type = 3; * @return {!proto.plugins.kinesis.v1.Plugin.ShardIteratorType} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getShardIteratorType = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getShardIteratorType = function() { return /** @type {!proto.plugins.kinesis.v1.Plugin.ShardIteratorType} */ (jspb.Message.getFieldWithDefault(this, 3, 0)); }; /** * @param {!proto.plugins.kinesis.v1.Plugin.ShardIteratorType} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setShardIteratorType = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setShardIteratorType = function(value) { return jspb.Message.setProto3EnumField(this, 3, value); }; @@ -1038,16 +1038,16 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.setShardIteratorType = function(va * optional int32 limit = 4; * @return {number} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getLimit = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getLimit = function() { return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0)); }; /** * @param {number} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setLimit = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setLimit = function(value) { return jspb.Message.setProto3IntField(this, 4, value); }; @@ -1056,16 +1056,16 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.setLimit = function(value) { * optional int32 polling_cooldown_ms = 5; * @return {number} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getPollingCooldownMs = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getPollingCooldownMs = function() { return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 5, 0)); }; /** * @param {number} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setPollingCooldownMs = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setPollingCooldownMs = function(value) { return jspb.Message.setProto3IntField(this, 5, value); }; @@ -1074,25 +1074,25 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.setPollingCooldownMs = function(va * optional string starting_sequence_number = 6; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getStartingSequenceNumber = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getStartingSequenceNumber = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 6, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setStartingSequenceNumber = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setStartingSequenceNumber = function(value) { return jspb.Message.setField(this, 6, value); }; /** * Clears the field making it undefined. - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.clearStartingSequenceNumber = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.clearStartingSequenceNumber = function() { return jspb.Message.setField(this, 6, undefined); }; @@ -1101,7 +1101,7 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.clearStartingSequenceNumber = func * Returns whether this field is set. * @return {boolean} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.hasStartingSequenceNumber = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.hasStartingSequenceNumber = function() { return jspb.Message.getField(this, 6) != null; }; @@ -1110,25 +1110,25 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.hasStartingSequenceNumber = functi * optional string timestamp = 7; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getTimestamp = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getTimestamp = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 7, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setTimestamp = function(value) { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setTimestamp = function(value) { return jspb.Message.setField(this, 7, value); }; /** * Clears the field making it undefined. - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.clearTimestamp = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.clearTimestamp = function() { return jspb.Message.setField(this, 7, undefined); }; @@ -1137,7 +1137,7 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.clearTimestamp = function() { * Returns whether this field is set. * @return {boolean} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.hasTimestamp = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.hasTimestamp = function() { return jspb.Message.getField(this, 7) != null; }; @@ -1146,26 +1146,26 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.hasTimestamp = function() { * optional string stream_name = 8; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getStreamName = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getStreamName = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 8, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setStreamName = function(value) { - return jspb.Message.setOneofField(this, 8, proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_[0], value); +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setStreamName = function(value) { + return jspb.Message.setOneofField(this, 8, proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_[0], value); }; /** * Clears the field making it undefined. - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.clearStreamName = function() { - return jspb.Message.setOneofField(this, 8, proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_[0], undefined); +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.clearStreamName = function() { + return jspb.Message.setOneofField(this, 8, proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_[0], undefined); }; @@ -1173,7 +1173,7 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.clearStreamName = function() { * Returns whether this field is set. * @return {boolean} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.hasStreamName = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.hasStreamName = function() { return jspb.Message.getField(this, 8) != null; }; @@ -1182,26 +1182,26 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.hasStreamName = function() { * optional string stream_arn = 9; * @return {string} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.getStreamArn = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.getStreamArn = function() { return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 9, "")); }; /** * @param {string} value - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.setStreamArn = function(value) { - return jspb.Message.setOneofField(this, 9, proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_[0], value); +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.setStreamArn = function(value) { + return jspb.Message.setOneofField(this, 9, proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_[0], value); }; /** * Clears the field making it undefined. - * @return {!proto.plugins.kinesis.v1.Plugin.Get} returns this + * @return {!proto.plugins.kinesis.v1.Plugin.KinesisGet} returns this */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.clearStreamArn = function() { - return jspb.Message.setOneofField(this, 9, proto.plugins.kinesis.v1.Plugin.Get.oneofGroups_[0], undefined); +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.clearStreamArn = function() { + return jspb.Message.setOneofField(this, 9, proto.plugins.kinesis.v1.Plugin.KinesisGet.oneofGroups_[0], undefined); }; @@ -1209,7 +1209,7 @@ proto.plugins.kinesis.v1.Plugin.Get.prototype.clearStreamArn = function() { * Returns whether this field is set. * @return {boolean} */ -proto.plugins.kinesis.v1.Plugin.Get.prototype.hasStreamArn = function() { +proto.plugins.kinesis.v1.Plugin.KinesisGet.prototype.hasStreamArn = function() { return jspb.Message.getField(this, 9) != null; }; @@ -1288,17 +1288,17 @@ proto.plugins.kinesis.v1.Plugin.prototype.hasConnection = function() { /** - * optional Put put = 3; - * @return {?proto.plugins.kinesis.v1.Plugin.Put} + * optional KinesisPut put = 3; + * @return {?proto.plugins.kinesis.v1.Plugin.KinesisPut} */ proto.plugins.kinesis.v1.Plugin.prototype.getPut = function() { - return /** @type{?proto.plugins.kinesis.v1.Plugin.Put} */ ( - jspb.Message.getWrapperField(this, proto.plugins.kinesis.v1.Plugin.Put, 3)); + return /** @type{?proto.plugins.kinesis.v1.Plugin.KinesisPut} */ ( + jspb.Message.getWrapperField(this, proto.plugins.kinesis.v1.Plugin.KinesisPut, 3)); }; /** - * @param {?proto.plugins.kinesis.v1.Plugin.Put|undefined} value + * @param {?proto.plugins.kinesis.v1.Plugin.KinesisPut|undefined} value * @return {!proto.plugins.kinesis.v1.Plugin} returns this */ proto.plugins.kinesis.v1.Plugin.prototype.setPut = function(value) { @@ -1325,17 +1325,17 @@ proto.plugins.kinesis.v1.Plugin.prototype.hasPut = function() { /** - * optional Get get = 4; - * @return {?proto.plugins.kinesis.v1.Plugin.Get} + * optional KinesisGet get = 4; + * @return {?proto.plugins.kinesis.v1.Plugin.KinesisGet} */ proto.plugins.kinesis.v1.Plugin.prototype.getGet = function() { - return /** @type{?proto.plugins.kinesis.v1.Plugin.Get} */ ( - jspb.Message.getWrapperField(this, proto.plugins.kinesis.v1.Plugin.Get, 4)); + return /** @type{?proto.plugins.kinesis.v1.Plugin.KinesisGet} */ ( + jspb.Message.getWrapperField(this, proto.plugins.kinesis.v1.Plugin.KinesisGet, 4)); }; /** - * @param {?proto.plugins.kinesis.v1.Plugin.Get|undefined} value + * @param {?proto.plugins.kinesis.v1.Plugin.KinesisGet|undefined} value * @return {!proto.plugins.kinesis.v1.Plugin} returns this */ proto.plugins.kinesis.v1.Plugin.prototype.setGet = function(value) { diff --git a/types/gen/py/superblocks_types/plugins/kinesis/v1/plugin_pb2.py b/types/gen/py/superblocks_types/plugins/kinesis/v1/plugin_pb2.py index b0921969..fb51c575 100644 --- a/types/gen/py/superblocks_types/plugins/kinesis/v1/plugin_pb2.py +++ b/types/gen/py/superblocks_types/plugins/kinesis/v1/plugin_pb2.py @@ -25,7 +25,7 @@ from superblocks_types.plugins.common.v1 import plugin_pb2 as plugins_dot_common_dot_v1_dot_plugin__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1fplugins/kinesis/v1/plugin.proto\x12\x12plugins.kinesis.v1\x1a\x1eplugins/common/v1/plugin.proto\"\xa7\n\n\x06Plugin\x12\x17\n\x04name\x18\x01 \x01(\tH\x01R\x04name\x88\x01\x01\x12L\n\nconnection\x18\x02 \x01(\x0b\x32,.plugins.kinesis.v1.Plugin.KinesisConnectionR\nconnection\x12\x32\n\x03put\x18\x03 \x01(\x0b\x32\x1e.plugins.kinesis.v1.Plugin.PutH\x00R\x03put\x12\x32\n\x03get\x18\x04 \x01(\x0b\x32\x1e.plugins.kinesis.v1.Plugin.GetH\x00R\x03get\x12z\n\x1e\x64ynamic_workflow_configuration\x18\x05 \x01(\x0b\x32/.plugins.common.v1.DynamicWorkflowConfigurationH\x02R\x1c\x64ynamicWorkflowConfiguration\x88\x01\x01\x1aP\n\x11KinesisConnection\x12;\n\naws_config\x18\x01 \x01(\x0b\x32\x1c.plugins.common.v1.AWSConfigR\tawsConfig\x1a\x97\x01\n\x03Put\x12\x12\n\x04\x64\x61ta\x18\x01 \x01(\tR\x04\x64\x61ta\x12#\n\rpartition_key\x18\x02 \x01(\tR\x0cpartitionKey\x12!\n\x0bstream_name\x18\x03 \x01(\tH\x00R\nstreamName\x12\x1f\n\nstream_arn\x18\x04 \x01(\tH\x00R\tstreamArnB\x13\n\x11stream_identifier\x1a\xaa\x03\n\x03Get\x12\x19\n\x08shard_id\x18\x02 \x01(\tR\x07shardId\x12\\\n\x13shard_iterator_type\x18\x03 \x01(\x0e\x32,.plugins.kinesis.v1.Plugin.ShardIteratorTypeR\x11shardIteratorType\x12\x14\n\x05limit\x18\x04 \x01(\x05R\x05limit\x12.\n\x13polling_cooldown_ms\x18\x05 \x01(\x05R\x11pollingCooldownMs\x12=\n\x18starting_sequence_number\x18\x06 \x01(\tH\x01R\x16startingSequenceNumber\x88\x01\x01\x12!\n\ttimestamp\x18\x07 \x01(\tH\x02R\ttimestamp\x88\x01\x01\x12!\n\x0bstream_name\x18\x08 \x01(\tH\x00R\nstreamName\x12\x1f\n\nstream_arn\x18\t \x01(\tH\x00R\tstreamArnB\x13\n\x11stream_identifierB\x1b\n\x19_starting_sequence_numberB\x0c\n\n_timestamp\"\xff\x01\n\x11ShardIteratorType\x12#\n\x1fSHARD_ITERATOR_TYPE_UNSPECIFIED\x10\x00\x12*\n&SHARD_ITERATOR_TYPE_AT_SEQUENCE_NUMBER\x10\x01\x12-\n)SHARD_ITERATOR_TYPE_AFTER_SEQUENCE_NUMBER\x10\x02\x12$\n SHARD_ITERATOR_TYPE_AT_TIMESTAMP\x10\x03\x12$\n SHARD_ITERATOR_TYPE_TRIM_HORIZON\x10\x04\x12\x1e\n\x1aSHARD_ITERATOR_TYPE_LATEST\x10\x05\x42\x0b\n\toperationB\x07\n\x05_nameB!\n\x1f_dynamic_workflow_configuration\"$\n\x08Metadata\x12\x18\n\x07streams\x18\x01 \x03(\tR\x07streamsBBZ@github.com/superblocksteam/agent/types/gen/go/plugins/kinesis/v1b\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1fplugins/kinesis/v1/plugin.proto\x12\x12plugins.kinesis.v1\x1a\x1eplugins/common/v1/plugin.proto\"\xc3\n\n\x06Plugin\x12\x17\n\x04name\x18\x01 \x01(\tH\x01R\x04name\x88\x01\x01\x12L\n\nconnection\x18\x02 \x01(\x0b\x32,.plugins.kinesis.v1.Plugin.KinesisConnectionR\nconnection\x12\x39\n\x03put\x18\x03 \x01(\x0b\x32%.plugins.kinesis.v1.Plugin.KinesisPutH\x00R\x03put\x12\x39\n\x03get\x18\x04 \x01(\x0b\x32%.plugins.kinesis.v1.Plugin.KinesisGetH\x00R\x03get\x12z\n\x1e\x64ynamic_workflow_configuration\x18\x05 \x01(\x0b\x32/.plugins.common.v1.DynamicWorkflowConfigurationH\x02R\x1c\x64ynamicWorkflowConfiguration\x88\x01\x01\x1aP\n\x11KinesisConnection\x12;\n\naws_config\x18\x01 \x01(\x0b\x32\x1c.plugins.common.v1.AWSConfigR\tawsConfig\x1a\x9e\x01\n\nKinesisPut\x12\x12\n\x04\x64\x61ta\x18\x01 \x01(\tR\x04\x64\x61ta\x12#\n\rpartition_key\x18\x02 \x01(\tR\x0cpartitionKey\x12!\n\x0bstream_name\x18\x03 \x01(\tH\x00R\nstreamName\x12\x1f\n\nstream_arn\x18\x04 \x01(\tH\x00R\tstreamArnB\x13\n\x11stream_identifier\x1a\xb1\x03\n\nKinesisGet\x12\x19\n\x08shard_id\x18\x02 \x01(\tR\x07shardId\x12\\\n\x13shard_iterator_type\x18\x03 \x01(\x0e\x32,.plugins.kinesis.v1.Plugin.ShardIteratorTypeR\x11shardIteratorType\x12\x14\n\x05limit\x18\x04 \x01(\x05R\x05limit\x12.\n\x13polling_cooldown_ms\x18\x05 \x01(\x05R\x11pollingCooldownMs\x12=\n\x18starting_sequence_number\x18\x06 \x01(\tH\x01R\x16startingSequenceNumber\x88\x01\x01\x12!\n\ttimestamp\x18\x07 \x01(\tH\x02R\ttimestamp\x88\x01\x01\x12!\n\x0bstream_name\x18\x08 \x01(\tH\x00R\nstreamName\x12\x1f\n\nstream_arn\x18\t \x01(\tH\x00R\tstreamArnB\x13\n\x11stream_identifierB\x1b\n\x19_starting_sequence_numberB\x0c\n\n_timestamp\"\xff\x01\n\x11ShardIteratorType\x12#\n\x1fSHARD_ITERATOR_TYPE_UNSPECIFIED\x10\x00\x12*\n&SHARD_ITERATOR_TYPE_AT_SEQUENCE_NUMBER\x10\x01\x12-\n)SHARD_ITERATOR_TYPE_AFTER_SEQUENCE_NUMBER\x10\x02\x12$\n SHARD_ITERATOR_TYPE_AT_TIMESTAMP\x10\x03\x12$\n SHARD_ITERATOR_TYPE_TRIM_HORIZON\x10\x04\x12\x1e\n\x1aSHARD_ITERATOR_TYPE_LATEST\x10\x05\x42\x0b\n\toperationB\x07\n\x05_nameB!\n\x1f_dynamic_workflow_configuration\"$\n\x08Metadata\x12\x18\n\x07streams\x18\x01 \x03(\tR\x07streamsBBZ@github.com/superblocksteam/agent/types/gen/go/plugins/kinesis/v1b\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -34,15 +34,15 @@ _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z@github.com/superblocksteam/agent/types/gen/go/plugins/kinesis/v1' _globals['_PLUGIN']._serialized_start=88 - _globals['_PLUGIN']._serialized_end=1407 - _globals['_PLUGIN_KINESISCONNECTION']._serialized_start=429 - _globals['_PLUGIN_KINESISCONNECTION']._serialized_end=509 - _globals['_PLUGIN_PUT']._serialized_start=512 - _globals['_PLUGIN_PUT']._serialized_end=663 - _globals['_PLUGIN_GET']._serialized_start=666 - _globals['_PLUGIN_GET']._serialized_end=1092 - _globals['_PLUGIN_SHARDITERATORTYPE']._serialized_start=1095 - _globals['_PLUGIN_SHARDITERATORTYPE']._serialized_end=1350 - _globals['_METADATA']._serialized_start=1409 - _globals['_METADATA']._serialized_end=1445 + _globals['_PLUGIN']._serialized_end=1435 + _globals['_PLUGIN_KINESISCONNECTION']._serialized_start=443 + _globals['_PLUGIN_KINESISCONNECTION']._serialized_end=523 + _globals['_PLUGIN_KINESISPUT']._serialized_start=526 + _globals['_PLUGIN_KINESISPUT']._serialized_end=684 + _globals['_PLUGIN_KINESISGET']._serialized_start=687 + _globals['_PLUGIN_KINESISGET']._serialized_end=1120 + _globals['_PLUGIN_SHARDITERATORTYPE']._serialized_start=1123 + _globals['_PLUGIN_SHARDITERATORTYPE']._serialized_end=1378 + _globals['_METADATA']._serialized_start=1437 + _globals['_METADATA']._serialized_end=1473 # @@protoc_insertion_point(module_scope) diff --git a/types/proto/plugins/kinesis/v1/plugin.proto b/types/proto/plugins/kinesis/v1/plugin.proto index 3b0f74f1..3f541898 100644 --- a/types/proto/plugins/kinesis/v1/plugin.proto +++ b/types/proto/plugins/kinesis/v1/plugin.proto @@ -10,8 +10,8 @@ message Plugin { optional string name = 1; KinesisConnection connection = 2; oneof operation { - Put put = 3; - Get get = 4; + KinesisPut put = 3; + KinesisGet get = 4; } optional plugins.common.v1.DynamicWorkflowConfiguration dynamic_workflow_configuration = 5; @@ -21,7 +21,7 @@ message Plugin { // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html - message Put { + message KinesisPut { string data = 1; string partition_key = 2; oneof stream_identifier { @@ -38,7 +38,7 @@ message Plugin { // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html // we will need to get a shard iterator first // https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html - message Get { + message KinesisGet { string shard_id = 2; ShardIteratorType shard_iterator_type = 3; int32 limit = 4; diff --git a/workers/javascript/package-lock.json b/workers/javascript/package-lock.json index 074d47b8..1b076961 100644 --- a/workers/javascript/package-lock.json +++ b/workers/javascript/package-lock.json @@ -21,6 +21,7 @@ "resolved": "https://registry.npmjs.org/pnpm/-/pnpm-9.7.1.tgz", "integrity": "sha512-+vNEry1splxMXIwiJOp3qBpeiFnLxOBrFRHdzi8BUVEkMd0Z5q/zHyxqj18qztm9InPh/tfdTeGGiYQFnSxCRw==", "dev": true, + "license": "MIT", "bin": { "pnpm": "bin/pnpm.cjs", "pnpx": "bin/pnpx.cjs" diff --git a/workers/javascript/packages/plugins/kinesis/src/index.ts b/workers/javascript/packages/plugins/kinesis/src/index.ts index e8f7e8e4..8dfc7a2d 100644 --- a/workers/javascript/packages/plugins/kinesis/src/index.ts +++ b/workers/javascript/packages/plugins/kinesis/src/index.ts @@ -50,7 +50,7 @@ export default class KinesisPlugin extends BasePlugin { throw new IntegrationError(`options.until not set.`); } - const get = props.actionConfiguration.operation.value as Plugin.Plugin_Get; + const get = props.actionConfiguration.operation.value as Plugin.Plugin_KinesisGet; if (!get.pollingCooldownMs || get.pollingCooldownMs <= 0) { throw new IntegrationError('pollingCooldownMs must be present and greater than 0'); @@ -115,7 +115,7 @@ export default class KinesisPlugin extends BasePlugin { 'The consume action is not supported outside of a Stream block trigger. Please add a Stream block and place this block in the Trigger section' ); } - const put = (actionConfiguration as KinesisActionConfiguration).operation.value as Plugin.Plugin_Put; + const put = (actionConfiguration as KinesisActionConfiguration).operation.value as Plugin.Plugin_KinesisPut; const output: ExecutionOutput = new ExecutionOutput(); { diff --git a/workers/javascript/packages/plugins/kinesis/src/utils.test.ts b/workers/javascript/packages/plugins/kinesis/src/utils.test.ts index de74c844..9eb2605f 100644 --- a/workers/javascript/packages/plugins/kinesis/src/utils.test.ts +++ b/workers/javascript/packages/plugins/kinesis/src/utils.test.ts @@ -101,7 +101,7 @@ describe('acGetToGetShardIteratorCommand happy path', () => { expectedOutput: { ShardIteratorType: 'TRIM_HORIZON', ShardId: 'si', StreamARN: 'sa' } } ])('$description', ({ acGet, expectedOutput }) => { - expect(acGetToGetShardIteratorCommand(acGet as Plugin.Plugin_Get)).toEqual(expectedOutput); + expect(acGetToGetShardIteratorCommand(acGet as Plugin.Plugin_KinesisGet)).toEqual(expectedOutput); }); }); @@ -118,7 +118,7 @@ describe('acGetToGetShardIteratorCommand throws', () => { } ])('$description', ({ acGet, expectedErrorMessage }) => { expect(() => { - acGetToGetShardIteratorCommand(acGet as Plugin.Plugin_Get); + acGetToGetShardIteratorCommand(acGet as Plugin.Plugin_KinesisGet); }).toThrow(expectedErrorMessage); }); }); @@ -201,7 +201,7 @@ describe('configFromShardIteratorType happy path', () => { expectedConfig: { ShardIteratorType: 'AFTER_SEQUENCE_NUMBER', StartingSequenceNumber: '12345' } } ])('$description', ({ acGet, expectedConfig }) => { - expect(configFromShardIteratorType(acGet as Plugin.Plugin_Get)).toEqual(expectedConfig); + expect(configFromShardIteratorType(acGet as Plugin.Plugin_KinesisGet)).toEqual(expectedConfig); }); }); @@ -229,7 +229,7 @@ describe('convertShardIteratorType throws', () => { } ])('$description', ({ acGet, expectedErrorMessage }) => { expect(() => { - configFromShardIteratorType(acGet as Plugin.Plugin_Get); + configFromShardIteratorType(acGet as Plugin.Plugin_KinesisGet); }).toThrow(expectedErrorMessage); }); }); diff --git a/workers/javascript/packages/plugins/kinesis/src/utils.ts b/workers/javascript/packages/plugins/kinesis/src/utils.ts index 3bc1de17..7ab8c7b5 100644 --- a/workers/javascript/packages/plugins/kinesis/src/utils.ts +++ b/workers/javascript/packages/plugins/kinesis/src/utils.ts @@ -5,7 +5,7 @@ import { KinesisPluginV1 as Plugin } from '@superblocksteam/types'; // https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis/command/PutRecordsCommand/ export function actionConfigurationToRecords(actionConfiguration: KinesisActionConfiguration): PutRecordsRequestEntry[] { - const put = actionConfiguration.operation.value as Plugin.Plugin_Put; + const put = actionConfiguration.operation.value as Plugin.Plugin_KinesisPut; const partitionKey = put.partitionKey; if (!partitionKey) { throw new IntegrationError('partitionKey is required'); @@ -57,7 +57,7 @@ export function getStreamIdentifierConfig(streamIdentifier: any): StreamIdentifi } // converts the ac (action configuration) GET object to something AWS can handle -export function acGetToGetShardIteratorCommand(acGet: Plugin.Plugin_Get): GetShardIteratorCommandInput { +export function acGetToGetShardIteratorCommand(acGet: Plugin.Plugin_KinesisGet): GetShardIteratorCommandInput { const shardIteratorConfig = configFromShardIteratorType(acGet); const streamIdentifierConfig = getStreamIdentifierConfig(acGet.streamIdentifier); return { ShardId: acGet.shardId, ...shardIteratorConfig, ...streamIdentifierConfig } as GetShardIteratorCommandInput; @@ -70,7 +70,7 @@ type ShardConfig = { StartingSequenceNumber?: string; }; // eslint-disable-next-line @typescript-eslint/no-explicit-any -export function configFromShardIteratorType(acGet: Plugin.Plugin_Get): ShardConfig { +export function configFromShardIteratorType(acGet: Plugin.Plugin_KinesisGet): ShardConfig { switch (acGet.shardIteratorType) { case Plugin.Plugin_ShardIteratorType.TRIM_HORIZON: return { ShardIteratorType: 'TRIM_HORIZON' }; diff --git a/workers/javascript/packages/types/src/plugins/kinesis/v1/plugin_pb.ts b/workers/javascript/packages/types/src/plugins/kinesis/v1/plugin_pb.ts index 345d43dc..1500bb39 100644 --- a/workers/javascript/packages/types/src/plugins/kinesis/v1/plugin_pb.ts +++ b/workers/javascript/packages/types/src/plugins/kinesis/v1/plugin_pb.ts @@ -26,15 +26,15 @@ export class Plugin extends Message { */ operation: { /** - * @generated from field: plugins.kinesis.v1.Plugin.Put put = 3; + * @generated from field: plugins.kinesis.v1.Plugin.KinesisPut put = 3; */ - value: Plugin_Put; + value: Plugin_KinesisPut; case: "put"; } | { /** - * @generated from field: plugins.kinesis.v1.Plugin.Get get = 4; + * @generated from field: plugins.kinesis.v1.Plugin.KinesisGet get = 4; */ - value: Plugin_Get; + value: Plugin_KinesisGet; case: "get"; } | { case: undefined; value?: undefined } = { case: undefined }; @@ -53,8 +53,8 @@ export class Plugin extends Message { static readonly fields: FieldList = proto3.util.newFieldList(() => [ { no: 1, name: "name", kind: "scalar", T: 9 /* ScalarType.STRING */, opt: true }, { no: 2, name: "connection", kind: "message", T: Plugin_KinesisConnection }, - { no: 3, name: "put", kind: "message", T: Plugin_Put, oneof: "operation" }, - { no: 4, name: "get", kind: "message", T: Plugin_Get, oneof: "operation" }, + { no: 3, name: "put", kind: "message", T: Plugin_KinesisPut, oneof: "operation" }, + { no: 4, name: "get", kind: "message", T: Plugin_KinesisGet, oneof: "operation" }, { no: 5, name: "dynamic_workflow_configuration", kind: "message", T: DynamicWorkflowConfiguration, opt: true }, ]); @@ -162,9 +162,9 @@ export class Plugin_KinesisConnection extends Message * https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html * https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html * - * @generated from message plugins.kinesis.v1.Plugin.Put + * @generated from message plugins.kinesis.v1.Plugin.KinesisPut */ -export class Plugin_Put extends Message { +export class Plugin_KinesisPut extends Message { /** * @generated from field: string data = 1; */ @@ -176,7 +176,7 @@ export class Plugin_Put extends Message { partitionKey = ""; /** - * @generated from oneof plugins.kinesis.v1.Plugin.Put.stream_identifier + * @generated from oneof plugins.kinesis.v1.Plugin.KinesisPut.stream_identifier */ streamIdentifier: { /** @@ -192,13 +192,13 @@ export class Plugin_Put extends Message { case: "streamArn"; } | { case: undefined; value?: undefined } = { case: undefined }; - constructor(data?: PartialMessage) { + constructor(data?: PartialMessage) { super(); proto3.util.initPartial(data, this); } static readonly runtime: typeof proto3 = proto3; - static readonly typeName = "plugins.kinesis.v1.Plugin.Put"; + static readonly typeName = "plugins.kinesis.v1.Plugin.KinesisPut"; static readonly fields: FieldList = proto3.util.newFieldList(() => [ { no: 1, name: "data", kind: "scalar", T: 9 /* ScalarType.STRING */ }, { no: 2, name: "partition_key", kind: "scalar", T: 9 /* ScalarType.STRING */ }, @@ -206,20 +206,20 @@ export class Plugin_Put extends Message { { no: 4, name: "stream_arn", kind: "scalar", T: 9 /* ScalarType.STRING */, oneof: "stream_identifier" }, ]); - static fromBinary(bytes: Uint8Array, options?: Partial): Plugin_Put { - return new Plugin_Put().fromBinary(bytes, options); + static fromBinary(bytes: Uint8Array, options?: Partial): Plugin_KinesisPut { + return new Plugin_KinesisPut().fromBinary(bytes, options); } - static fromJson(jsonValue: JsonValue, options?: Partial): Plugin_Put { - return new Plugin_Put().fromJson(jsonValue, options); + static fromJson(jsonValue: JsonValue, options?: Partial): Plugin_KinesisPut { + return new Plugin_KinesisPut().fromJson(jsonValue, options); } - static fromJsonString(jsonString: string, options?: Partial): Plugin_Put { - return new Plugin_Put().fromJsonString(jsonString, options); + static fromJsonString(jsonString: string, options?: Partial): Plugin_KinesisPut { + return new Plugin_KinesisPut().fromJsonString(jsonString, options); } - static equals(a: Plugin_Put | PlainMessage | undefined, b: Plugin_Put | PlainMessage | undefined): boolean { - return proto3.util.equals(Plugin_Put, a, b); + static equals(a: Plugin_KinesisPut | PlainMessage | undefined, b: Plugin_KinesisPut | PlainMessage | undefined): boolean { + return proto3.util.equals(Plugin_KinesisPut, a, b); } } @@ -228,9 +228,9 @@ export class Plugin_Put extends Message { * we will need to get a shard iterator first * https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html * - * @generated from message plugins.kinesis.v1.Plugin.Get + * @generated from message plugins.kinesis.v1.Plugin.KinesisGet */ -export class Plugin_Get extends Message { +export class Plugin_KinesisGet extends Message { /** * @generated from field: string shard_id = 2; */ @@ -267,7 +267,7 @@ export class Plugin_Get extends Message { timestamp?: string; /** - * @generated from oneof plugins.kinesis.v1.Plugin.Get.stream_identifier + * @generated from oneof plugins.kinesis.v1.Plugin.KinesisGet.stream_identifier */ streamIdentifier: { /** @@ -283,13 +283,13 @@ export class Plugin_Get extends Message { case: "streamArn"; } | { case: undefined; value?: undefined } = { case: undefined }; - constructor(data?: PartialMessage) { + constructor(data?: PartialMessage) { super(); proto3.util.initPartial(data, this); } static readonly runtime: typeof proto3 = proto3; - static readonly typeName = "plugins.kinesis.v1.Plugin.Get"; + static readonly typeName = "plugins.kinesis.v1.Plugin.KinesisGet"; static readonly fields: FieldList = proto3.util.newFieldList(() => [ { no: 2, name: "shard_id", kind: "scalar", T: 9 /* ScalarType.STRING */ }, { no: 3, name: "shard_iterator_type", kind: "enum", T: proto3.getEnumType(Plugin_ShardIteratorType) }, @@ -301,20 +301,20 @@ export class Plugin_Get extends Message { { no: 9, name: "stream_arn", kind: "scalar", T: 9 /* ScalarType.STRING */, oneof: "stream_identifier" }, ]); - static fromBinary(bytes: Uint8Array, options?: Partial): Plugin_Get { - return new Plugin_Get().fromBinary(bytes, options); + static fromBinary(bytes: Uint8Array, options?: Partial): Plugin_KinesisGet { + return new Plugin_KinesisGet().fromBinary(bytes, options); } - static fromJson(jsonValue: JsonValue, options?: Partial): Plugin_Get { - return new Plugin_Get().fromJson(jsonValue, options); + static fromJson(jsonValue: JsonValue, options?: Partial): Plugin_KinesisGet { + return new Plugin_KinesisGet().fromJson(jsonValue, options); } - static fromJsonString(jsonString: string, options?: Partial): Plugin_Get { - return new Plugin_Get().fromJsonString(jsonString, options); + static fromJsonString(jsonString: string, options?: Partial): Plugin_KinesisGet { + return new Plugin_KinesisGet().fromJsonString(jsonString, options); } - static equals(a: Plugin_Get | PlainMessage | undefined, b: Plugin_Get | PlainMessage | undefined): boolean { - return proto3.util.equals(Plugin_Get, a, b); + static equals(a: Plugin_KinesisGet | PlainMessage | undefined, b: Plugin_KinesisGet | PlainMessage | undefined): boolean { + return proto3.util.equals(Plugin_KinesisGet, a, b); } }