From 11e52730dc6edadd118a94de93b5e220fdfcd1a7 Mon Sep 17 00:00:00 2001 From: Engineering Date: Thu, 5 Dec 2024 09:54:20 +0000 Subject: [PATCH] Updated to SDP v0.18.4-390-g40c6b17 --- account.pb.go | 222 +++++++++++++++++----------------- sdpconnect/account.connect.go | 88 +++++++------- 2 files changed, 155 insertions(+), 155 deletions(-) diff --git a/account.pb.go b/account.pb.go index 476090a..c998293 100644 --- a/account.pb.go +++ b/account.pb.go @@ -3667,7 +3667,7 @@ var file_account_proto_rawDesc = []byte{ 0x54, 0x45, 0x52, 0x5f, 0x43, 0x41, 0x54, 0x45, 0x47, 0x4f, 0x52, 0x59, 0x5f, 0x43, 0x4f, 0x4e, 0x46, 0x49, 0x47, 0x55, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x10, 0x07, 0x12, 0x17, 0x0a, 0x13, 0x41, 0x44, 0x41, 0x50, 0x54, 0x45, 0x52, 0x5f, 0x43, 0x41, 0x54, 0x45, 0x47, 0x4f, 0x52, 0x59, - 0x5f, 0x41, 0x49, 0x10, 0x08, 0x32, 0xcc, 0x08, 0x0a, 0x0c, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x53, + 0x5f, 0x41, 0x49, 0x10, 0x08, 0x32, 0xe1, 0x07, 0x0a, 0x0c, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x12, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x71, @@ -3729,87 +3729,87 @@ var file_account_proto_rawDesc = []byte{ 0x75, 0x6e, 0x74, 0x2e, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, 0x6b, 0x65, - 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x69, 0x0a, 0x16, 0x4c, 0x69, 0x73, - 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x74, 0x65, 0x6d, 0x54, 0x79, - 0x70, 0x65, 0x73, 0x12, 0x26, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, - 0x73, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x74, 0x65, 0x6d, 0x54, - 0x79, 0x70, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x61, 0x63, - 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, - 0x62, 0x6c, 0x65, 0x49, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x32, 0x93, 0x09, 0x0a, 0x11, 0x4d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x6d, - 0x65, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x45, 0x0a, 0x0a, 0x47, 0x65, - 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1a, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, - 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, - 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x12, 0x4e, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, - 0x6e, 0x74, 0x12, 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x44, 0x65, 0x6c, - 0x65, 0x74, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x1e, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, - 0x74, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x12, 0x48, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, - 0x12, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, - 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, - 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x6f, 0x75, 0x72, - 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x43, - 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x1c, 0x2e, 0x61, 0x63, - 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, - 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, - 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x42, 0x0a, 0x09, 0x47, 0x65, 0x74, 0x53, - 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x19, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, - 0x47, 0x65, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x1a, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x6f, - 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, - 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x1c, 0x2e, 0x61, - 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, - 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x61, 0x63, 0x63, - 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, - 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x44, 0x65, 0x6c, - 0x65, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, - 0x75, 0x6e, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, - 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x63, 0x0a, 0x14, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, - 0x6c, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x24, - 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, - 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, + 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xfe, 0x09, 0x0a, 0x11, 0x4d, 0x61, + 0x6e, 0x61, 0x67, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, + 0x45, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1a, 0x2e, + 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, + 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, + 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4e, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, + 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, + 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, + 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x6f, + 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, + 0x4c, 0x69, 0x73, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, + 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x4b, 0x0a, 0x0c, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, + 0x12, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, + 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, + 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, + 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x42, 0x0a, + 0x09, 0x47, 0x65, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x19, 0x2e, 0x61, 0x63, 0x63, + 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, + 0x47, 0x65, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, + 0x65, 0x12, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x55, 0x70, 0x64, 0x61, + 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, + 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, + 0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x1c, + 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, + 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x61, + 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x6f, 0x75, + 0x72, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x63, 0x0a, 0x14, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, - 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x66, 0x0a, 0x17, 0x4c, - 0x69, 0x73, 0x74, 0x41, 0x63, 0x74, 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, - 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x24, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, - 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, - 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x61, - 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x53, 0x6f, - 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x12, 0x66, 0x0a, 0x15, 0x53, 0x75, 0x62, 0x6d, 0x69, 0x74, 0x53, 0x6f, 0x75, - 0x72, 0x63, 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x25, 0x2e, 0x61, - 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x53, 0x75, 0x62, 0x6d, 0x69, 0x74, 0x53, 0x6f, 0x75, - 0x72, 0x63, 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x53, 0x75, - 0x62, 0x6d, 0x69, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, - 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x57, 0x0a, 0x10, 0x4b, - 0x65, 0x65, 0x70, 0x61, 0x6c, 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, - 0x20, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4b, 0x65, 0x65, 0x70, 0x61, 0x6c, - 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x21, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4b, 0x65, 0x65, 0x70, - 0x61, 0x6c, 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0b, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, - 0x6b, 0x65, 0x6e, 0x12, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, - 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, - 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x50, - 0x0a, 0x0d, 0x52, 0x65, 0x76, 0x6c, 0x69, 0x6e, 0x6b, 0x57, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x12, - 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x52, 0x65, 0x76, 0x6c, 0x69, 0x6e, - 0x6b, 0x57, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, - 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x52, 0x65, 0x76, 0x6c, 0x69, 0x6e, 0x6b, - 0x57, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x30, 0x01, - 0x12, 0x48, 0x0a, 0x0b, 0x47, 0x65, 0x74, 0x54, 0x72, 0x69, 0x61, 0x6c, 0x45, 0x6e, 0x64, 0x12, - 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x72, 0x69, - 0x61, 0x6c, 0x45, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x61, - 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x72, 0x69, 0x61, 0x6c, 0x45, - 0x6e, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x24, 0x5a, 0x22, 0x67, 0x69, + 0x74, 0x75, 0x73, 0x12, 0x24, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, + 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, + 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x61, 0x63, 0x63, 0x6f, + 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x53, 0x6f, 0x75, 0x72, 0x63, + 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x66, 0x0a, 0x17, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x63, 0x74, 0x69, 0x76, 0x65, 0x53, 0x6f, + 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x24, 0x2e, 0x61, 0x63, + 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x53, 0x6f, 0x75, + 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x25, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, + 0x41, 0x6c, 0x6c, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x66, 0x0a, 0x15, 0x53, 0x75, 0x62, 0x6d, + 0x69, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, + 0x74, 0x12, 0x25, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x53, 0x75, 0x62, 0x6d, + 0x69, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, + 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, + 0x6e, 0x74, 0x2e, 0x53, 0x75, 0x62, 0x6d, 0x69, 0x74, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x48, + 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x57, 0x0a, 0x10, 0x4b, 0x65, 0x65, 0x70, 0x61, 0x6c, 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, + 0x72, 0x63, 0x65, 0x73, 0x12, 0x20, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4b, + 0x65, 0x65, 0x70, 0x61, 0x6c, 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, + 0x2e, 0x4b, 0x65, 0x65, 0x70, 0x61, 0x6c, 0x69, 0x76, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, + 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0b, 0x43, 0x72, 0x65, + 0x61, 0x74, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, + 0x6e, 0x74, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, + 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x12, 0x50, 0x0a, 0x0d, 0x52, 0x65, 0x76, 0x6c, 0x69, 0x6e, 0x6b, 0x57, 0x61, + 0x72, 0x6d, 0x75, 0x70, 0x12, 0x1d, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x52, + 0x65, 0x76, 0x6c, 0x69, 0x6e, 0x6b, 0x57, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x52, 0x65, + 0x76, 0x6c, 0x69, 0x6e, 0x6b, 0x57, 0x61, 0x72, 0x6d, 0x75, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x30, 0x01, 0x12, 0x48, 0x0a, 0x0b, 0x47, 0x65, 0x74, 0x54, 0x72, 0x69, 0x61, + 0x6c, 0x45, 0x6e, 0x64, 0x12, 0x1b, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, + 0x65, 0x74, 0x54, 0x72, 0x69, 0x61, 0x6c, 0x45, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x1c, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x47, 0x65, 0x74, 0x54, + 0x72, 0x69, 0x61, 0x6c, 0x45, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, + 0x69, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, 0x65, + 0x49, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x73, 0x12, 0x26, 0x2e, 0x61, 0x63, 0x63, 0x6f, + 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, + 0x65, 0x49, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x27, 0x2e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x2e, 0x4c, 0x69, 0x73, 0x74, + 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, + 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x24, 0x5a, 0x22, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6f, 0x76, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x64, 0x74, 0x65, 0x63, 0x68, 0x2f, 0x73, 0x64, 0x70, 0x2d, 0x67, 0x6f, 0x3b, 0x73, 0x64, 0x70, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, @@ -3955,21 +3955,21 @@ var file_account_proto_depIdxs = []int32{ 17, // 56: account.AdminService.DeleteSource:input_type -> account.AdminDeleteSourceRequest 18, // 57: account.AdminService.KeepaliveSources:input_type -> account.AdminKeepaliveSourcesRequest 19, // 58: account.AdminService.CreateToken:input_type -> account.AdminCreateTokenRequest - 58, // 59: account.AdminService.ListAvailableItemTypes:input_type -> account.ListAvailableItemTypesRequest - 26, // 60: account.ManagementService.GetAccount:input_type -> account.GetAccountRequest - 28, // 61: account.ManagementService.DeleteAccount:input_type -> account.DeleteAccountRequest - 30, // 62: account.ManagementService.ListSources:input_type -> account.ListSourcesRequest - 32, // 63: account.ManagementService.CreateSource:input_type -> account.CreateSourceRequest - 34, // 64: account.ManagementService.GetSource:input_type -> account.GetSourceRequest - 36, // 65: account.ManagementService.UpdateSource:input_type -> account.UpdateSourceRequest - 38, // 66: account.ManagementService.DeleteSource:input_type -> account.DeleteSourceRequest - 41, // 67: account.ManagementService.ListAllSourcesStatus:input_type -> account.ListAllSourcesStatusRequest - 41, // 68: account.ManagementService.ListActiveSourcesStatus:input_type -> account.ListAllSourcesStatusRequest - 44, // 69: account.ManagementService.SubmitSourceHeartbeat:input_type -> account.SubmitSourceHeartbeatRequest - 49, // 70: account.ManagementService.KeepaliveSources:input_type -> account.KeepaliveSourcesRequest - 51, // 71: account.ManagementService.CreateToken:input_type -> account.CreateTokenRequest - 53, // 72: account.ManagementService.RevlinkWarmup:input_type -> account.RevlinkWarmupRequest - 55, // 73: account.ManagementService.GetTrialEnd:input_type -> account.GetTrialEndRequest + 26, // 59: account.ManagementService.GetAccount:input_type -> account.GetAccountRequest + 28, // 60: account.ManagementService.DeleteAccount:input_type -> account.DeleteAccountRequest + 30, // 61: account.ManagementService.ListSources:input_type -> account.ListSourcesRequest + 32, // 62: account.ManagementService.CreateSource:input_type -> account.CreateSourceRequest + 34, // 63: account.ManagementService.GetSource:input_type -> account.GetSourceRequest + 36, // 64: account.ManagementService.UpdateSource:input_type -> account.UpdateSourceRequest + 38, // 65: account.ManagementService.DeleteSource:input_type -> account.DeleteSourceRequest + 41, // 66: account.ManagementService.ListAllSourcesStatus:input_type -> account.ListAllSourcesStatusRequest + 41, // 67: account.ManagementService.ListActiveSourcesStatus:input_type -> account.ListAllSourcesStatusRequest + 44, // 68: account.ManagementService.SubmitSourceHeartbeat:input_type -> account.SubmitSourceHeartbeatRequest + 49, // 69: account.ManagementService.KeepaliveSources:input_type -> account.KeepaliveSourcesRequest + 51, // 70: account.ManagementService.CreateToken:input_type -> account.CreateTokenRequest + 53, // 71: account.ManagementService.RevlinkWarmup:input_type -> account.RevlinkWarmupRequest + 55, // 72: account.ManagementService.GetTrialEnd:input_type -> account.GetTrialEndRequest + 58, // 73: account.ManagementService.ListAvailableItemTypes:input_type -> account.ListAvailableItemTypesRequest 4, // 74: account.AdminService.ListAccounts:output_type -> account.ListAccountsResponse 6, // 75: account.AdminService.CreateAccount:output_type -> account.CreateAccountResponse 8, // 76: account.AdminService.UpdateAccount:output_type -> account.UpdateAccountResponse @@ -3982,21 +3982,21 @@ var file_account_proto_depIdxs = []int32{ 39, // 83: account.AdminService.DeleteSource:output_type -> account.DeleteSourceResponse 50, // 84: account.AdminService.KeepaliveSources:output_type -> account.KeepaliveSourcesResponse 52, // 85: account.AdminService.CreateToken:output_type -> account.CreateTokenResponse - 59, // 86: account.AdminService.ListAvailableItemTypes:output_type -> account.ListAvailableItemTypesResponse - 27, // 87: account.ManagementService.GetAccount:output_type -> account.GetAccountResponse - 29, // 88: account.ManagementService.DeleteAccount:output_type -> account.DeleteAccountResponse - 31, // 89: account.ManagementService.ListSources:output_type -> account.ListSourcesResponse - 33, // 90: account.ManagementService.CreateSource:output_type -> account.CreateSourceResponse - 35, // 91: account.ManagementService.GetSource:output_type -> account.GetSourceResponse - 37, // 92: account.ManagementService.UpdateSource:output_type -> account.UpdateSourceResponse - 39, // 93: account.ManagementService.DeleteSource:output_type -> account.DeleteSourceResponse - 43, // 94: account.ManagementService.ListAllSourcesStatus:output_type -> account.ListAllSourcesStatusResponse - 43, // 95: account.ManagementService.ListActiveSourcesStatus:output_type -> account.ListAllSourcesStatusResponse - 48, // 96: account.ManagementService.SubmitSourceHeartbeat:output_type -> account.SubmitSourceHeartbeatResponse - 50, // 97: account.ManagementService.KeepaliveSources:output_type -> account.KeepaliveSourcesResponse - 52, // 98: account.ManagementService.CreateToken:output_type -> account.CreateTokenResponse - 54, // 99: account.ManagementService.RevlinkWarmup:output_type -> account.RevlinkWarmupResponse - 56, // 100: account.ManagementService.GetTrialEnd:output_type -> account.GetTrialEndResponse + 27, // 86: account.ManagementService.GetAccount:output_type -> account.GetAccountResponse + 29, // 87: account.ManagementService.DeleteAccount:output_type -> account.DeleteAccountResponse + 31, // 88: account.ManagementService.ListSources:output_type -> account.ListSourcesResponse + 33, // 89: account.ManagementService.CreateSource:output_type -> account.CreateSourceResponse + 35, // 90: account.ManagementService.GetSource:output_type -> account.GetSourceResponse + 37, // 91: account.ManagementService.UpdateSource:output_type -> account.UpdateSourceResponse + 39, // 92: account.ManagementService.DeleteSource:output_type -> account.DeleteSourceResponse + 43, // 93: account.ManagementService.ListAllSourcesStatus:output_type -> account.ListAllSourcesStatusResponse + 43, // 94: account.ManagementService.ListActiveSourcesStatus:output_type -> account.ListAllSourcesStatusResponse + 48, // 95: account.ManagementService.SubmitSourceHeartbeat:output_type -> account.SubmitSourceHeartbeatResponse + 50, // 96: account.ManagementService.KeepaliveSources:output_type -> account.KeepaliveSourcesResponse + 52, // 97: account.ManagementService.CreateToken:output_type -> account.CreateTokenResponse + 54, // 98: account.ManagementService.RevlinkWarmup:output_type -> account.RevlinkWarmupResponse + 56, // 99: account.ManagementService.GetTrialEnd:output_type -> account.GetTrialEndResponse + 59, // 100: account.ManagementService.ListAvailableItemTypes:output_type -> account.ListAvailableItemTypesResponse 74, // [74:101] is the sub-list for method output_type 47, // [47:74] is the sub-list for method input_type 47, // [47:47] is the sub-list for extension type_name diff --git a/sdpconnect/account.connect.go b/sdpconnect/account.connect.go index 3f98074..1e52d7a 100644 --- a/sdpconnect/account.connect.go +++ b/sdpconnect/account.connect.go @@ -69,9 +69,6 @@ const ( // AdminServiceCreateTokenProcedure is the fully-qualified name of the AdminService's CreateToken // RPC. AdminServiceCreateTokenProcedure = "/account.AdminService/CreateToken" - // AdminServiceListAvailableItemTypesProcedure is the fully-qualified name of the AdminService's - // ListAvailableItemTypes RPC. - AdminServiceListAvailableItemTypesProcedure = "/account.AdminService/ListAvailableItemTypes" // ManagementServiceGetAccountProcedure is the fully-qualified name of the ManagementService's // GetAccount RPC. ManagementServiceGetAccountProcedure = "/account.ManagementService/GetAccount" @@ -114,6 +111,9 @@ const ( // ManagementServiceGetTrialEndProcedure is the fully-qualified name of the ManagementService's // GetTrialEnd RPC. ManagementServiceGetTrialEndProcedure = "/account.ManagementService/GetTrialEnd" + // ManagementServiceListAvailableItemTypesProcedure is the fully-qualified name of the + // ManagementService's ListAvailableItemTypes RPC. + ManagementServiceListAvailableItemTypesProcedure = "/account.ManagementService/ListAvailableItemTypes" ) // These variables are the protoreflect.Descriptor objects for the RPCs defined in this package. @@ -131,7 +131,6 @@ var ( adminServiceDeleteSourceMethodDescriptor = adminServiceServiceDescriptor.Methods().ByName("DeleteSource") adminServiceKeepaliveSourcesMethodDescriptor = adminServiceServiceDescriptor.Methods().ByName("KeepaliveSources") adminServiceCreateTokenMethodDescriptor = adminServiceServiceDescriptor.Methods().ByName("CreateToken") - adminServiceListAvailableItemTypesMethodDescriptor = adminServiceServiceDescriptor.Methods().ByName("ListAvailableItemTypes") managementServiceServiceDescriptor = sdp_go.File_account_proto.Services().ByName("ManagementService") managementServiceGetAccountMethodDescriptor = managementServiceServiceDescriptor.Methods().ByName("GetAccount") managementServiceDeleteAccountMethodDescriptor = managementServiceServiceDescriptor.Methods().ByName("DeleteAccount") @@ -147,6 +146,7 @@ var ( managementServiceCreateTokenMethodDescriptor = managementServiceServiceDescriptor.Methods().ByName("CreateToken") managementServiceRevlinkWarmupMethodDescriptor = managementServiceServiceDescriptor.Methods().ByName("RevlinkWarmup") managementServiceGetTrialEndMethodDescriptor = managementServiceServiceDescriptor.Methods().ByName("GetTrialEnd") + managementServiceListAvailableItemTypesMethodDescriptor = managementServiceServiceDescriptor.Methods().ByName("ListAvailableItemTypes") ) // AdminServiceClient is a client for the account.AdminService service. @@ -180,8 +180,6 @@ type AdminServiceClient interface { // control the associated private key also in order to connect to NATS as // the token is not enough on its own CreateToken(context.Context, *connect.Request[sdp_go.AdminCreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error) - // Lists all the available item types that can be discovered by sources that are running and healthy - ListAvailableItemTypes(context.Context, *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) } // NewAdminServiceClient constructs a client for the account.AdminService service. By default, it @@ -266,30 +264,23 @@ func NewAdminServiceClient(httpClient connect.HTTPClient, baseURL string, opts . connect.WithSchema(adminServiceCreateTokenMethodDescriptor), connect.WithClientOptions(opts...), ), - listAvailableItemTypes: connect.NewClient[sdp_go.ListAvailableItemTypesRequest, sdp_go.ListAvailableItemTypesResponse]( - httpClient, - baseURL+AdminServiceListAvailableItemTypesProcedure, - connect.WithSchema(adminServiceListAvailableItemTypesMethodDescriptor), - connect.WithClientOptions(opts...), - ), } } // adminServiceClient implements AdminServiceClient. type adminServiceClient struct { - listAccounts *connect.Client[sdp_go.ListAccountsRequest, sdp_go.ListAccountsResponse] - createAccount *connect.Client[sdp_go.CreateAccountRequest, sdp_go.CreateAccountResponse] - updateAccount *connect.Client[sdp_go.AdminUpdateAccountRequest, sdp_go.UpdateAccountResponse] - getAccount *connect.Client[sdp_go.AdminGetAccountRequest, sdp_go.GetAccountResponse] - deleteAccount *connect.Client[sdp_go.AdminDeleteAccountRequest, sdp_go.AdminDeleteAccountResponse] - listSources *connect.Client[sdp_go.AdminListSourcesRequest, sdp_go.ListSourcesResponse] - createSource *connect.Client[sdp_go.AdminCreateSourceRequest, sdp_go.CreateSourceResponse] - getSource *connect.Client[sdp_go.AdminGetSourceRequest, sdp_go.GetSourceResponse] - updateSource *connect.Client[sdp_go.AdminUpdateSourceRequest, sdp_go.UpdateSourceResponse] - deleteSource *connect.Client[sdp_go.AdminDeleteSourceRequest, sdp_go.DeleteSourceResponse] - keepaliveSources *connect.Client[sdp_go.AdminKeepaliveSourcesRequest, sdp_go.KeepaliveSourcesResponse] - createToken *connect.Client[sdp_go.AdminCreateTokenRequest, sdp_go.CreateTokenResponse] - listAvailableItemTypes *connect.Client[sdp_go.ListAvailableItemTypesRequest, sdp_go.ListAvailableItemTypesResponse] + listAccounts *connect.Client[sdp_go.ListAccountsRequest, sdp_go.ListAccountsResponse] + createAccount *connect.Client[sdp_go.CreateAccountRequest, sdp_go.CreateAccountResponse] + updateAccount *connect.Client[sdp_go.AdminUpdateAccountRequest, sdp_go.UpdateAccountResponse] + getAccount *connect.Client[sdp_go.AdminGetAccountRequest, sdp_go.GetAccountResponse] + deleteAccount *connect.Client[sdp_go.AdminDeleteAccountRequest, sdp_go.AdminDeleteAccountResponse] + listSources *connect.Client[sdp_go.AdminListSourcesRequest, sdp_go.ListSourcesResponse] + createSource *connect.Client[sdp_go.AdminCreateSourceRequest, sdp_go.CreateSourceResponse] + getSource *connect.Client[sdp_go.AdminGetSourceRequest, sdp_go.GetSourceResponse] + updateSource *connect.Client[sdp_go.AdminUpdateSourceRequest, sdp_go.UpdateSourceResponse] + deleteSource *connect.Client[sdp_go.AdminDeleteSourceRequest, sdp_go.DeleteSourceResponse] + keepaliveSources *connect.Client[sdp_go.AdminKeepaliveSourcesRequest, sdp_go.KeepaliveSourcesResponse] + createToken *connect.Client[sdp_go.AdminCreateTokenRequest, sdp_go.CreateTokenResponse] } // ListAccounts calls account.AdminService.ListAccounts. @@ -352,11 +343,6 @@ func (c *adminServiceClient) CreateToken(ctx context.Context, req *connect.Reque return c.createToken.CallUnary(ctx, req) } -// ListAvailableItemTypes calls account.AdminService.ListAvailableItemTypes. -func (c *adminServiceClient) ListAvailableItemTypes(ctx context.Context, req *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) { - return c.listAvailableItemTypes.CallUnary(ctx, req) -} - // AdminServiceHandler is an implementation of the account.AdminService service. type AdminServiceHandler interface { // Lists the details of all NATS Accounts @@ -388,8 +374,6 @@ type AdminServiceHandler interface { // control the associated private key also in order to connect to NATS as // the token is not enough on its own CreateToken(context.Context, *connect.Request[sdp_go.AdminCreateTokenRequest]) (*connect.Response[sdp_go.CreateTokenResponse], error) - // Lists all the available item types that can be discovered by sources that are running and healthy - ListAvailableItemTypes(context.Context, *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) } // NewAdminServiceHandler builds an HTTP handler from the service implementation. It returns the @@ -470,12 +454,6 @@ func NewAdminServiceHandler(svc AdminServiceHandler, opts ...connect.HandlerOpti connect.WithSchema(adminServiceCreateTokenMethodDescriptor), connect.WithHandlerOptions(opts...), ) - adminServiceListAvailableItemTypesHandler := connect.NewUnaryHandler( - AdminServiceListAvailableItemTypesProcedure, - svc.ListAvailableItemTypes, - connect.WithSchema(adminServiceListAvailableItemTypesMethodDescriptor), - connect.WithHandlerOptions(opts...), - ) return "/account.AdminService/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { switch r.URL.Path { case AdminServiceListAccountsProcedure: @@ -502,8 +480,6 @@ func NewAdminServiceHandler(svc AdminServiceHandler, opts ...connect.HandlerOpti adminServiceKeepaliveSourcesHandler.ServeHTTP(w, r) case AdminServiceCreateTokenProcedure: adminServiceCreateTokenHandler.ServeHTTP(w, r) - case AdminServiceListAvailableItemTypesProcedure: - adminServiceListAvailableItemTypesHandler.ServeHTTP(w, r) default: http.NotFound(w, r) } @@ -561,10 +537,6 @@ func (UnimplementedAdminServiceHandler) CreateToken(context.Context, *connect.Re return nil, connect.NewError(connect.CodeUnimplemented, errors.New("account.AdminService.CreateToken is not implemented")) } -func (UnimplementedAdminServiceHandler) ListAvailableItemTypes(context.Context, *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) { - return nil, connect.NewError(connect.CodeUnimplemented, errors.New("account.AdminService.ListAvailableItemTypes is not implemented")) -} - // ManagementServiceClient is a client for the account.ManagementService service. type ManagementServiceClient interface { // Get the details of the account that this user belongs to @@ -605,6 +577,8 @@ type ManagementServiceClient interface { // so the actual logic does only run when required. RevlinkWarmup(context.Context, *connect.Request[sdp_go.RevlinkWarmupRequest]) (*connect.ServerStreamForClient[sdp_go.RevlinkWarmupResponse], error) GetTrialEnd(context.Context, *connect.Request[sdp_go.GetTrialEndRequest]) (*connect.Response[sdp_go.GetTrialEndResponse], error) + // Lists all the available item types that can be discovered by sources that are running and healthy + ListAvailableItemTypes(context.Context, *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) } // NewManagementServiceClient constructs a client for the account.ManagementService service. By @@ -701,6 +675,12 @@ func NewManagementServiceClient(httpClient connect.HTTPClient, baseURL string, o connect.WithSchema(managementServiceGetTrialEndMethodDescriptor), connect.WithClientOptions(opts...), ), + listAvailableItemTypes: connect.NewClient[sdp_go.ListAvailableItemTypesRequest, sdp_go.ListAvailableItemTypesResponse]( + httpClient, + baseURL+ManagementServiceListAvailableItemTypesProcedure, + connect.WithSchema(managementServiceListAvailableItemTypesMethodDescriptor), + connect.WithClientOptions(opts...), + ), } } @@ -720,6 +700,7 @@ type managementServiceClient struct { createToken *connect.Client[sdp_go.CreateTokenRequest, sdp_go.CreateTokenResponse] revlinkWarmup *connect.Client[sdp_go.RevlinkWarmupRequest, sdp_go.RevlinkWarmupResponse] getTrialEnd *connect.Client[sdp_go.GetTrialEndRequest, sdp_go.GetTrialEndResponse] + listAvailableItemTypes *connect.Client[sdp_go.ListAvailableItemTypesRequest, sdp_go.ListAvailableItemTypesResponse] } // GetAccount calls account.ManagementService.GetAccount. @@ -792,6 +773,11 @@ func (c *managementServiceClient) GetTrialEnd(ctx context.Context, req *connect. return c.getTrialEnd.CallUnary(ctx, req) } +// ListAvailableItemTypes calls account.ManagementService.ListAvailableItemTypes. +func (c *managementServiceClient) ListAvailableItemTypes(ctx context.Context, req *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) { + return c.listAvailableItemTypes.CallUnary(ctx, req) +} + // ManagementServiceHandler is an implementation of the account.ManagementService service. type ManagementServiceHandler interface { // Get the details of the account that this user belongs to @@ -832,6 +818,8 @@ type ManagementServiceHandler interface { // so the actual logic does only run when required. RevlinkWarmup(context.Context, *connect.Request[sdp_go.RevlinkWarmupRequest], *connect.ServerStream[sdp_go.RevlinkWarmupResponse]) error GetTrialEnd(context.Context, *connect.Request[sdp_go.GetTrialEndRequest]) (*connect.Response[sdp_go.GetTrialEndResponse], error) + // Lists all the available item types that can be discovered by sources that are running and healthy + ListAvailableItemTypes(context.Context, *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) } // NewManagementServiceHandler builds an HTTP handler from the service implementation. It returns @@ -924,6 +912,12 @@ func NewManagementServiceHandler(svc ManagementServiceHandler, opts ...connect.H connect.WithSchema(managementServiceGetTrialEndMethodDescriptor), connect.WithHandlerOptions(opts...), ) + managementServiceListAvailableItemTypesHandler := connect.NewUnaryHandler( + ManagementServiceListAvailableItemTypesProcedure, + svc.ListAvailableItemTypes, + connect.WithSchema(managementServiceListAvailableItemTypesMethodDescriptor), + connect.WithHandlerOptions(opts...), + ) return "/account.ManagementService/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { switch r.URL.Path { case ManagementServiceGetAccountProcedure: @@ -954,6 +948,8 @@ func NewManagementServiceHandler(svc ManagementServiceHandler, opts ...connect.H managementServiceRevlinkWarmupHandler.ServeHTTP(w, r) case ManagementServiceGetTrialEndProcedure: managementServiceGetTrialEndHandler.ServeHTTP(w, r) + case ManagementServiceListAvailableItemTypesProcedure: + managementServiceListAvailableItemTypesHandler.ServeHTTP(w, r) default: http.NotFound(w, r) } @@ -1018,3 +1014,7 @@ func (UnimplementedManagementServiceHandler) RevlinkWarmup(context.Context, *con func (UnimplementedManagementServiceHandler) GetTrialEnd(context.Context, *connect.Request[sdp_go.GetTrialEndRequest]) (*connect.Response[sdp_go.GetTrialEndResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("account.ManagementService.GetTrialEnd is not implemented")) } + +func (UnimplementedManagementServiceHandler) ListAvailableItemTypes(context.Context, *connect.Request[sdp_go.ListAvailableItemTypesRequest]) (*connect.Response[sdp_go.ListAvailableItemTypesResponse], error) { + return nil, connect.NewError(connect.CodeUnimplemented, errors.New("account.ManagementService.ListAvailableItemTypes is not implemented")) +}