Skip to content
Snippets Groups Projects
Commit 703155c9 authored by Malte Bauch's avatar Malte Bauch
Browse files

Allow requesting Plugins via API

parent 5c7e76d2
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
go/gosdn/csbi/csbi.pb.go
+ 107
− 173
View file @ 703155c9
...@@ -125,7 +125,7 @@ func (x DeleteResponse_Status) Number() protoreflect.EnumNumber { ...@@ -125,7 +125,7 @@ func (x DeleteResponse_Status) Number() protoreflect.EnumNumber {
// Deprecated: Use DeleteResponse_Status.Descriptor instead. // Deprecated: Use DeleteResponse_Status.Descriptor instead.
func (DeleteResponse_Status) EnumDescriptor() ([]byte, []int) { func (DeleteResponse_Status) EnumDescriptor() ([]byte, []int) {
return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{10, 0} return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{9, 0}
} }
type Syn struct { type Syn struct {
...@@ -482,61 +482,6 @@ func (x *CreateRequest) GetTransportOption() []*transport.TransportOption { ...@@ -482,61 +482,6 @@ func (x *CreateRequest) GetTransportOption() []*transport.TransportOption {
return nil return nil
} }
type CreatePluginRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Timestamp in nanoseconds since Epoch.
TransportOption []*transport.TransportOption `protobuf:"bytes,2,rep,name=transport_option,json=transportOption,proto3" json:"transport_option,omitempty"`
}
func (x *CreatePluginRequest) Reset() {
*x = CreatePluginRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CreatePluginRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreatePluginRequest) ProtoMessage() {}
func (x *CreatePluginRequest) ProtoReflect() protoreflect.Message {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreatePluginRequest.ProtoReflect.Descriptor instead.
func (*CreatePluginRequest) Descriptor() ([]byte, []int) {
return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{6}
}
func (x *CreatePluginRequest) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *CreatePluginRequest) GetTransportOption() []*transport.TransportOption {
if x != nil {
return x.TransportOption
}
return nil
}
type CreateResponse struct { type CreateResponse struct {
state protoimpl.MessageState state protoimpl.MessageState
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
...@@ -549,7 +494,7 @@ type CreateResponse struct { ...@@ -549,7 +494,7 @@ type CreateResponse struct {
func (x *CreateResponse) Reset() { func (x *CreateResponse) Reset() {
*x = CreateResponse{} *x = CreateResponse{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[7] mi := &file_gosdn_csbi_csbi_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
...@@ -562,7 +507,7 @@ func (x *CreateResponse) String() string { ...@@ -562,7 +507,7 @@ func (x *CreateResponse) String() string {
func (*CreateResponse) ProtoMessage() {} func (*CreateResponse) ProtoMessage() {}
func (x *CreateResponse) ProtoReflect() protoreflect.Message { func (x *CreateResponse) ProtoReflect() protoreflect.Message {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[7] mi := &file_gosdn_csbi_csbi_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
...@@ -575,7 +520,7 @@ func (x *CreateResponse) ProtoReflect() protoreflect.Message { ...@@ -575,7 +520,7 @@ func (x *CreateResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead. // Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) Descriptor() ([]byte, []int) { func (*CreateResponse) Descriptor() ([]byte, []int) {
return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{7} return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{6}
} }
func (x *CreateResponse) GetTimestamp() int64 { func (x *CreateResponse) GetTimestamp() int64 {
...@@ -603,7 +548,7 @@ type Payload struct { ...@@ -603,7 +548,7 @@ type Payload struct {
func (x *Payload) Reset() { func (x *Payload) Reset() {
*x = Payload{} *x = Payload{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[8] mi := &file_gosdn_csbi_csbi_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
...@@ -616,7 +561,7 @@ func (x *Payload) String() string { ...@@ -616,7 +561,7 @@ func (x *Payload) String() string {
func (*Payload) ProtoMessage() {} func (*Payload) ProtoMessage() {}
func (x *Payload) ProtoReflect() protoreflect.Message { func (x *Payload) ProtoReflect() protoreflect.Message {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[8] mi := &file_gosdn_csbi_csbi_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
...@@ -629,7 +574,7 @@ func (x *Payload) ProtoReflect() protoreflect.Message { ...@@ -629,7 +574,7 @@ func (x *Payload) ProtoReflect() protoreflect.Message {
// Deprecated: Use Payload.ProtoReflect.Descriptor instead. // Deprecated: Use Payload.ProtoReflect.Descriptor instead.
func (*Payload) Descriptor() ([]byte, []int) { func (*Payload) Descriptor() ([]byte, []int) {
return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{8} return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{7}
} }
func (x *Payload) GetChunk() []byte { func (x *Payload) GetChunk() []byte {
...@@ -651,7 +596,7 @@ type DeleteRequest struct { ...@@ -651,7 +596,7 @@ type DeleteRequest struct {
func (x *DeleteRequest) Reset() { func (x *DeleteRequest) Reset() {
*x = DeleteRequest{} *x = DeleteRequest{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[9] mi := &file_gosdn_csbi_csbi_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
...@@ -664,7 +609,7 @@ func (x *DeleteRequest) String() string { ...@@ -664,7 +609,7 @@ func (x *DeleteRequest) String() string {
func (*DeleteRequest) ProtoMessage() {} func (*DeleteRequest) ProtoMessage() {}
func (x *DeleteRequest) ProtoReflect() protoreflect.Message { func (x *DeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[9] mi := &file_gosdn_csbi_csbi_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
...@@ -677,7 +622,7 @@ func (x *DeleteRequest) ProtoReflect() protoreflect.Message { ...@@ -677,7 +622,7 @@ func (x *DeleteRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead. // Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) Descriptor() ([]byte, []int) { func (*DeleteRequest) Descriptor() ([]byte, []int) {
return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{9} return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{8}
} }
func (x *DeleteRequest) GetTimestamp() int64 { func (x *DeleteRequest) GetTimestamp() int64 {
...@@ -706,7 +651,7 @@ type DeleteResponse struct { ...@@ -706,7 +651,7 @@ type DeleteResponse struct {
func (x *DeleteResponse) Reset() { func (x *DeleteResponse) Reset() {
*x = DeleteResponse{} *x = DeleteResponse{}
if protoimpl.UnsafeEnabled { if protoimpl.UnsafeEnabled {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[10] mi := &file_gosdn_csbi_csbi_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi) ms.StoreMessageInfo(mi)
} }
...@@ -719,7 +664,7 @@ func (x *DeleteResponse) String() string { ...@@ -719,7 +664,7 @@ func (x *DeleteResponse) String() string {
func (*DeleteResponse) ProtoMessage() {} func (*DeleteResponse) ProtoMessage() {}
func (x *DeleteResponse) ProtoReflect() protoreflect.Message { func (x *DeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_gosdn_csbi_csbi_proto_msgTypes[10] mi := &file_gosdn_csbi_csbi_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil { if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil { if ms.LoadMessageInfo() == nil {
...@@ -732,7 +677,7 @@ func (x *DeleteResponse) ProtoReflect() protoreflect.Message { ...@@ -732,7 +677,7 @@ func (x *DeleteResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead. // Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) Descriptor() ([]byte, []int) { func (*DeleteResponse) Descriptor() ([]byte, []int) {
return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{10} return file_gosdn_csbi_csbi_proto_rawDescGZIP(), []int{9}
} }
func (x *DeleteResponse) GetTimestamp() int64 { func (x *DeleteResponse) GetTimestamp() int64 {
...@@ -793,70 +738,69 @@ var file_gosdn_csbi_csbi_proto_rawDesc = []byte{ ...@@ -793,70 +738,69 @@ var file_gosdn_csbi_csbi_proto_rawDesc = []byte{
0x32, 0x20, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f,
0x72, 0x74, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4f, 0x70, 0x74, 0x69, 0x72, 0x74, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4f, 0x70, 0x74, 0x69,
0x6f, 0x6e, 0x52, 0x0f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4f, 0x70, 0x74, 0x6f, 0x6e, 0x52, 0x0f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4f, 0x70, 0x74,
0x69, 0x6f, 0x6e, 0x22, 0x80, 0x01, 0x0a, 0x13, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x6c, 0x69, 0x6f, 0x6e, 0x22, 0x68, 0x0a, 0x0e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73,
0x75, 0x67, 0x69, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74,
0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09,
0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x4b, 0x0a, 0x10, 0x74, 0x72, 0x61,
0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x74, 0x72, 0x61, 0x6e,
0x73, 0x70, 0x6f, 0x72, 0x74, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x4f,
0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74,
0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x68, 0x0a, 0x0e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65,
0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65,
0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d,
0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x38, 0x0a, 0x0b, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79,
0x6d, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x6f,
0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d,
0x65, 0x6e, 0x74, 0x52, 0x0b, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x73,
0x22, 0x1f, 0x0a, 0x07, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x63,
0x68, 0x75, 0x6e, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x63, 0x68, 0x75, 0x6e,
0x6b, 0x22, 0x3f, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18,
0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70,
0x12, 0x10, 0x0a, 0x03, 0x64, 0x69, 0x64, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x03, 0x64,
0x69, 0x64, 0x22, 0xac, 0x01, 0x0a, 0x0e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x73,
0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
0x61, 0x6d, 0x70, 0x12, 0x39, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x61, 0x6d, 0x70, 0x12, 0x38, 0x0a, 0x0b, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e,
0x01, 0x28, 0x0e, 0x32, 0x21, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e,
0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x44, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74,
0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x41, 0x52, 0x0b, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x22, 0x1f, 0x0a,
0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x16, 0x0a, 0x12, 0x53, 0x54, 0x41, 0x54, 0x07, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x68, 0x75, 0x6e,
0x55, 0x53, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x63, 0x68, 0x75, 0x6e, 0x6b, 0x22, 0x3f,
0x12, 0x0d, 0x0a, 0x09, 0x53, 0x54, 0x41, 0x54, 0x55, 0x53, 0x5f, 0x4f, 0x4b, 0x10, 0x01, 0x12, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
0x10, 0x0a, 0x0c, 0x53, 0x54, 0x41, 0x54, 0x55, 0x53, 0x5f, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01,
0x02, 0x2a, 0x85, 0x01, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x15, 0x0a, 0x11, 0x53, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x10, 0x0a,
0x54, 0x41, 0x54, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x03, 0x64, 0x69, 0x64, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x03, 0x64, 0x69, 0x64, 0x22,
0x10, 0x00, 0x12, 0x13, 0x0a, 0x0f, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x41, 0x4e, 0x4e, 0x4f, 0xac, 0x01, 0x0a, 0x0e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x55, 0x4e, 0x43, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0f, 0x0a, 0x0b, 0x53, 0x54, 0x41, 0x54, 0x45, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18,
0x5f, 0x42, 0x55, 0x49, 0x4c, 0x54, 0x10, 0x02, 0x12, 0x12, 0x0a, 0x0e, 0x53, 0x54, 0x41, 0x54, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70,
0x45, 0x5f, 0x44, 0x45, 0x50, 0x4c, 0x4f, 0x59, 0x45, 0x44, 0x10, 0x03, 0x12, 0x11, 0x0a, 0x0d, 0x12, 0x39, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e,
0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x52, 0x55, 0x4e, 0x4e, 0x49, 0x4e, 0x47, 0x10, 0x04, 0x12, 0x32, 0x21, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x44, 0x65,
0x18, 0x0a, 0x14, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x44, 0x45, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x53, 0x74, 0x61,
0x53, 0x53, 0x49, 0x4f, 0x4e, 0x45, 0x44, 0x10, 0x05, 0x32, 0xba, 0x02, 0x0a, 0x0b, 0x43, 0x73, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x41, 0x0a, 0x06, 0x53,
0x62, 0x69, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x36, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x16, 0x0a, 0x12, 0x53, 0x54, 0x41, 0x54, 0x55, 0x53, 0x5f,
0x12, 0x16, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x47, 0x65, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0d, 0x0a,
0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x09, 0x53, 0x54, 0x41, 0x54, 0x55, 0x53, 0x5f, 0x4f, 0x4b, 0x10, 0x01, 0x12, 0x10, 0x0a, 0x0c,
0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x53, 0x54, 0x41, 0x54, 0x55, 0x53, 0x5f, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x02, 0x2a, 0x85,
0x65, 0x12, 0x3f, 0x0a, 0x06, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x12, 0x19, 0x2e, 0x67, 0x6f, 0x01, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x15, 0x0a, 0x11, 0x53, 0x54, 0x41, 0x54,
0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x13, 0x0a, 0x0f, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x41, 0x4e, 0x4e, 0x4f, 0x55, 0x4e, 0x43,
0x73, 0x62, 0x69, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0f, 0x0a, 0x0b, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x42, 0x55,
0x73, 0x65, 0x12, 0x3f, 0x0a, 0x06, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x19, 0x2e, 0x67, 0x49, 0x4c, 0x54, 0x10, 0x02, 0x12, 0x12, 0x0a, 0x0e, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x44,
0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x45, 0x50, 0x4c, 0x4f, 0x59, 0x45, 0x44, 0x10, 0x03, 0x12, 0x11, 0x0a, 0x0d, 0x53, 0x54, 0x41,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x54, 0x45, 0x5f, 0x52, 0x55, 0x4e, 0x4e, 0x49, 0x4e, 0x47, 0x10, 0x04, 0x12, 0x18, 0x0a, 0x14,
0x63, 0x73, 0x62, 0x69, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f, 0x44, 0x45, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x53, 0x53, 0x49,
0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x05, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x12, 0x0f, 0x2e, 0x67, 0x4f, 0x4e, 0x45, 0x44, 0x10, 0x05, 0x32, 0xb2, 0x03, 0x0a, 0x0b, 0x43, 0x73, 0x62, 0x69, 0x53,
0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x53, 0x79, 0x6e, 0x1a, 0x0f, 0x2e, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x36, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, 0x16, 0x2e,
0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x41, 0x63, 0x6b, 0x12, 0x46, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65,
0x0a, 0x0c, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x12, 0x1f, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73,
0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x62, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3c,
0x74, 0x65, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0a, 0x0b, 0x47, 0x65, 0x74, 0x47, 0x6f, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x12, 0x16, 0x2e,
0x13, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x50, 0x61, 0x79, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65,
0x6c, 0x6f, 0x61, 0x64, 0x30, 0x01, 0x42, 0x2a, 0x5a, 0x28, 0x63, 0x6f, 0x64, 0x65, 0x2e, 0x66, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x13, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73,
0x62, 0x69, 0x2e, 0x68, 0x2d, 0x64, 0x61, 0x2e, 0x64, 0x65, 0x2f, 0x64, 0x61, 0x6e, 0x65, 0x74, 0x62, 0x69, 0x2e, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x30, 0x01, 0x12, 0x3c, 0x0a, 0x0b,
0x2f, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2f, 0x63, 0x73, 0x47, 0x65, 0x74, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x12, 0x16, 0x2e, 0x67, 0x6f,
0x62, 0x69, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x1a, 0x13, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69,
0x2e, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x30, 0x01, 0x12, 0x3f, 0x0a, 0x06, 0x43, 0x72,
0x65, 0x61, 0x74, 0x65, 0x12, 0x19, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62,
0x69, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
0x1a, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x43, 0x72, 0x65,
0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3f, 0x0a, 0x06, 0x44,
0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x19, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73,
0x62, 0x69, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x1a, 0x1a, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x44, 0x65,
0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x05,
0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x12, 0x0f, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73,
0x62, 0x69, 0x2e, 0x53, 0x79, 0x6e, 0x1a, 0x0f, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63,
0x73, 0x62, 0x69, 0x2e, 0x41, 0x63, 0x6b, 0x12, 0x42, 0x0a, 0x0e, 0x43, 0x72, 0x65, 0x61, 0x74,
0x65, 0x47, 0x6f, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x12, 0x19, 0x2e, 0x67, 0x6f, 0x73, 0x64,
0x6e, 0x2e, 0x63, 0x73, 0x62, 0x69, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74, 0x1a, 0x13, 0x2e, 0x67, 0x6f, 0x73, 0x64, 0x6e, 0x2e, 0x63, 0x73, 0x62,
0x69, 0x2e, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x30, 0x01, 0x42, 0x2a, 0x5a, 0x28, 0x63,
0x6f, 0x64, 0x65, 0x2e, 0x66, 0x62, 0x69, 0x2e, 0x68, 0x2d, 0x64, 0x61, 0x2e, 0x64, 0x65, 0x2f,
0x64, 0x61, 0x6e, 0x65, 0x74, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x6f, 0x73,
0x64, 0x6e, 0x2f, 0x63, 0x73, 0x62, 0x69, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
} }
var ( var (
...@@ -872,7 +816,7 @@ func file_gosdn_csbi_csbi_proto_rawDescGZIP() []byte { ...@@ -872,7 +816,7 @@ func file_gosdn_csbi_csbi_proto_rawDescGZIP() []byte {
} }
var file_gosdn_csbi_csbi_proto_enumTypes = make([]protoimpl.EnumInfo, 2) var file_gosdn_csbi_csbi_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
var file_gosdn_csbi_csbi_proto_msgTypes = make([]protoimpl.MessageInfo, 11) var file_gosdn_csbi_csbi_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
var file_gosdn_csbi_csbi_proto_goTypes = []interface{}{ var file_gosdn_csbi_csbi_proto_goTypes = []interface{}{
(State)(0), // 0: gosdn.csbi.State (State)(0), // 0: gosdn.csbi.State
(DeleteResponse_Status)(0), // 1: gosdn.csbi.DeleteResponse.Status (DeleteResponse_Status)(0), // 1: gosdn.csbi.DeleteResponse.Status
...@@ -882,36 +826,38 @@ var file_gosdn_csbi_csbi_proto_goTypes = []interface{}{ ...@@ -882,36 +826,38 @@ var file_gosdn_csbi_csbi_proto_goTypes = []interface{}{
(*GetResponse)(nil), // 5: gosdn.csbi.GetResponse (*GetResponse)(nil), // 5: gosdn.csbi.GetResponse
(*Deployment)(nil), // 6: gosdn.csbi.Deployment (*Deployment)(nil), // 6: gosdn.csbi.Deployment
(*CreateRequest)(nil), // 7: gosdn.csbi.CreateRequest (*CreateRequest)(nil), // 7: gosdn.csbi.CreateRequest
(*CreatePluginRequest)(nil), // 8: gosdn.csbi.CreatePluginRequest (*CreateResponse)(nil), // 8: gosdn.csbi.CreateResponse
(*CreateResponse)(nil), // 9: gosdn.csbi.CreateResponse (*Payload)(nil), // 9: gosdn.csbi.Payload
(*Payload)(nil), // 10: gosdn.csbi.Payload (*DeleteRequest)(nil), // 10: gosdn.csbi.DeleteRequest
(*DeleteRequest)(nil), // 11: gosdn.csbi.DeleteRequest (*DeleteResponse)(nil), // 11: gosdn.csbi.DeleteResponse
(*DeleteResponse)(nil), // 12: gosdn.csbi.DeleteResponse (*transport.TransportOption)(nil), // 12: gosdn.transport.TransportOption
(*transport.TransportOption)(nil), // 13: gosdn.transport.TransportOption
} }
var file_gosdn_csbi_csbi_proto_depIdxs = []int32{ var file_gosdn_csbi_csbi_proto_depIdxs = []int32{
13, // 0: gosdn.csbi.Ack.transport_option:type_name -> gosdn.transport.TransportOption 12, // 0: gosdn.csbi.Ack.transport_option:type_name -> gosdn.transport.TransportOption
6, // 1: gosdn.csbi.GetResponse.deployments:type_name -> gosdn.csbi.Deployment 6, // 1: gosdn.csbi.GetResponse.deployments:type_name -> gosdn.csbi.Deployment
0, // 2: gosdn.csbi.Deployment.state:type_name -> gosdn.csbi.State 0, // 2: gosdn.csbi.Deployment.state:type_name -> gosdn.csbi.State
13, // 3: gosdn.csbi.CreateRequest.transport_option:type_name -> gosdn.transport.TransportOption 12, // 3: gosdn.csbi.CreateRequest.transport_option:type_name -> gosdn.transport.TransportOption
13, // 4: gosdn.csbi.CreatePluginRequest.transport_option:type_name -> gosdn.transport.TransportOption 6, // 4: gosdn.csbi.CreateResponse.deployments:type_name -> gosdn.csbi.Deployment
6, // 5: gosdn.csbi.CreateResponse.deployments:type_name -> gosdn.csbi.Deployment 1, // 5: gosdn.csbi.DeleteResponse.status:type_name -> gosdn.csbi.DeleteResponse.Status
1, // 6: gosdn.csbi.DeleteResponse.status:type_name -> gosdn.csbi.DeleteResponse.Status 4, // 6: gosdn.csbi.CsbiService.Get:input_type -> gosdn.csbi.GetRequest
4, // 7: gosdn.csbi.CsbiService.Get:input_type -> gosdn.csbi.GetRequest 4, // 7: gosdn.csbi.CsbiService.GetGoStruct:input_type -> gosdn.csbi.GetRequest
7, // 8: gosdn.csbi.CsbiService.Create:input_type -> gosdn.csbi.CreateRequest 4, // 8: gosdn.csbi.CsbiService.GetManifest:input_type -> gosdn.csbi.GetRequest
11, // 9: gosdn.csbi.CsbiService.Delete:input_type -> gosdn.csbi.DeleteRequest 7, // 9: gosdn.csbi.CsbiService.Create:input_type -> gosdn.csbi.CreateRequest
2, // 10: gosdn.csbi.CsbiService.Hello:input_type -> gosdn.csbi.Syn 10, // 10: gosdn.csbi.CsbiService.Delete:input_type -> gosdn.csbi.DeleteRequest
8, // 11: gosdn.csbi.CsbiService.CreatePlugin:input_type -> gosdn.csbi.CreatePluginRequest 2, // 11: gosdn.csbi.CsbiService.Hello:input_type -> gosdn.csbi.Syn
5, // 12: gosdn.csbi.CsbiService.Get:output_type -> gosdn.csbi.GetResponse 7, // 12: gosdn.csbi.CsbiService.CreateGoStruct:input_type -> gosdn.csbi.CreateRequest
9, // 13: gosdn.csbi.CsbiService.Create:output_type -> gosdn.csbi.CreateResponse 5, // 13: gosdn.csbi.CsbiService.Get:output_type -> gosdn.csbi.GetResponse
12, // 14: gosdn.csbi.CsbiService.Delete:output_type -> gosdn.csbi.DeleteResponse 9, // 14: gosdn.csbi.CsbiService.GetGoStruct:output_type -> gosdn.csbi.Payload
3, // 15: gosdn.csbi.CsbiService.Hello:output_type -> gosdn.csbi.Ack 9, // 15: gosdn.csbi.CsbiService.GetManifest:output_type -> gosdn.csbi.Payload
10, // 16: gosdn.csbi.CsbiService.CreatePlugin:output_type -> gosdn.csbi.Payload 8, // 16: gosdn.csbi.CsbiService.Create:output_type -> gosdn.csbi.CreateResponse
12, // [12:17] is the sub-list for method output_type 11, // 17: gosdn.csbi.CsbiService.Delete:output_type -> gosdn.csbi.DeleteResponse
7, // [7:12] is the sub-list for method input_type 3, // 18: gosdn.csbi.CsbiService.Hello:output_type -> gosdn.csbi.Ack
7, // [7:7] is the sub-list for extension type_name 9, // 19: gosdn.csbi.CsbiService.CreateGoStruct:output_type -> gosdn.csbi.Payload
7, // [7:7] is the sub-list for extension extendee 13, // [13:20] is the sub-list for method output_type
0, // [0:7] is the sub-list for field type_name 6, // [6:13] is the sub-list for method input_type
6, // [6:6] is the sub-list for extension type_name
6, // [6:6] is the sub-list for extension extendee
0, // [0:6] is the sub-list for field type_name
} }
func init() { file_gosdn_csbi_csbi_proto_init() } func init() { file_gosdn_csbi_csbi_proto_init() }
...@@ -993,18 +939,6 @@ func file_gosdn_csbi_csbi_proto_init() { ...@@ -993,18 +939,6 @@ func file_gosdn_csbi_csbi_proto_init() {
} }
} }
file_gosdn_csbi_csbi_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { file_gosdn_csbi_csbi_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CreatePluginRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CreateResponse); i { switch v := v.(*CreateResponse); i {
case 0: case 0:
return &v.state return &v.state
...@@ -1016,7 +950,7 @@ func file_gosdn_csbi_csbi_proto_init() { ...@@ -1016,7 +950,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil return nil
} }
} }
file_gosdn_csbi_csbi_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { file_gosdn_csbi_csbi_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Payload); i { switch v := v.(*Payload); i {
case 0: case 0:
return &v.state return &v.state
...@@ -1028,7 +962,7 @@ func file_gosdn_csbi_csbi_proto_init() { ...@@ -1028,7 +962,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil return nil
} }
} }
file_gosdn_csbi_csbi_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { file_gosdn_csbi_csbi_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DeleteRequest); i { switch v := v.(*DeleteRequest); i {
case 0: case 0:
return &v.state return &v.state
...@@ -1040,7 +974,7 @@ func file_gosdn_csbi_csbi_proto_init() { ...@@ -1040,7 +974,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil return nil
} }
} }
file_gosdn_csbi_csbi_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { file_gosdn_csbi_csbi_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DeleteResponse); i { switch v := v.(*DeleteResponse); i {
case 0: case 0:
return &v.state return &v.state
...@@ -1059,7 +993,7 @@ func file_gosdn_csbi_csbi_proto_init() { ...@@ -1059,7 +993,7 @@ func file_gosdn_csbi_csbi_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(), GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_gosdn_csbi_csbi_proto_rawDesc, RawDescriptor: file_gosdn_csbi_csbi_proto_rawDesc,
NumEnums: 2, NumEnums: 2,
NumMessages: 11, NumMessages: 10,
NumExtensions: 0, NumExtensions: 0,
NumServices: 1, NumServices: 1,
}, },
......
go/gosdn/csbi/csbi_grpc.pb.go
+ 144
− 18
View file @ 703155c9
...@@ -19,10 +19,12 @@ const _ = grpc.SupportPackageIsVersion7 ...@@ -19,10 +19,12 @@ const _ = grpc.SupportPackageIsVersion7
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type CsbiServiceClient interface { type CsbiServiceClient interface {
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
GetGoStruct(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (CsbiService_GetGoStructClient, error)
GetManifest(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (CsbiService_GetManifestClient, error)
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
Hello(ctx context.Context, in *Syn, opts ...grpc.CallOption) (*Ack, error) Hello(ctx context.Context, in *Syn, opts ...grpc.CallOption) (*Ack, error)
CreatePlugin(ctx context.Context, in *CreatePluginRequest, opts ...grpc.CallOption) (CsbiService_CreatePluginClient, error) CreateGoStruct(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (CsbiService_CreateGoStructClient, error)
} }
type csbiServiceClient struct { type csbiServiceClient struct {
...@@ -42,6 +44,70 @@ func (c *csbiServiceClient) Get(ctx context.Context, in *GetRequest, opts ...grp ...@@ -42,6 +44,70 @@ func (c *csbiServiceClient) Get(ctx context.Context, in *GetRequest, opts ...grp
return out, nil return out, nil
} }
func (c *csbiServiceClient) GetGoStruct(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (CsbiService_GetGoStructClient, error) {
stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[0], "/gosdn.csbi.CsbiService/GetGoStruct", opts...)
if err != nil {
return nil, err
}
x := &csbiServiceGetGoStructClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type CsbiService_GetGoStructClient interface {
Recv() (*Payload, error)
grpc.ClientStream
}
type csbiServiceGetGoStructClient struct {
grpc.ClientStream
}
func (x *csbiServiceGetGoStructClient) Recv() (*Payload, error) {
m := new(Payload)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *csbiServiceClient) GetManifest(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (CsbiService_GetManifestClient, error) {
stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[1], "/gosdn.csbi.CsbiService/GetManifest", opts...)
if err != nil {
return nil, err
}
x := &csbiServiceGetManifestClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type CsbiService_GetManifestClient interface {
Recv() (*Payload, error)
grpc.ClientStream
}
type csbiServiceGetManifestClient struct {
grpc.ClientStream
}
func (x *csbiServiceGetManifestClient) Recv() (*Payload, error) {
m := new(Payload)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *csbiServiceClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) { func (c *csbiServiceClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
out := new(CreateResponse) out := new(CreateResponse)
err := c.cc.Invoke(ctx, "/gosdn.csbi.CsbiService/Create", in, out, opts...) err := c.cc.Invoke(ctx, "/gosdn.csbi.CsbiService/Create", in, out, opts...)
...@@ -69,12 +135,12 @@ func (c *csbiServiceClient) Hello(ctx context.Context, in *Syn, opts ...grpc.Cal ...@@ -69,12 +135,12 @@ func (c *csbiServiceClient) Hello(ctx context.Context, in *Syn, opts ...grpc.Cal
return out, nil return out, nil
} }
func (c *csbiServiceClient) CreatePlugin(ctx context.Context, in *CreatePluginRequest, opts ...grpc.CallOption) (CsbiService_CreatePluginClient, error) { func (c *csbiServiceClient) CreateGoStruct(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (CsbiService_CreateGoStructClient, error) {
stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[0], "/gosdn.csbi.CsbiService/CreatePlugin", opts...) stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[2], "/gosdn.csbi.CsbiService/CreateGoStruct", opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
x := &csbiServiceCreatePluginClient{stream} x := &csbiServiceCreateGoStructClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil { if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err return nil, err
} }
...@@ -84,16 +150,16 @@ func (c *csbiServiceClient) CreatePlugin(ctx context.Context, in *CreatePluginRe ...@@ -84,16 +150,16 @@ func (c *csbiServiceClient) CreatePlugin(ctx context.Context, in *CreatePluginRe
return x, nil return x, nil
} }
type CsbiService_CreatePluginClient interface { type CsbiService_CreateGoStructClient interface {
Recv() (*Payload, error) Recv() (*Payload, error)
grpc.ClientStream grpc.ClientStream
} }
type csbiServiceCreatePluginClient struct { type csbiServiceCreateGoStructClient struct {
grpc.ClientStream grpc.ClientStream
} }
func (x *csbiServiceCreatePluginClient) Recv() (*Payload, error) { func (x *csbiServiceCreateGoStructClient) Recv() (*Payload, error) {
m := new(Payload) m := new(Payload)
if err := x.ClientStream.RecvMsg(m); err != nil { if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err return nil, err
...@@ -106,10 +172,12 @@ func (x *csbiServiceCreatePluginClient) Recv() (*Payload, error) { ...@@ -106,10 +172,12 @@ func (x *csbiServiceCreatePluginClient) Recv() (*Payload, error) {
// for forward compatibility // for forward compatibility
type CsbiServiceServer interface { type CsbiServiceServer interface {
Get(context.Context, *GetRequest) (*GetResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error)
GetGoStruct(*GetRequest, CsbiService_GetGoStructServer) error
GetManifest(*GetRequest, CsbiService_GetManifestServer) error
Create(context.Context, *CreateRequest) (*CreateResponse, error) Create(context.Context, *CreateRequest) (*CreateResponse, error)
Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
Hello(context.Context, *Syn) (*Ack, error) Hello(context.Context, *Syn) (*Ack, error)
CreatePlugin(*CreatePluginRequest, CsbiService_CreatePluginServer) error CreateGoStruct(*CreateRequest, CsbiService_CreateGoStructServer) error
mustEmbedUnimplementedCsbiServiceServer() mustEmbedUnimplementedCsbiServiceServer()
} }
...@@ -120,6 +188,12 @@ type UnimplementedCsbiServiceServer struct { ...@@ -120,6 +188,12 @@ type UnimplementedCsbiServiceServer struct {
func (UnimplementedCsbiServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error) { func (UnimplementedCsbiServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
} }
func (UnimplementedCsbiServiceServer) GetGoStruct(*GetRequest, CsbiService_GetGoStructServer) error {
return status.Errorf(codes.Unimplemented, "method GetGoStruct not implemented")
}
func (UnimplementedCsbiServiceServer) GetManifest(*GetRequest, CsbiService_GetManifestServer) error {
return status.Errorf(codes.Unimplemented, "method GetManifest not implemented")
}
func (UnimplementedCsbiServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) { func (UnimplementedCsbiServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
} }
...@@ -129,8 +203,8 @@ func (UnimplementedCsbiServiceServer) Delete(context.Context, *DeleteRequest) (* ...@@ -129,8 +203,8 @@ func (UnimplementedCsbiServiceServer) Delete(context.Context, *DeleteRequest) (*
func (UnimplementedCsbiServiceServer) Hello(context.Context, *Syn) (*Ack, error) { func (UnimplementedCsbiServiceServer) Hello(context.Context, *Syn) (*Ack, error) {
return nil, status.Errorf(codes.Unimplemented, "method Hello not implemented") return nil, status.Errorf(codes.Unimplemented, "method Hello not implemented")
} }
func (UnimplementedCsbiServiceServer) CreatePlugin(*CreatePluginRequest, CsbiService_CreatePluginServer) error { func (UnimplementedCsbiServiceServer) CreateGoStruct(*CreateRequest, CsbiService_CreateGoStructServer) error {
return status.Errorf(codes.Unimplemented, "method CreatePlugin not implemented") return status.Errorf(codes.Unimplemented, "method CreateGoStruct not implemented")
} }
func (UnimplementedCsbiServiceServer) mustEmbedUnimplementedCsbiServiceServer() {} func (UnimplementedCsbiServiceServer) mustEmbedUnimplementedCsbiServiceServer() {}
...@@ -163,6 +237,48 @@ func _CsbiService_Get_Handler(srv interface{}, ctx context.Context, dec func(int ...@@ -163,6 +237,48 @@ func _CsbiService_Get_Handler(srv interface{}, ctx context.Context, dec func(int
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _CsbiService_GetGoStruct_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(CsbiServiceServer).GetGoStruct(m, &csbiServiceGetGoStructServer{stream})
}
type CsbiService_GetGoStructServer interface {
Send(*Payload) error
grpc.ServerStream
}
type csbiServiceGetGoStructServer struct {
grpc.ServerStream
}
func (x *csbiServiceGetGoStructServer) Send(m *Payload) error {
return x.ServerStream.SendMsg(m)
}
func _CsbiService_GetManifest_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(CsbiServiceServer).GetManifest(m, &csbiServiceGetManifestServer{stream})
}
type CsbiService_GetManifestServer interface {
Send(*Payload) error
grpc.ServerStream
}
type csbiServiceGetManifestServer struct {
grpc.ServerStream
}
func (x *csbiServiceGetManifestServer) Send(m *Payload) error {
return x.ServerStream.SendMsg(m)
}
func _CsbiService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _CsbiService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateRequest) in := new(CreateRequest)
if err := dec(in); err != nil { if err := dec(in); err != nil {
...@@ -217,24 +333,24 @@ func _CsbiService_Hello_Handler(srv interface{}, ctx context.Context, dec func(i ...@@ -217,24 +333,24 @@ func _CsbiService_Hello_Handler(srv interface{}, ctx context.Context, dec func(i
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _CsbiService_CreatePlugin_Handler(srv interface{}, stream grpc.ServerStream) error { func _CsbiService_CreateGoStruct_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(CreatePluginRequest) m := new(CreateRequest)
if err := stream.RecvMsg(m); err != nil { if err := stream.RecvMsg(m); err != nil {
return err return err
} }
return srv.(CsbiServiceServer).CreatePlugin(m, &csbiServiceCreatePluginServer{stream}) return srv.(CsbiServiceServer).CreateGoStruct(m, &csbiServiceCreateGoStructServer{stream})
} }
type CsbiService_CreatePluginServer interface { type CsbiService_CreateGoStructServer interface {
Send(*Payload) error Send(*Payload) error
grpc.ServerStream grpc.ServerStream
} }
type csbiServiceCreatePluginServer struct { type csbiServiceCreateGoStructServer struct {
grpc.ServerStream grpc.ServerStream
} }
func (x *csbiServiceCreatePluginServer) Send(m *Payload) error { func (x *csbiServiceCreateGoStructServer) Send(m *Payload) error {
return x.ServerStream.SendMsg(m) return x.ServerStream.SendMsg(m)
} }
...@@ -264,8 +380,18 @@ var CsbiService_ServiceDesc = grpc.ServiceDesc{ ...@@ -264,8 +380,18 @@ var CsbiService_ServiceDesc = grpc.ServiceDesc{
}, },
Streams: []grpc.StreamDesc{ Streams: []grpc.StreamDesc{
{ {
StreamName: "CreatePlugin", StreamName: "GetGoStruct",
Handler: _CsbiService_CreatePlugin_Handler, Handler: _CsbiService_GetGoStruct_Handler,
ServerStreams: true,
},
{
StreamName: "GetManifest",
Handler: _CsbiService_GetManifest_Handler,
ServerStreams: true,
},
{
StreamName: "CreateGoStruct",
Handler: _CsbiService_CreateGoStruct_Handler,
ServerStreams: true, ServerStreams: true,
}, },
}, },
......
openapiv2/gosdn_northbound.swagger.json
+ 4
− 4
View file @ 703155c9
...@@ -18,16 +18,16 @@ ...@@ -18,16 +18,16 @@
"name": "PndService" "name": "PndService"
}, },
{ {
"name": "Collector" "name": "gNMI"
}, },
{ {
"name": "gNMI" "name": "CoreService"
}, },
{ {
"name": "AgentManager" "name": "Collector"
}, },
{ {
"name": "CoreService" "name": "AgentManager"
}, },
{ {
"name": "CsbiService" "name": "CsbiService"
......
proto/gosdn/csbi/csbi.proto
+ 3
− 6
View file @ 703155c9
...@@ -8,10 +8,12 @@ option go_package = "code.fbi.h-da.de/danet/api/go/gosdn/csbi"; ...@@ -8,10 +8,12 @@ option go_package = "code.fbi.h-da.de/danet/api/go/gosdn/csbi";
service CsbiService { service CsbiService {
rpc Get(GetRequest) returns (GetResponse); rpc Get(GetRequest) returns (GetResponse);
rpc GetGoStruct(GetRequest) returns (stream Payload);
rpc GetManifest(GetRequest) returns (stream Payload);
rpc Create(CreateRequest) returns (CreateResponse); rpc Create(CreateRequest) returns (CreateResponse);
rpc Delete(DeleteRequest) returns (DeleteResponse); rpc Delete(DeleteRequest) returns (DeleteResponse);
rpc Hello(Syn) returns (Ack); rpc Hello(Syn) returns (Ack);
rpc CreatePlugin(CreatePluginRequest) returns (stream Payload); rpc CreateGoStruct(CreateRequest) returns (stream Payload);
} }
message Syn { message Syn {
...@@ -56,11 +58,6 @@ message CreateRequest { ...@@ -56,11 +58,6 @@ message CreateRequest {
repeated .gosdn.transport.TransportOption transport_option = 2; repeated .gosdn.transport.TransportOption transport_option = 2;
} }
message CreatePluginRequest {
int64 timestamp = 1; // Timestamp in nanoseconds since Epoch.
repeated .gosdn.transport.TransportOption transport_option = 2;
}
message CreateResponse { message CreateResponse {
int64 timestamp = 1; // Timestamp in nanoseconds since Epoch. int64 timestamp = 1; // Timestamp in nanoseconds since Epoch.
repeated Deployment deployments = 2; repeated Deployment deployments = 2;
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment