Skip to content
Snippets Groups Projects
Commit 39dbdbc4 authored by Anton Sattarov's avatar Anton Sattarov :cucumber:
Browse files

generate new clients

parent b995af8e
No related branches found
No related tags found
No related merge requests found
Showing
with 15408 additions and 0 deletions
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.27.1
// protoc v3.17.3
// source: clients/clients.proto
package clients
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
emptypb "google.golang.org/protobuf/types/known/emptypb"
reflect "reflect"
sync "sync"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type Client struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Внутренний идентификатор клиента внутри системы
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// Идентификатор пространства
SpaceId string `protobuf:"bytes,2,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
// Имя приложения (обязательное поле)
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
// Описание клиента, назначение
Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
// Приложение отключено и не может авторизоваться
Disabled *bool `protobuf:"varint,7,opt,name=disabled,proto3,oneof" json:"disabled,omitempty"`
RoleId string `protobuf:"bytes,8,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
Oauth *Client_OAuth `protobuf:"bytes,10,opt,name=oauth,proto3" json:"oauth,omitempty"`
Tls *Client_TLS `protobuf:"bytes,11,opt,name=tls,proto3" json:"tls,omitempty"`
ApiKey *Client_APIKey `protobuf:"bytes,12,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
}
func (x *Client) Reset() {
*x = Client{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Client) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Client) ProtoMessage() {}
func (x *Client) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[0]
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 Client.ProtoReflect.Descriptor instead.
func (*Client) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{0}
}
func (x *Client) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *Client) GetSpaceId() string {
if x != nil {
return x.SpaceId
}
return ""
}
func (x *Client) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *Client) GetDescription() string {
if x != nil {
return x.Description
}
return ""
}
func (x *Client) GetDisabled() bool {
if x != nil && x.Disabled != nil {
return *x.Disabled
}
return false
}
func (x *Client) GetRoleId() string {
if x != nil {
return x.RoleId
}
return ""
}
func (x *Client) GetOauth() *Client_OAuth {
if x != nil {
return x.Oauth
}
return nil
}
func (x *Client) GetTls() *Client_TLS {
if x != nil {
return x.Tls
}
return nil
}
func (x *Client) GetApiKey() *Client_APIKey {
if x != nil {
return x.ApiKey
}
return nil
}
type CreateRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Client *Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
}
func (x *CreateRequest) Reset() {
*x = CreateRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CreateRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateRequest) ProtoMessage() {}
func (x *CreateRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[1]
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 CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{1}
}
func (x *CreateRequest) GetClient() *Client {
if x != nil {
return x.Client
}
return nil
}
type CreateResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Created *Client `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty"`
}
func (x *CreateResponse) Reset() {
*x = CreateResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CreateResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateResponse) ProtoMessage() {}
func (x *CreateResponse) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[2]
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 CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{2}
}
func (x *CreateResponse) GetCreated() *Client {
if x != nil {
return x.Created
}
return nil
}
type GetRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
SpaceId string `protobuf:"bytes,1,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}
func (x *GetRequest) Reset() {
*x = GetRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetRequest) ProtoMessage() {}
func (x *GetRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[3]
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 GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{3}
}
func (x *GetRequest) GetSpaceId() string {
if x != nil {
return x.SpaceId
}
return ""
}
func (x *GetRequest) GetId() string {
if x != nil {
return x.Id
}
return ""
}
type GetResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Client *Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
}
func (x *GetResponse) Reset() {
*x = GetResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetResponse) ProtoMessage() {}
func (x *GetResponse) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[4]
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 GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{4}
}
func (x *GetResponse) GetClient() *Client {
if x != nil {
return x.Client
}
return nil
}
type GetByRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
SpaceId string `protobuf:"bytes,1,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
OauthClientId string `protobuf:"bytes,2,opt,name=oauth_client_id,json=oauthClientId,proto3" json:"oauth_client_id,omitempty"`
TlsSubject string `protobuf:"bytes,3,opt,name=tls_subject,json=tlsSubject,proto3" json:"tls_subject,omitempty"`
ApiKey string `protobuf:"bytes,4,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
}
func (x *GetByRequest) Reset() {
*x = GetByRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetByRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetByRequest) ProtoMessage() {}
func (x *GetByRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[5]
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 GetByRequest.ProtoReflect.Descriptor instead.
func (*GetByRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{5}
}
func (x *GetByRequest) GetSpaceId() string {
if x != nil {
return x.SpaceId
}
return ""
}
func (x *GetByRequest) GetOauthClientId() string {
if x != nil {
return x.OauthClientId
}
return ""
}
func (x *GetByRequest) GetTlsSubject() string {
if x != nil {
return x.TlsSubject
}
return ""
}
func (x *GetByRequest) GetApiKey() string {
if x != nil {
return x.ApiKey
}
return ""
}
type GetByResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Client *Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
}
func (x *GetByResponse) Reset() {
*x = GetByResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetByResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetByResponse) ProtoMessage() {}
func (x *GetByResponse) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_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 GetByResponse.ProtoReflect.Descriptor instead.
func (*GetByResponse) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{6}
}
func (x *GetByResponse) GetClient() *Client {
if x != nil {
return x.Client
}
return nil
}
type UpdateRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Client *Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
}
func (x *UpdateRequest) Reset() {
*x = UpdateRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *UpdateRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UpdateRequest) ProtoMessage() {}
func (x *UpdateRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[7]
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 UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{7}
}
func (x *UpdateRequest) GetClient() *Client {
if x != nil {
return x.Client
}
return nil
}
type ListRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
SpaceId string `protobuf:"bytes,1,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
}
func (x *ListRequest) Reset() {
*x = ListRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ListRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListRequest) ProtoMessage() {}
func (x *ListRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[8]
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 ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{8}
}
func (x *ListRequest) GetSpaceId() string {
if x != nil {
return x.SpaceId
}
return ""
}
type ListResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Clients []*Client `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
}
func (x *ListResponse) Reset() {
*x = ListResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ListResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListResponse) ProtoMessage() {}
func (x *ListResponse) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[9]
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 ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{9}
}
func (x *ListResponse) GetClients() []*Client {
if x != nil {
return x.Clients
}
return nil
}
type DeleteRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
SpaceId string `protobuf:"bytes,1,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}
func (x *DeleteRequest) Reset() {
*x = DeleteRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *DeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteRequest) ProtoMessage() {}
func (x *DeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[10]
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 DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{10}
}
func (x *DeleteRequest) GetSpaceId() string {
if x != nil {
return x.SpaceId
}
return ""
}
func (x *DeleteRequest) GetId() string {
if x != nil {
return x.Id
}
return ""
}
type EnableRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
SpaceId string `protobuf:"bytes,1,opt,name=space_id,json=spaceId,proto3" json:"space_id,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
}
func (x *EnableRequest) Reset() {
*x = EnableRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *EnableRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*EnableRequest) ProtoMessage() {}
func (x *EnableRequest) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[11]
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 EnableRequest.ProtoReflect.Descriptor instead.
func (*EnableRequest) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{11}
}
func (x *EnableRequest) GetSpaceId() string {
if x != nil {
return x.SpaceId
}
return ""
}
func (x *EnableRequest) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *EnableRequest) GetEnable() bool {
if x != nil {
return x.Enable
}
return false
}
type Client_OAuth struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
ClientId string `protobuf:"bytes,4,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` // Идентификатор клиента выданные IdP сервером, используется для идентификации клиента
AuthId string `protobuf:"bytes,5,opt,name=auth_id,json=authId,proto3" json:"auth_id,omitempty"` // Сервис который используется для авторизации клиента
TokenUrl string `protobuf:"bytes,10,opt,name=token_url,json=tokenUrl,proto3" json:"token_url,omitempty"` // URL для получения/обновления access token клиента (опционально)
ClientSecret string `protobuf:"bytes,11,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"` // Секретный Ключ клиента, используется для идентификации клиента (опционально)
}
func (x *Client_OAuth) Reset() {
*x = Client_OAuth{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Client_OAuth) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Client_OAuth) ProtoMessage() {}
func (x *Client_OAuth) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[12]
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 Client_OAuth.ProtoReflect.Descriptor instead.
func (*Client_OAuth) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{0, 0}
}
func (x *Client_OAuth) GetClientId() string {
if x != nil {
return x.ClientId
}
return ""
}
func (x *Client_OAuth) GetAuthId() string {
if x != nil {
return x.AuthId
}
return ""
}
func (x *Client_OAuth) GetTokenUrl() string {
if x != nil {
return x.TokenUrl
}
return ""
}
func (x *Client_OAuth) GetClientSecret() string {
if x != nil {
return x.ClientSecret
}
return ""
}
type Client_APIKey struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Rotate bool `protobuf:"varint,2,opt,name=rotate,proto3" json:"rotate,omitempty"`
}
func (x *Client_APIKey) Reset() {
*x = Client_APIKey{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Client_APIKey) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Client_APIKey) ProtoMessage() {}
func (x *Client_APIKey) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[13]
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 Client_APIKey.ProtoReflect.Descriptor instead.
func (*Client_APIKey) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{0, 1}
}
func (x *Client_APIKey) GetKey() string {
if x != nil {
return x.Key
}
return ""
}
func (x *Client_APIKey) GetRotate() bool {
if x != nil {
return x.Rotate
}
return false
}
type Client_TLS struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
}
func (x *Client_TLS) Reset() {
*x = Client_TLS{}
if protoimpl.UnsafeEnabled {
mi := &file_clients_clients_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Client_TLS) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Client_TLS) ProtoMessage() {}
func (x *Client_TLS) ProtoReflect() protoreflect.Message {
mi := &file_clients_clients_proto_msgTypes[14]
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 Client_TLS.ProtoReflect.Descriptor instead.
func (*Client_TLS) Descriptor() ([]byte, []int) {
return file_clients_clients_proto_rawDescGZIP(), []int{0, 2}
}
func (x *Client_TLS) GetSubject() string {
if x != nil {
return x.Subject
}
return ""
}
var File_clients_clients_proto protoreflect.FileDescriptor
var file_clients_clients_proto_rawDesc = []byte{
0x0a, 0x15, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0f, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74,
0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa3, 0x04, 0x0a, 0x06, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64,
0x12, 0x19, 0x0a, 0x08, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x07, 0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e,
0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12,
0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x06,
0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f,
0x6e, 0x12, 0x1f, 0x0a, 0x08, 0x64, 0x69, 0x73, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x18, 0x07, 0x20,
0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x08, 0x64, 0x69, 0x73, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x88,
0x01, 0x01, 0x12, 0x17, 0x0a, 0x07, 0x72, 0x6f, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20,
0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x6f, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x33, 0x0a, 0x05, 0x6f,
0x61, 0x75, 0x74, 0x68, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x63, 0x6f, 0x6e,
0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x43, 0x6c, 0x69,
0x65, 0x6e, 0x74, 0x2e, 0x4f, 0x41, 0x75, 0x74, 0x68, 0x52, 0x05, 0x6f, 0x61, 0x75, 0x74, 0x68,
0x12, 0x2d, 0x0a, 0x03, 0x74, 0x6c, 0x73, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e,
0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e,
0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x54, 0x4c, 0x53, 0x52, 0x03, 0x74, 0x6c, 0x73, 0x12,
0x37, 0x0a, 0x07, 0x61, 0x70, 0x69, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x1e, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x73, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x41, 0x50, 0x49, 0x4b, 0x65, 0x79,
0x52, 0x06, 0x61, 0x70, 0x69, 0x4b, 0x65, 0x79, 0x1a, 0x7f, 0x0a, 0x05, 0x4f, 0x41, 0x75, 0x74,
0x68, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04,
0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x17,
0x0a, 0x07, 0x61, 0x75, 0x74, 0x68, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52,
0x06, 0x61, 0x75, 0x74, 0x68, 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x6f, 0x6b, 0x65, 0x6e,
0x5f, 0x75, 0x72, 0x6c, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x6f, 0x6b, 0x65,
0x6e, 0x55, 0x72, 0x6c, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73,
0x65, 0x63, 0x72, 0x65, 0x74, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x6c, 0x69,
0x65, 0x6e, 0x74, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x1a, 0x32, 0x0a, 0x06, 0x41, 0x50, 0x49,
0x4b, 0x65, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x6f, 0x74, 0x61, 0x74, 0x65, 0x18,
0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x72, 0x6f, 0x74, 0x61, 0x74, 0x65, 0x1a, 0x1f, 0x0a,
0x03, 0x54, 0x4c, 0x53, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18,
0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x42, 0x0b,
0x0a, 0x09, 0x5f, 0x64, 0x69, 0x73, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x22, 0x40, 0x0a, 0x0d, 0x43,
0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2f, 0x0a, 0x06,
0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x63,
0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x43,
0x6c, 0x69, 0x65, 0x6e, 0x74, 0x52, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x22, 0x43, 0x0a,
0x0e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
0x31, 0x0a, 0x07, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x17, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x73, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x52, 0x07, 0x63, 0x72, 0x65, 0x61, 0x74,
0x65, 0x64, 0x22, 0x37, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x12, 0x19, 0x0a, 0x08, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
0x28, 0x09, 0x52, 0x07, 0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x69,
0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x22, 0x3e, 0x0a, 0x0b, 0x47,
0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2f, 0x0a, 0x06, 0x63, 0x6c,
0x69, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x63, 0x6f, 0x6e,
0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x43, 0x6c, 0x69,
0x65, 0x6e, 0x74, 0x52, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x22, 0x8b, 0x01, 0x0a, 0x0c,
0x47, 0x65, 0x74, 0x42, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08,
0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x26, 0x0a, 0x0f, 0x6f, 0x61, 0x75, 0x74, 0x68,
0x5f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0d, 0x6f, 0x61, 0x75, 0x74, 0x68, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12,
0x1f, 0x0a, 0x0b, 0x74, 0x6c, 0x73, 0x5f, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x03,
0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x74, 0x6c, 0x73, 0x53, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74,
0x12, 0x17, 0x0a, 0x07, 0x61, 0x70, 0x69, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x04, 0x20, 0x01, 0x28,
0x09, 0x52, 0x06, 0x61, 0x70, 0x69, 0x4b, 0x65, 0x79, 0x22, 0x40, 0x0a, 0x0d, 0x47, 0x65, 0x74,
0x42, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2f, 0x0a, 0x06, 0x63, 0x6c,
0x69, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x63, 0x6f, 0x6e,
0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x43, 0x6c, 0x69,
0x65, 0x6e, 0x74, 0x52, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x22, 0x40, 0x0a, 0x0d, 0x55,
0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2f, 0x0a, 0x06,
0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x63,
0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x43,
0x6c, 0x69, 0x65, 0x6e, 0x74, 0x52, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x22, 0x28, 0x0a,
0x0b, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08,
0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x22, 0x41, 0x0a, 0x0c, 0x4c, 0x69, 0x73, 0x74, 0x52,
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x31, 0x0a, 0x07, 0x63, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65,
0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x52, 0x07, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x22, 0x3a, 0x0a, 0x0d, 0x44, 0x65,
0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08, 0x73,
0x70, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73,
0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x22, 0x52, 0x0a, 0x0d, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08, 0x73, 0x70, 0x61, 0x63, 0x65,
0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x70, 0x61, 0x63, 0x65,
0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02,
0x69, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01,
0x28, 0x08, 0x52, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x32, 0xf7, 0x03, 0x0a, 0x07, 0x43,
0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x4b, 0x0a, 0x06, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65,
0x12, 0x1e, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x73, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x1a, 0x1f, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x73, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
0x65, 0x22, 0x00, 0x12, 0x42, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, 0x1b, 0x2e, 0x63, 0x6f, 0x6e,
0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x47, 0x65, 0x74,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e,
0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73,
0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x48, 0x0a, 0x05, 0x47, 0x65, 0x74, 0x42, 0x79,
0x12, 0x1d, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e,
0x74, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
0x1e, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
0x73, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
0x00, 0x12, 0x42, 0x0a, 0x06, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x1e, 0x2e, 0x63, 0x6f,
0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x55, 0x70,
0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f,
0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d,
0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x45, 0x0a, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1c, 0x2e,
0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e,
0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x63, 0x6f,
0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x4c, 0x69,
0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x42, 0x0a, 0x06,
0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x1e, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74,
0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00,
0x12, 0x42, 0x0a, 0x06, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x1e, 0x2e, 0x63, 0x6f, 0x6e,
0x74, 0x65, 0x6e, 0x74, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x45, 0x6e, 0x61,
0x62, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f,
0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70,
0x74, 0x79, 0x22, 0x00, 0x42, 0x2e, 0x5a, 0x2c, 0x67, 0x69, 0x74, 0x2e, 0x70, 0x65, 0x72, 0x78,
0x2e, 0x72, 0x75, 0x2f, 0x70, 0x65, 0x72, 0x78, 0x69, 0x73, 0x2f, 0x70, 0x65, 0x72, 0x78, 0x69,
0x73, 0x2d, 0x67, 0x6f, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x3b, 0x63, 0x6c, 0x69,
0x65, 0x6e, 0x74, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_clients_clients_proto_rawDescOnce sync.Once
file_clients_clients_proto_rawDescData = file_clients_clients_proto_rawDesc
)
func file_clients_clients_proto_rawDescGZIP() []byte {
file_clients_clients_proto_rawDescOnce.Do(func() {
file_clients_clients_proto_rawDescData = protoimpl.X.CompressGZIP(file_clients_clients_proto_rawDescData)
})
return file_clients_clients_proto_rawDescData
}
var file_clients_clients_proto_msgTypes = make([]protoimpl.MessageInfo, 15)
var file_clients_clients_proto_goTypes = []interface{}{
(*Client)(nil), // 0: content.clients.Client
(*CreateRequest)(nil), // 1: content.clients.CreateRequest
(*CreateResponse)(nil), // 2: content.clients.CreateResponse
(*GetRequest)(nil), // 3: content.clients.GetRequest
(*GetResponse)(nil), // 4: content.clients.GetResponse
(*GetByRequest)(nil), // 5: content.clients.GetByRequest
(*GetByResponse)(nil), // 6: content.clients.GetByResponse
(*UpdateRequest)(nil), // 7: content.clients.UpdateRequest
(*ListRequest)(nil), // 8: content.clients.ListRequest
(*ListResponse)(nil), // 9: content.clients.ListResponse
(*DeleteRequest)(nil), // 10: content.clients.DeleteRequest
(*EnableRequest)(nil), // 11: content.clients.EnableRequest
(*Client_OAuth)(nil), // 12: content.clients.Client.OAuth
(*Client_APIKey)(nil), // 13: content.clients.Client.APIKey
(*Client_TLS)(nil), // 14: content.clients.Client.TLS
(*emptypb.Empty)(nil), // 15: google.protobuf.Empty
}
var file_clients_clients_proto_depIdxs = []int32{
12, // 0: content.clients.Client.oauth:type_name -> content.clients.Client.OAuth
14, // 1: content.clients.Client.tls:type_name -> content.clients.Client.TLS
13, // 2: content.clients.Client.api_key:type_name -> content.clients.Client.APIKey
0, // 3: content.clients.CreateRequest.client:type_name -> content.clients.Client
0, // 4: content.clients.CreateResponse.created:type_name -> content.clients.Client
0, // 5: content.clients.GetResponse.client:type_name -> content.clients.Client
0, // 6: content.clients.GetByResponse.client:type_name -> content.clients.Client
0, // 7: content.clients.UpdateRequest.client:type_name -> content.clients.Client
0, // 8: content.clients.ListResponse.clients:type_name -> content.clients.Client
1, // 9: content.clients.Clients.Create:input_type -> content.clients.CreateRequest
3, // 10: content.clients.Clients.Get:input_type -> content.clients.GetRequest
5, // 11: content.clients.Clients.GetBy:input_type -> content.clients.GetByRequest
7, // 12: content.clients.Clients.Update:input_type -> content.clients.UpdateRequest
8, // 13: content.clients.Clients.List:input_type -> content.clients.ListRequest
10, // 14: content.clients.Clients.Delete:input_type -> content.clients.DeleteRequest
11, // 15: content.clients.Clients.Enable:input_type -> content.clients.EnableRequest
2, // 16: content.clients.Clients.Create:output_type -> content.clients.CreateResponse
4, // 17: content.clients.Clients.Get:output_type -> content.clients.GetResponse
6, // 18: content.clients.Clients.GetBy:output_type -> content.clients.GetByResponse
15, // 19: content.clients.Clients.Update:output_type -> google.protobuf.Empty
9, // 20: content.clients.Clients.List:output_type -> content.clients.ListResponse
15, // 21: content.clients.Clients.Delete:output_type -> google.protobuf.Empty
15, // 22: content.clients.Clients.Enable:output_type -> google.protobuf.Empty
16, // [16:23] is the sub-list for method output_type
9, // [9:16] is the sub-list for method input_type
9, // [9:9] is the sub-list for extension type_name
9, // [9:9] is the sub-list for extension extendee
0, // [0:9] is the sub-list for field type_name
}
func init() { file_clients_clients_proto_init() }
func file_clients_clients_proto_init() {
if File_clients_clients_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_clients_clients_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Client); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CreateRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CreateResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetByRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetByResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UpdateRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ListRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ListResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DeleteRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*EnableRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Client_OAuth); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Client_APIKey); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_clients_clients_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Client_TLS); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
file_clients_clients_proto_msgTypes[0].OneofWrappers = []interface{}{}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_clients_clients_proto_rawDesc,
NumEnums: 0,
NumMessages: 15,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_clients_clients_proto_goTypes,
DependencyIndexes: file_clients_clients_proto_depIdxs,
MessageInfos: file_clients_clients_proto_msgTypes,
}.Build()
File_clients_clients_proto = out.File
file_clients_clients_proto_rawDesc = nil
file_clients_clients_proto_goTypes = nil
file_clients_clients_proto_depIdxs = nil
}
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package clients
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// ClientsClient is the client API for Clients service.
//
// 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 ClientsClient interface {
// Create - создает клиента (приложение) для работы с API
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
// Get - возвращает клиента по id
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
// GetByClientID - возвращает клиента по clientId системы авторизации
GetBy(ctx context.Context, in *GetByRequest, opts ...grpc.CallOption) (*GetByResponse, error)
// Update - обновляет параметры клиента
Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// List - возвращает список клиентов созданных в пространстве
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
// Delete - удаляет указанного клиента из пространстве
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Enable - активирует/деактивирует клиента. Клиент не сможет обращаться к API платформы
Enable(ctx context.Context, in *EnableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
type clientsClient struct {
cc grpc.ClientConnInterface
}
func NewClientsClient(cc grpc.ClientConnInterface) ClientsClient {
return &clientsClient{cc}
}
func (c *clientsClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
out := new(CreateResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Create", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
out := new(GetResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Get", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) GetBy(ctx context.Context, in *GetByRequest, opts ...grpc.CallOption) (*GetByResponse, error) {
out := new(GetByResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/GetBy", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Update", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
out := new(ListResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/List", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Delete", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Enable(ctx context.Context, in *EnableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Enable", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// ClientsServer is the server API for Clients service.
// All implementations must embed UnimplementedClientsServer
// for forward compatibility
type ClientsServer interface {
// Create - создает клиента (приложение) для работы с API
Create(context.Context, *CreateRequest) (*CreateResponse, error)
// Get - возвращает клиента по id
Get(context.Context, *GetRequest) (*GetResponse, error)
// GetByClientID - возвращает клиента по clientId системы авторизации
GetBy(context.Context, *GetByRequest) (*GetByResponse, error)
// Update - обновляет параметры клиента
Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)
// List - возвращает список клиентов созданных в пространстве
List(context.Context, *ListRequest) (*ListResponse, error)
// Delete - удаляет указанного клиента из пространстве
Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
// Enable - активирует/деактивирует клиента. Клиент не сможет обращаться к API платформы
Enable(context.Context, *EnableRequest) (*emptypb.Empty, error)
mustEmbedUnimplementedClientsServer()
}
// UnimplementedClientsServer must be embedded to have forward compatible implementations.
type UnimplementedClientsServer struct {
}
func (UnimplementedClientsServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedClientsServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (UnimplementedClientsServer) GetBy(context.Context, *GetByRequest) (*GetByResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetBy not implemented")
}
func (UnimplementedClientsServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
}
func (UnimplementedClientsServer) List(context.Context, *ListRequest) (*ListResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
}
func (UnimplementedClientsServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
}
func (UnimplementedClientsServer) Enable(context.Context, *EnableRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Enable not implemented")
}
func (UnimplementedClientsServer) mustEmbedUnimplementedClientsServer() {}
// UnsafeClientsServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ClientsServer will
// result in compilation errors.
type UnsafeClientsServer interface {
mustEmbedUnimplementedClientsServer()
}
func RegisterClientsServer(s grpc.ServiceRegistrar, srv ClientsServer) {
s.RegisterService(&Clients_ServiceDesc, srv)
}
func _Clients_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Create(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Create",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Create(ctx, req.(*CreateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Get(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Get",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Get(ctx, req.(*GetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_GetBy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetByRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).GetBy(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/GetBy",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).GetBy(ctx, req.(*GetByRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Update(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Update",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Update(ctx, req.(*UpdateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).List(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/List",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).List(ctx, req.(*ListRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Delete(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Delete",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Delete(ctx, req.(*DeleteRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Enable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EnableRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Enable(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Enable",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Enable(ctx, req.(*EnableRequest))
}
return interceptor(ctx, in, info, handler)
}
// Clients_ServiceDesc is the grpc.ServiceDesc for Clients service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Clients_ServiceDesc = grpc.ServiceDesc{
ServiceName: "content.clients.Clients",
HandlerType: (*ClientsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Create",
Handler: _Clients_Create_Handler,
},
{
MethodName: "Get",
Handler: _Clients_Get_Handler,
},
{
MethodName: "GetBy",
Handler: _Clients_GetBy_Handler,
},
{
MethodName: "Update",
Handler: _Clients_Update_Handler,
},
{
MethodName: "List",
Handler: _Clients_List_Handler,
},
{
MethodName: "Delete",
Handler: _Clients_Delete_Handler,
},
{
MethodName: "Enable",
Handler: _Clients_Enable_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "clients/clients.proto",
}
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package collaborators
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// CollaboratorsClient is the client API for Collaborators service.
//
// 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 CollaboratorsClient interface {
Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ListCollaborators(ctx context.Context, in *ListCollaboratorsRequest, opts ...grpc.CallOption) (*ListCollaboratorsResponse, error)
ListSpaces(ctx context.Context, in *ListSpacesRequest, opts ...grpc.CallOption) (*ListSpacesResponse, error)
}
type collaboratorsClient struct {
cc grpc.ClientConnInterface
}
func NewCollaboratorsClient(cc grpc.ClientConnInterface) CollaboratorsClient {
return &collaboratorsClient{cc}
}
func (c *collaboratorsClient) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/Set", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
out := new(GetResponse)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/Get", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/Remove", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) ListCollaborators(ctx context.Context, in *ListCollaboratorsRequest, opts ...grpc.CallOption) (*ListCollaboratorsResponse, error) {
out := new(ListCollaboratorsResponse)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/ListCollaborators", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) ListSpaces(ctx context.Context, in *ListSpacesRequest, opts ...grpc.CallOption) (*ListSpacesResponse, error) {
out := new(ListSpacesResponse)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/ListSpaces", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// CollaboratorsServer is the server API for Collaborators service.
// All implementations must embed UnimplementedCollaboratorsServer
// for forward compatibility
type CollaboratorsServer interface {
Set(context.Context, *SetRequest) (*emptypb.Empty, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
Remove(context.Context, *RemoveRequest) (*emptypb.Empty, error)
ListCollaborators(context.Context, *ListCollaboratorsRequest) (*ListCollaboratorsResponse, error)
ListSpaces(context.Context, *ListSpacesRequest) (*ListSpacesResponse, error)
mustEmbedUnimplementedCollaboratorsServer()
}
// UnimplementedCollaboratorsServer must be embedded to have forward compatible implementations.
type UnimplementedCollaboratorsServer struct {
}
func (UnimplementedCollaboratorsServer) Set(context.Context, *SetRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Set not implemented")
}
func (UnimplementedCollaboratorsServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (UnimplementedCollaboratorsServer) Remove(context.Context, *RemoveRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Remove not implemented")
}
func (UnimplementedCollaboratorsServer) ListCollaborators(context.Context, *ListCollaboratorsRequest) (*ListCollaboratorsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListCollaborators not implemented")
}
func (UnimplementedCollaboratorsServer) ListSpaces(context.Context, *ListSpacesRequest) (*ListSpacesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListSpaces not implemented")
}
func (UnimplementedCollaboratorsServer) mustEmbedUnimplementedCollaboratorsServer() {}
// UnsafeCollaboratorsServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to CollaboratorsServer will
// result in compilation errors.
type UnsafeCollaboratorsServer interface {
mustEmbedUnimplementedCollaboratorsServer()
}
func RegisterCollaboratorsServer(s grpc.ServiceRegistrar, srv CollaboratorsServer) {
s.RegisterService(&Collaborators_ServiceDesc, srv)
}
func _Collaborators_Set_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).Set(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/Set",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).Set(ctx, req.(*SetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).Get(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/Get",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).Get(ctx, req.(*GetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_Remove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).Remove(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/Remove",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).Remove(ctx, req.(*RemoveRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_ListCollaborators_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListCollaboratorsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).ListCollaborators(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/ListCollaborators",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).ListCollaborators(ctx, req.(*ListCollaboratorsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_ListSpaces_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListSpacesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).ListSpaces(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/ListSpaces",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).ListSpaces(ctx, req.(*ListSpacesRequest))
}
return interceptor(ctx, in, info, handler)
}
// Collaborators_ServiceDesc is the grpc.ServiceDesc for Collaborators service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Collaborators_ServiceDesc = grpc.ServiceDesc{
ServiceName: "content.collaborators.Collaborators",
HandlerType: (*CollaboratorsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Set",
Handler: _Collaborators_Set_Handler,
},
{
MethodName: "Get",
Handler: _Collaborators_Get_Handler,
},
{
MethodName: "Remove",
Handler: _Collaborators_Remove_Handler,
},
{
MethodName: "ListCollaborators",
Handler: _Collaborators_ListCollaborators_Handler,
},
{
MethodName: "ListSpaces",
Handler: _Collaborators_ListSpaces_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "collaborators/collaborators.proto",
}
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package collections
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// CollectionsClient is the client API for Collections service.
//
// 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 CollectionsClient interface {
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
SetSchema(ctx context.Context, in *SetSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
type collectionsClient struct {
cc grpc.ClientConnInterface
}
func NewCollectionsClient(cc grpc.ClientConnInterface) CollectionsClient {
return &collectionsClient{cc}
}
func (c *collectionsClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
out := new(CreateResponse)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Create", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
out := new(GetResponse)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Get", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
out := new(ListResponse)
err := c.cc.Invoke(ctx, "/content.collections.Collections/List", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Update", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) SetSchema(ctx context.Context, in *SetSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collections.Collections/SetSchema", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Delete", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// CollectionsServer is the server API for Collections service.
// All implementations must embed UnimplementedCollectionsServer
// for forward compatibility
type CollectionsServer interface {
Create(context.Context, *CreateRequest) (*CreateResponse, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
List(context.Context, *ListRequest) (*ListResponse, error)
Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)
SetSchema(context.Context, *SetSchemaRequest) (*emptypb.Empty, error)
Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
mustEmbedUnimplementedCollectionsServer()
}
// UnimplementedCollectionsServer must be embedded to have forward compatible implementations.
type UnimplementedCollectionsServer struct {
}
func (UnimplementedCollectionsServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedCollectionsServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (UnimplementedCollectionsServer) List(context.Context, *ListRequest) (*ListResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
}
func (UnimplementedCollectionsServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
}
func (UnimplementedCollectionsServer) SetSchema(context.Context, *SetSchemaRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method SetSchema not implemented")
}
func (UnimplementedCollectionsServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
}
func (UnimplementedCollectionsServer) mustEmbedUnimplementedCollectionsServer() {}
// UnsafeCollectionsServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to CollectionsServer will
// result in compilation errors.
type UnsafeCollectionsServer interface {
mustEmbedUnimplementedCollectionsServer()
}
func RegisterCollectionsServer(s grpc.ServiceRegistrar, srv CollectionsServer) {
s.RegisterService(&Collections_ServiceDesc, srv)
}
func _Collections_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Create(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Create",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Create(ctx, req.(*CreateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Get(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Get",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Get(ctx, req.(*GetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).List(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/List",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).List(ctx, req.(*ListRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Update(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Update",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Update(ctx, req.(*UpdateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_SetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetSchemaRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).SetSchema(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/SetSchema",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).SetSchema(ctx, req.(*SetSchemaRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Delete(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Delete",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Delete(ctx, req.(*DeleteRequest))
}
return interceptor(ctx, in, info, handler)
}
// Collections_ServiceDesc is the grpc.ServiceDesc for Collections service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Collections_ServiceDesc = grpc.ServiceDesc{
ServiceName: "content.collections.Collections",
HandlerType: (*CollectionsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Create",
Handler: _Collections_Create_Handler,
},
{
MethodName: "Get",
Handler: _Collections_Get_Handler,
},
{
MethodName: "List",
Handler: _Collections_List_Handler,
},
{
MethodName: "Update",
Handler: _Collections_Update_Handler,
},
{
MethodName: "SetSchema",
Handler: _Collections_SetSchema_Handler,
},
{
MethodName: "Delete",
Handler: _Collections_Delete_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "collections/collections.proto",
}
This diff is collapsed.
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package delivery
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// DeliveryClient is the client API for Delivery service.
//
// 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 DeliveryClient interface {
ListLocales(ctx context.Context, in *ListLocalesRequest, opts ...grpc.CallOption) (*ListLocalesResponse, error)
GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentResponse, error)
ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
GetCollection(ctx context.Context, in *GetCollectionRequest, opts ...grpc.CallOption) (*GetCollectionResponse, error)
ListCollections(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*ListCollectionsResponse, error)
GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error)
FindItems(ctx context.Context, in *FindItemsRequest, opts ...grpc.CallOption) (*FindItemsResponse, error)
Aggregate(ctx context.Context, in *AggregateRequest, opts ...grpc.CallOption) (*AggregateResponse, error)
}
type deliveryClient struct {
cc grpc.ClientConnInterface
}
func NewDeliveryClient(cc grpc.ClientConnInterface) DeliveryClient {
return &deliveryClient{cc}
}
func (c *deliveryClient) ListLocales(ctx context.Context, in *ListLocalesRequest, opts ...grpc.CallOption) (*ListLocalesResponse, error) {
out := new(ListLocalesResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/ListLocales", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentResponse, error) {
out := new(GetEnvironmentResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/GetEnvironment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error) {
out := new(ListEnvironmentsResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/ListEnvironments", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) GetCollection(ctx context.Context, in *GetCollectionRequest, opts ...grpc.CallOption) (*GetCollectionResponse, error) {
out := new(GetCollectionResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/GetCollection", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) ListCollections(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*ListCollectionsResponse, error) {
out := new(ListCollectionsResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/ListCollections", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error) {
out := new(GetItemResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/GetItem", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) FindItems(ctx context.Context, in *FindItemsRequest, opts ...grpc.CallOption) (*FindItemsResponse, error) {
out := new(FindItemsResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/FindItems", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) Aggregate(ctx context.Context, in *AggregateRequest, opts ...grpc.CallOption) (*AggregateResponse, error) {
out := new(AggregateResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/Aggregate", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// DeliveryServer is the server API for Delivery service.
// All implementations must embed UnimplementedDeliveryServer
// for forward compatibility
type DeliveryServer interface {
ListLocales(context.Context, *ListLocalesRequest) (*ListLocalesResponse, error)
GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentResponse, error)
ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error)
ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsResponse, error)
GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error)
FindItems(context.Context, *FindItemsRequest) (*FindItemsResponse, error)
Aggregate(context.Context, *AggregateRequest) (*AggregateResponse, error)
mustEmbedUnimplementedDeliveryServer()
}
// UnimplementedDeliveryServer must be embedded to have forward compatible implementations.
type UnimplementedDeliveryServer struct {
}
func (UnimplementedDeliveryServer) ListLocales(context.Context, *ListLocalesRequest) (*ListLocalesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListLocales not implemented")
}
func (UnimplementedDeliveryServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetEnvironment not implemented")
}
func (UnimplementedDeliveryServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListEnvironments not implemented")
}
func (UnimplementedDeliveryServer) GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetCollection not implemented")
}
func (UnimplementedDeliveryServer) ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListCollections not implemented")
}
func (UnimplementedDeliveryServer) GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetItem not implemented")
}
func (UnimplementedDeliveryServer) FindItems(context.Context, *FindItemsRequest) (*FindItemsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method FindItems not implemented")
}
func (UnimplementedDeliveryServer) Aggregate(context.Context, *AggregateRequest) (*AggregateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Aggregate not implemented")
}
func (UnimplementedDeliveryServer) mustEmbedUnimplementedDeliveryServer() {}
// UnsafeDeliveryServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to DeliveryServer will
// result in compilation errors.
type UnsafeDeliveryServer interface {
mustEmbedUnimplementedDeliveryServer()
}
func RegisterDeliveryServer(s grpc.ServiceRegistrar, srv DeliveryServer) {
s.RegisterService(&Delivery_ServiceDesc, srv)
}
func _Delivery_ListLocales_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListLocalesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).ListLocales(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/ListLocales",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).ListLocales(ctx, req.(*ListLocalesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_GetEnvironment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetEnvironmentRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).GetEnvironment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/GetEnvironment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).GetEnvironment(ctx, req.(*GetEnvironmentRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_ListEnvironments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListEnvironmentsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).ListEnvironments(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/ListEnvironments",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).ListEnvironments(ctx, req.(*ListEnvironmentsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_GetCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetCollectionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).GetCollection(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/GetCollection",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).GetCollection(ctx, req.(*GetCollectionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_ListCollections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListCollectionsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).ListCollections(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/ListCollections",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).ListCollections(ctx, req.(*ListCollectionsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_GetItem_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetItemRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).GetItem(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/GetItem",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).GetItem(ctx, req.(*GetItemRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_FindItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(FindItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).FindItems(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/FindItems",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).FindItems(ctx, req.(*FindItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_Aggregate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AggregateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).Aggregate(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/Aggregate",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).Aggregate(ctx, req.(*AggregateRequest))
}
return interceptor(ctx, in, info, handler)
}
// Delivery_ServiceDesc is the grpc.ServiceDesc for Delivery service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Delivery_ServiceDesc = grpc.ServiceDesc{
ServiceName: "delivery.Delivery",
HandlerType: (*DeliveryServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "ListLocales",
Handler: _Delivery_ListLocales_Handler,
},
{
MethodName: "GetEnvironment",
Handler: _Delivery_GetEnvironment_Handler,
},
{
MethodName: "ListEnvironments",
Handler: _Delivery_ListEnvironments_Handler,
},
{
MethodName: "GetCollection",
Handler: _Delivery_GetCollection_Handler,
},
{
MethodName: "ListCollections",
Handler: _Delivery_ListCollections_Handler,
},
{
MethodName: "GetItem",
Handler: _Delivery_GetItem_Handler,
},
{
MethodName: "FindItems",
Handler: _Delivery_FindItems_Handler,
},
{
MethodName: "Aggregate",
Handler: _Delivery_Aggregate_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "delivery/delivery.proto",
}
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package extensions
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// ExtensionClient is the client API for Extension service.
//
// 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 ExtensionClient interface {
// Для установки расширения выполняется запрос к сервису с указанием расширений которые должны быть установлены. Если
// расширение уже установлено процесс возвращает ошибку.
Install(ctx context.Context, in *InstallRequest, opts ...grpc.CallOption) (*InstallResponse, error)
// Можно запросить проверку статуса установки для расширения. При этом расширение проверяет наличие необходимых данных в
// пространстве или наличие новой версии расширения и сообщает об этом. Никаких действий с данными пространства не
// производится.
Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
// Сервис выполняет необходимые действия с данными и миграции для соответствия нужной версии расширения.
// Если расширение не установлено процесс обновления возвращает ошибку.
Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
// Удаление расширения из пространства.
Uninstall(ctx context.Context, in *UninstallRequest, opts ...grpc.CallOption) (*UninstallResponse, error)
// Пользовательские Действия (Actions)
//
// Пользовательские действия позволяют расширить функционал пользовательского интерфейса путем
// добавления в интерфейс элементов взаимодействуя с которыми пользователь может вызывать реакцию на
// сервере или переход в интерфейсе.
//
// Пользовательские действия добавляются при установке расширений в системную коллекции `System/Actions`.
// Коллекция создается автоматически менеджером расширений. При установке так же отображается меню `Действия`
// доступное для всех пользователей.
//
// Примеры пользовательских действий:
// - "Собрать сайт" - добавляется Perxis.Web для сборки сайта, доступна пользователю через меню,
// параметры space_id, env_id. При вызове выполняется запрос на сервер ProcessAction.
// - "Посмотреть задачи" - добавляется Tasks для перехода на коллекцию задач. Отображается в меню,
// параметры space_id, env_id.
//
// Приложения так же могут использовать действия для вызова обработки в других приложениях при
// необходимости.
Action(ctx context.Context, in *ActionRequest, opts ...grpc.CallOption) (*ActionResponse, error)
}
type extensionClient struct {
cc grpc.ClientConnInterface
}
func NewExtensionClient(cc grpc.ClientConnInterface) ExtensionClient {
return &extensionClient{cc}
}
func (c *extensionClient) Install(ctx context.Context, in *InstallRequest, opts ...grpc.CallOption) (*InstallResponse, error) {
out := new(InstallResponse)
err := c.cc.Invoke(ctx, "/extensions.Extension/Install", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *extensionClient) Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error) {
out := new(CheckResponse)
err := c.cc.Invoke(ctx, "/extensions.Extension/Check", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *extensionClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) {
out := new(UpdateResponse)
err := c.cc.Invoke(ctx, "/extensions.Extension/Update", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *extensionClient) Uninstall(ctx context.Context, in *UninstallRequest, opts ...grpc.CallOption) (*UninstallResponse, error) {
out := new(UninstallResponse)
err := c.cc.Invoke(ctx, "/extensions.Extension/Uninstall", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *extensionClient) Action(ctx context.Context, in *ActionRequest, opts ...grpc.CallOption) (*ActionResponse, error) {
out := new(ActionResponse)
err := c.cc.Invoke(ctx, "/extensions.Extension/Action", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// ExtensionServer is the server API for Extension service.
// All implementations must embed UnimplementedExtensionServer
// for forward compatibility
type ExtensionServer interface {
// Для установки расширения выполняется запрос к сервису с указанием расширений которые должны быть установлены. Если
// расширение уже установлено процесс возвращает ошибку.
Install(context.Context, *InstallRequest) (*InstallResponse, error)
// Можно запросить проверку статуса установки для расширения. При этом расширение проверяет наличие необходимых данных в
// пространстве или наличие новой версии расширения и сообщает об этом. Никаких действий с данными пространства не
// производится.
Check(context.Context, *CheckRequest) (*CheckResponse, error)
// Сервис выполняет необходимые действия с данными и миграции для соответствия нужной версии расширения.
// Если расширение не установлено процесс обновления возвращает ошибку.
Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
// Удаление расширения из пространства.
Uninstall(context.Context, *UninstallRequest) (*UninstallResponse, error)
// Пользовательские Действия (Actions)
//
// Пользовательские действия позволяют расширить функционал пользовательского интерфейса путем
// добавления в интерфейс элементов взаимодействуя с которыми пользователь может вызывать реакцию на
// сервере или переход в интерфейсе.
//
// Пользовательские действия добавляются при установке расширений в системную коллекции `System/Actions`.
// Коллекция создается автоматически менеджером расширений. При установке так же отображается меню `Действия`
// доступное для всех пользователей.
//
// Примеры пользовательских действий:
// - "Собрать сайт" - добавляется Perxis.Web для сборки сайта, доступна пользователю через меню,
// параметры space_id, env_id. При вызове выполняется запрос на сервер ProcessAction.
// - "Посмотреть задачи" - добавляется Tasks для перехода на коллекцию задач. Отображается в меню,
// параметры space_id, env_id.
//
// Приложения так же могут использовать действия для вызова обработки в других приложениях при
// необходимости.
Action(context.Context, *ActionRequest) (*ActionResponse, error)
mustEmbedUnimplementedExtensionServer()
}
// UnimplementedExtensionServer must be embedded to have forward compatible implementations.
type UnimplementedExtensionServer struct {
}
func (UnimplementedExtensionServer) Install(context.Context, *InstallRequest) (*InstallResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Install not implemented")
}
func (UnimplementedExtensionServer) Check(context.Context, *CheckRequest) (*CheckResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Check not implemented")
}
func (UnimplementedExtensionServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
}
func (UnimplementedExtensionServer) Uninstall(context.Context, *UninstallRequest) (*UninstallResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Uninstall not implemented")
}
func (UnimplementedExtensionServer) Action(context.Context, *ActionRequest) (*ActionResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Action not implemented")
}
func (UnimplementedExtensionServer) mustEmbedUnimplementedExtensionServer() {}
// UnsafeExtensionServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ExtensionServer will
// result in compilation errors.
type UnsafeExtensionServer interface {
mustEmbedUnimplementedExtensionServer()
}
func RegisterExtensionServer(s grpc.ServiceRegistrar, srv ExtensionServer) {
s.RegisterService(&Extension_ServiceDesc, srv)
}
func _Extension_Install_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(InstallRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ExtensionServer).Install(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.Extension/Install",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionServer).Install(ctx, req.(*InstallRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Extension_Check_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CheckRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ExtensionServer).Check(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.Extension/Check",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionServer).Check(ctx, req.(*CheckRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Extension_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ExtensionServer).Update(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.Extension/Update",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionServer).Update(ctx, req.(*UpdateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Extension_Uninstall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UninstallRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ExtensionServer).Uninstall(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.Extension/Uninstall",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionServer).Uninstall(ctx, req.(*UninstallRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Extension_Action_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ActionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ExtensionServer).Action(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.Extension/Action",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionServer).Action(ctx, req.(*ActionRequest))
}
return interceptor(ctx, in, info, handler)
}
// Extension_ServiceDesc is the grpc.ServiceDesc for Extension service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Extension_ServiceDesc = grpc.ServiceDesc{
ServiceName: "extensions.Extension",
HandlerType: (*ExtensionServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Install",
Handler: _Extension_Install_Handler,
},
{
MethodName: "Check",
Handler: _Extension_Check_Handler,
},
{
MethodName: "Update",
Handler: _Extension_Update_Handler,
},
{
MethodName: "Uninstall",
Handler: _Extension_Uninstall_Handler,
},
{
MethodName: "Action",
Handler: _Extension_Action_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "extensions/extension.proto",
}
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment