broker

package
v0.0.0-...-20525f7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 27, 2025 License: MIT Imports: 15 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	BrokerService_Get_FullMethodName               = "/yandex.cloud.iot.broker.v1.BrokerService/Get"
	BrokerService_List_FullMethodName              = "/yandex.cloud.iot.broker.v1.BrokerService/List"
	BrokerService_Create_FullMethodName            = "/yandex.cloud.iot.broker.v1.BrokerService/Create"
	BrokerService_Update_FullMethodName            = "/yandex.cloud.iot.broker.v1.BrokerService/Update"
	BrokerService_Delete_FullMethodName            = "/yandex.cloud.iot.broker.v1.BrokerService/Delete"
	BrokerService_ListCertificates_FullMethodName  = "/yandex.cloud.iot.broker.v1.BrokerService/ListCertificates"
	BrokerService_AddCertificate_FullMethodName    = "/yandex.cloud.iot.broker.v1.BrokerService/AddCertificate"
	BrokerService_DeleteCertificate_FullMethodName = "/yandex.cloud.iot.broker.v1.BrokerService/DeleteCertificate"
	BrokerService_ListPasswords_FullMethodName     = "/yandex.cloud.iot.broker.v1.BrokerService/ListPasswords"
	BrokerService_AddPassword_FullMethodName       = "/yandex.cloud.iot.broker.v1.BrokerService/AddPassword"
	BrokerService_DeletePassword_FullMethodName    = "/yandex.cloud.iot.broker.v1.BrokerService/DeletePassword"
	BrokerService_ListOperations_FullMethodName    = "/yandex.cloud.iot.broker.v1.BrokerService/ListOperations"
)
View Source 
const (
	BrokerDataService_Publish_FullMethodName = "/yandex.cloud.iot.broker.v1.BrokerDataService/Publish"
)

Variables

View Source 
var (
	Broker_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
	}
	Broker_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"CREATING":           1,
		"ACTIVE":             2,
		"DELETING":           3,
	}
)

Enum value maps for Broker_Status.

View Source 
var BrokerDataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.iot.broker.v1.BrokerDataService",
	HandlerType: (*BrokerDataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _BrokerDataService_Publish_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/iot/broker/v1/broker_data_service.proto",
}

BrokerDataService_ServiceDesc is the grpc.ServiceDesc for BrokerDataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var BrokerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.iot.broker.v1.BrokerService",
	HandlerType: (*BrokerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _BrokerService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _BrokerService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _BrokerService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _BrokerService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _BrokerService_Delete_Handler,
		},
		{
			MethodName: "ListCertificates",
			Handler:    _BrokerService_ListCertificates_Handler,
		},
		{
			MethodName: "AddCertificate",
			Handler:    _BrokerService_AddCertificate_Handler,
		},
		{
			MethodName: "DeleteCertificate",
			Handler:    _BrokerService_DeleteCertificate_Handler,
		},
		{
			MethodName: "ListPasswords",
			Handler:    _BrokerService_ListPasswords_Handler,
		},
		{
			MethodName: "AddPassword",
			Handler:    _BrokerService_AddPassword_Handler,
		},
		{
			MethodName: "DeletePassword",
			Handler:    _BrokerService_DeletePassword_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _BrokerService_ListOperations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/iot/broker/v1/broker_service.proto",
}

BrokerService_ServiceDesc is the grpc.ServiceDesc for BrokerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_yandex_cloud_iot_broker_v1_broker_data_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_iot_broker_v1_broker_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_iot_broker_v1_broker_service_proto protoreflect.FileDescriptor

Functions

func RegisterBrokerDataServiceServer 

func RegisterBrokerDataServiceServer(s grpc.ServiceRegistrar, srv BrokerDataServiceServer)

func RegisterBrokerServiceServer 

func RegisterBrokerServiceServer(s grpc.ServiceRegistrar, srv BrokerServiceServer)

Types

type AddBrokerCertificateMetadata 

type AddBrokerCertificateMetadata struct {

	// ID of the broker certificate that is being added.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Fingerprint of the certificate that is being added.
	Fingerprint string `protobuf:"bytes,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBrokerCertificateMetadata) Descriptor deprecated 

func (*AddBrokerCertificateMetadata) Descriptor() ([]byte, []int)

Deprecated: Use AddBrokerCertificateMetadata.ProtoReflect.Descriptor instead.

func (*AddBrokerCertificateMetadata) GetBrokerId 

func (x *AddBrokerCertificateMetadata) GetBrokerId() string

func (*AddBrokerCertificateMetadata) GetFingerprint 

func (x *AddBrokerCertificateMetadata) GetFingerprint() string

func (*AddBrokerCertificateMetadata) ProtoMessage 

func (*AddBrokerCertificateMetadata) ProtoMessage()

func (*AddBrokerCertificateMetadata) ProtoReflect 

func (x *AddBrokerCertificateMetadata) ProtoReflect() protoreflect.Message

func (*AddBrokerCertificateMetadata) Reset 

func (x *AddBrokerCertificateMetadata) Reset()

func (*AddBrokerCertificateMetadata) SetBrokerId 

func (m *AddBrokerCertificateMetadata) SetBrokerId(v string)

func (*AddBrokerCertificateMetadata) SetFingerprint 

func (m *AddBrokerCertificateMetadata) SetFingerprint(v string)

func (*AddBrokerCertificateMetadata) String 

func (x *AddBrokerCertificateMetadata) String() string

type AddBrokerCertificateRequest 

type AddBrokerCertificateRequest struct {

	// ID of the broker for which the certificate is being added.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Public part of the certificate that is being added.
	CertificateData string `protobuf:"bytes,3,opt,name=certificate_data,json=certificateData,proto3" json:"certificate_data,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBrokerCertificateRequest) Descriptor deprecated 

func (*AddBrokerCertificateRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddBrokerCertificateRequest.ProtoReflect.Descriptor instead.

func (*AddBrokerCertificateRequest) GetBrokerId 

func (x *AddBrokerCertificateRequest) GetBrokerId() string

func (*AddBrokerCertificateRequest) GetCertificateData 

func (x *AddBrokerCertificateRequest) GetCertificateData() string

func (*AddBrokerCertificateRequest) ProtoMessage 

func (*AddBrokerCertificateRequest) ProtoMessage()

func (*AddBrokerCertificateRequest) ProtoReflect 

func (x *AddBrokerCertificateRequest) ProtoReflect() protoreflect.Message

func (*AddBrokerCertificateRequest) Reset 

func (x *AddBrokerCertificateRequest) Reset()

func (*AddBrokerCertificateRequest) SetBrokerId 

func (m *AddBrokerCertificateRequest) SetBrokerId(v string)

func (*AddBrokerCertificateRequest) SetCertificateData 

func (m *AddBrokerCertificateRequest) SetCertificateData(v string)

func (*AddBrokerCertificateRequest) String 

func (x *AddBrokerCertificateRequest) String() string

type AddBrokerPasswordMetadata 

type AddBrokerPasswordMetadata struct {

	// ID of the broker for which the password is being added.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// ID of a password that is being added.
	PasswordId string `protobuf:"bytes,2,opt,name=password_id,json=passwordId,proto3" json:"password_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBrokerPasswordMetadata) Descriptor deprecated 

func (*AddBrokerPasswordMetadata) Descriptor() ([]byte, []int)

Deprecated: Use AddBrokerPasswordMetadata.ProtoReflect.Descriptor instead.

func (*AddBrokerPasswordMetadata) GetBrokerId 

func (x *AddBrokerPasswordMetadata) GetBrokerId() string

func (*AddBrokerPasswordMetadata) GetPasswordId 

func (x *AddBrokerPasswordMetadata) GetPasswordId() string

func (*AddBrokerPasswordMetadata) ProtoMessage 

func (*AddBrokerPasswordMetadata) ProtoMessage()

func (*AddBrokerPasswordMetadata) ProtoReflect 

func (x *AddBrokerPasswordMetadata) ProtoReflect() protoreflect.Message

func (*AddBrokerPasswordMetadata) Reset 

func (x *AddBrokerPasswordMetadata) Reset()

func (*AddBrokerPasswordMetadata) SetBrokerId 

func (m *AddBrokerPasswordMetadata) SetBrokerId(v string)

func (*AddBrokerPasswordMetadata) SetPasswordId 

func (m *AddBrokerPasswordMetadata) SetPasswordId(v string)

func (*AddBrokerPasswordMetadata) String 

func (x *AddBrokerPasswordMetadata) String() string

type AddBrokerPasswordRequest 

type AddBrokerPasswordRequest struct {

	// ID of the broker to add a password for.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Passwords for the broker.
	//
	// The password must contain at least three character categories among the following: upper case latin, lower case latin, numbers and special symbols.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBrokerPasswordRequest) Descriptor deprecated 

func (*AddBrokerPasswordRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddBrokerPasswordRequest.ProtoReflect.Descriptor instead.

func (*AddBrokerPasswordRequest) GetBrokerId 

func (x *AddBrokerPasswordRequest) GetBrokerId() string

func (*AddBrokerPasswordRequest) GetPassword 

func (x *AddBrokerPasswordRequest) GetPassword() string

func (*AddBrokerPasswordRequest) ProtoMessage 

func (*AddBrokerPasswordRequest) ProtoMessage()

func (*AddBrokerPasswordRequest) ProtoReflect 

func (x *AddBrokerPasswordRequest) ProtoReflect() protoreflect.Message

func (*AddBrokerPasswordRequest) Reset 

func (x *AddBrokerPasswordRequest) Reset()

func (*AddBrokerPasswordRequest) SetBrokerId 

func (m *AddBrokerPasswordRequest) SetBrokerId(v string)

func (*AddBrokerPasswordRequest) SetPassword 

func (m *AddBrokerPasswordRequest) SetPassword(v string)

func (*AddBrokerPasswordRequest) String 

func (x *AddBrokerPasswordRequest) String() string

type Broker 

type Broker struct {

	// ID of the broker.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the folder that the broker belongs to.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the broker. The name is unique within the folder.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the broker. 0-256 characters long.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs. Maximum of 64 per resource.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Status of the broker.
	Status Broker_Status `protobuf:"varint,7,opt,name=status,proto3,enum=yandex.cloud.iot.broker.v1.Broker_Status" json:"status,omitempty"`
	// Options for logging broker events
	LogOptions *LogOptions `protobuf:"bytes,8,opt,name=log_options,json=logOptions,proto3" json:"log_options,omitempty"`
	// contains filtered or unexported fields
}

A broker.

func (*Broker) Descriptor deprecated 

func (*Broker) Descriptor() ([]byte, []int)

Deprecated: Use Broker.ProtoReflect.Descriptor instead.

func (*Broker) GetCreatedAt 

func (x *Broker) GetCreatedAt() *timestamppb.Timestamp

func (*Broker) GetDescription 

func (x *Broker) GetDescription() string

func (*Broker) GetFolderId 

func (x *Broker) GetFolderId() string

func (*Broker) GetId 

func (x *Broker) GetId() string

func (*Broker) GetLabels 

func (x *Broker) GetLabels() map[string]string

func (*Broker) GetLogOptions 

func (x *Broker) GetLogOptions() *LogOptions

func (*Broker) GetName 

func (x *Broker) GetName() string

func (*Broker) GetStatus 

func (x *Broker) GetStatus() Broker_Status

func (*Broker) ProtoMessage 

func (*Broker) ProtoMessage()

func (*Broker) ProtoReflect 

func (x *Broker) ProtoReflect() protoreflect.Message

func (*Broker) Reset 

func (x *Broker) Reset()

func (*Broker) SetCreatedAt 

func (m *Broker) SetCreatedAt(v *timestamppb.Timestamp)

func (*Broker) SetDescription 

func (m *Broker) SetDescription(v string)

func (*Broker) SetFolderId 

func (m *Broker) SetFolderId(v string)

func (*Broker) SetId 

func (m *Broker) SetId(v string)

func (*Broker) SetLabels 

func (m *Broker) SetLabels(v map[string]string)

func (*Broker) SetLogOptions 

func (m *Broker) SetLogOptions(v *LogOptions)

func (*Broker) SetName 

func (m *Broker) SetName(v string)

func (*Broker) SetStatus 

func (m *Broker) SetStatus(v Broker_Status)

func (*Broker) String 

func (x *Broker) String() string

type BrokerCertificate 

type BrokerCertificate struct {

	// ID of the broker that the certificate belongs to.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// SHA256 hash of the certificates.
	Fingerprint string `protobuf:"bytes,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// Public part of the certificate.
	CertificateData string `protobuf:"bytes,3,opt,name=certificate_data,json=certificateData,proto3" json:"certificate_data,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

A broker certificate.

func (*BrokerCertificate) Descriptor deprecated 

func (*BrokerCertificate) Descriptor() ([]byte, []int)

Deprecated: Use BrokerCertificate.ProtoReflect.Descriptor instead.

func (*BrokerCertificate) GetBrokerId 

func (x *BrokerCertificate) GetBrokerId() string

func (*BrokerCertificate) GetCertificateData 

func (x *BrokerCertificate) GetCertificateData() string

func (*BrokerCertificate) GetCreatedAt 

func (x *BrokerCertificate) GetCreatedAt() *timestamppb.Timestamp

func (*BrokerCertificate) GetFingerprint 

func (x *BrokerCertificate) GetFingerprint() string

func (*BrokerCertificate) ProtoMessage 

func (*BrokerCertificate) ProtoMessage()

func (*BrokerCertificate) ProtoReflect 

func (x *BrokerCertificate) ProtoReflect() protoreflect.Message

func (*BrokerCertificate) Reset 

func (x *BrokerCertificate) Reset()

func (*BrokerCertificate) SetBrokerId 

func (m *BrokerCertificate) SetBrokerId(v string)

func (*BrokerCertificate) SetCertificateData 

func (m *BrokerCertificate) SetCertificateData(v string)

func (*BrokerCertificate) SetCreatedAt 

func (m *BrokerCertificate) SetCreatedAt(v *timestamppb.Timestamp)

func (*BrokerCertificate) SetFingerprint 

func (m *BrokerCertificate) SetFingerprint(v string)

func (*BrokerCertificate) String 

func (x *BrokerCertificate) String() string

type BrokerDataServiceClient 

type BrokerDataServiceClient interface {
	// Publishes message on behalf of specified broker
	Publish(ctx context.Context, in *PublishBrokerDataRequest, opts ...grpc.CallOption) (*PublishBrokerDataResponse, error)
}

BrokerDataServiceClient is the client API for BrokerDataService 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.

A set of methods to work with IoT Core messages on behalf of broker

func NewBrokerDataServiceClient 

func NewBrokerDataServiceClient(cc grpc.ClientConnInterface) BrokerDataServiceClient

type BrokerDataServiceServer 

type BrokerDataServiceServer interface {
	// Publishes message on behalf of specified broker
	Publish(context.Context, *PublishBrokerDataRequest) (*PublishBrokerDataResponse, error)
}

BrokerDataServiceServer is the server API for BrokerDataService service. All implementations should embed UnimplementedBrokerDataServiceServer for forward compatibility.

A set of methods to work with IoT Core messages on behalf of broker

type BrokerPassword 

type BrokerPassword struct {

	// ID of the broker that the password belongs to.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// ID of the password.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

A broker password.

func (*BrokerPassword) Descriptor deprecated 

func (*BrokerPassword) Descriptor() ([]byte, []int)

Deprecated: Use BrokerPassword.ProtoReflect.Descriptor instead.

func (*BrokerPassword) GetBrokerId 

func (x *BrokerPassword) GetBrokerId() string

func (*BrokerPassword) GetCreatedAt 

func (x *BrokerPassword) GetCreatedAt() *timestamppb.Timestamp

func (*BrokerPassword) GetId 

func (x *BrokerPassword) GetId() string

func (*BrokerPassword) ProtoMessage 

func (*BrokerPassword) ProtoMessage()

func (*BrokerPassword) ProtoReflect 

func (x *BrokerPassword) ProtoReflect() protoreflect.Message

func (*BrokerPassword) Reset 

func (x *BrokerPassword) Reset()

func (*BrokerPassword) SetBrokerId 

func (m *BrokerPassword) SetBrokerId(v string)

func (*BrokerPassword) SetCreatedAt 

func (m *BrokerPassword) SetCreatedAt(v *timestamppb.Timestamp)

func (*BrokerPassword) SetId 

func (m *BrokerPassword) SetId(v string)

func (*BrokerPassword) String 

func (x *BrokerPassword) String() string

type BrokerServiceClient 

type BrokerServiceClient interface {
	// Returns the specified broker.
	//
	// To get the list of available brokers, make a [List] request.
	Get(ctx context.Context, in *GetBrokerRequest, opts ...grpc.CallOption) (*Broker, error)
	// Retrieves the list of brokers in the specified folder.
	List(ctx context.Context, in *ListBrokersRequest, opts ...grpc.CallOption) (*ListBrokersResponse, error)
	// Creates a broker in the specified folder.
	Create(ctx context.Context, in *CreateBrokerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified broker.
	Update(ctx context.Context, in *UpdateBrokerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified broker.
	Delete(ctx context.Context, in *DeleteBrokerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Retrieves the list of broker certificates for the specified broker.
	ListCertificates(ctx context.Context, in *ListBrokerCertificatesRequest, opts ...grpc.CallOption) (*ListBrokerCertificatesResponse, error)
	// Adds a certificate.
	AddCertificate(ctx context.Context, in *AddBrokerCertificateRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified broker certificate.
	DeleteCertificate(ctx context.Context, in *DeleteBrokerCertificateRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Retrieves the list of passwords for the specified broker.
	ListPasswords(ctx context.Context, in *ListBrokerPasswordsRequest, opts ...grpc.CallOption) (*ListBrokerPasswordsResponse, error)
	// Adds password for the specified broker.
	AddPassword(ctx context.Context, in *AddBrokerPasswordRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified password.
	DeletePassword(ctx context.Context, in *DeleteBrokerPasswordRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified broker.
	ListOperations(ctx context.Context, in *ListBrokerOperationsRequest, opts ...grpc.CallOption) (*ListBrokerOperationsResponse, error)
}

BrokerServiceClient is the client API for BrokerService 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.

A set of methods for managing broker.

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc grpc.ClientConnInterface) BrokerServiceClient

type BrokerServiceServer 

type BrokerServiceServer interface {
	// Returns the specified broker.
	//
	// To get the list of available brokers, make a [List] request.
	Get(context.Context, *GetBrokerRequest) (*Broker, error)
	// Retrieves the list of brokers in the specified folder.
	List(context.Context, *ListBrokersRequest) (*ListBrokersResponse, error)
	// Creates a broker in the specified folder.
	Create(context.Context, *CreateBrokerRequest) (*operation.Operation, error)
	// Updates the specified broker.
	Update(context.Context, *UpdateBrokerRequest) (*operation.Operation, error)
	// Deletes the specified broker.
	Delete(context.Context, *DeleteBrokerRequest) (*operation.Operation, error)
	// Retrieves the list of broker certificates for the specified broker.
	ListCertificates(context.Context, *ListBrokerCertificatesRequest) (*ListBrokerCertificatesResponse, error)
	// Adds a certificate.
	AddCertificate(context.Context, *AddBrokerCertificateRequest) (*operation.Operation, error)
	// Deletes the specified broker certificate.
	DeleteCertificate(context.Context, *DeleteBrokerCertificateRequest) (*operation.Operation, error)
	// Retrieves the list of passwords for the specified broker.
	ListPasswords(context.Context, *ListBrokerPasswordsRequest) (*ListBrokerPasswordsResponse, error)
	// Adds password for the specified broker.
	AddPassword(context.Context, *AddBrokerPasswordRequest) (*operation.Operation, error)
	// Deletes the specified password.
	DeletePassword(context.Context, *DeleteBrokerPasswordRequest) (*operation.Operation, error)
	// Lists operations for the specified broker.
	ListOperations(context.Context, *ListBrokerOperationsRequest) (*ListBrokerOperationsResponse, error)
}

BrokerServiceServer is the server API for BrokerService service. All implementations should embed UnimplementedBrokerServiceServer for forward compatibility.

A set of methods for managing broker.

type Broker_Status 

type Broker_Status int32
const (
	Broker_STATUS_UNSPECIFIED Broker_Status = 0
	// Broker is being created.
	Broker_CREATING Broker_Status = 1
	// Broker is ready to use.
	Broker_ACTIVE Broker_Status = 2
	// Broker is being deleted.
	Broker_DELETING Broker_Status = 3
)

func (Broker_Status) Descriptor 

func (Broker_Status) Descriptor() protoreflect.EnumDescriptor

func (Broker_Status) Enum 

func (x Broker_Status) Enum() *Broker_Status

func (Broker_Status) EnumDescriptor deprecated 

func (Broker_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Broker_Status.Descriptor instead.

func (Broker_Status) Number 

func (x Broker_Status) Number() protoreflect.EnumNumber

func (Broker_Status) String 

func (x Broker_Status) String() string

func (Broker_Status) Type 

func (Broker_Status) Type() protoreflect.EnumType

type CreateBrokerMetadata 

type CreateBrokerMetadata struct {

	// ID of the broker that is being created.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBrokerMetadata) Descriptor deprecated 

func (*CreateBrokerMetadata) Descriptor() ([]byte, []int)

Deprecated: Use CreateBrokerMetadata.ProtoReflect.Descriptor instead.

func (*CreateBrokerMetadata) GetBrokerId 

func (x *CreateBrokerMetadata) GetBrokerId() string

func (*CreateBrokerMetadata) ProtoMessage 

func (*CreateBrokerMetadata) ProtoMessage()

func (*CreateBrokerMetadata) ProtoReflect 

func (x *CreateBrokerMetadata) ProtoReflect() protoreflect.Message

func (*CreateBrokerMetadata) Reset 

func (x *CreateBrokerMetadata) Reset()

func (*CreateBrokerMetadata) SetBrokerId 

func (m *CreateBrokerMetadata) SetBrokerId(v string)

func (*CreateBrokerMetadata) String 

func (x *CreateBrokerMetadata) String() string

type CreateBrokerRequest 

type CreateBrokerRequest struct {

	// ID of the folder to create a broker in.
	//
	// To get a folder ID, make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the broker. The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the broker.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Broker certificates.
	Certificates []*CreateBrokerRequest_Certificate `protobuf:"bytes,5,rep,name=certificates,proto3" json:"certificates,omitempty"`
	// Broker passwords.
	//
	// The password must contain at least three character categories among the following: upper case latin, lower case latin, numbers and special symbols.
	Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	// Options for logging broker events
	LogOptions *LogOptions `protobuf:"bytes,7,opt,name=log_options,json=logOptions,proto3" json:"log_options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBrokerRequest) Descriptor deprecated 

func (*CreateBrokerRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateBrokerRequest.ProtoReflect.Descriptor instead.

func (*CreateBrokerRequest) GetCertificates 

func (x *CreateBrokerRequest) GetCertificates() []*CreateBrokerRequest_Certificate

func (*CreateBrokerRequest) GetDescription 

func (x *CreateBrokerRequest) GetDescription() string

func (*CreateBrokerRequest) GetFolderId 

func (x *CreateBrokerRequest) GetFolderId() string

func (*CreateBrokerRequest) GetLabels 

func (x *CreateBrokerRequest) GetLabels() map[string]string

func (*CreateBrokerRequest) GetLogOptions 

func (x *CreateBrokerRequest) GetLogOptions() *LogOptions

func (*CreateBrokerRequest) GetName 

func (x *CreateBrokerRequest) GetName() string

func (*CreateBrokerRequest) GetPassword 

func (x *CreateBrokerRequest) GetPassword() string

func (*CreateBrokerRequest) ProtoMessage 

func (*CreateBrokerRequest) ProtoMessage()

func (*CreateBrokerRequest) ProtoReflect 

func (x *CreateBrokerRequest) ProtoReflect() protoreflect.Message

func (*CreateBrokerRequest) Reset 

func (x *CreateBrokerRequest) Reset()

func (*CreateBrokerRequest) SetCertificates 

func (m *CreateBrokerRequest) SetCertificates(v []*CreateBrokerRequest_Certificate)

func (*CreateBrokerRequest) SetDescription 

func (m *CreateBrokerRequest) SetDescription(v string)

func (*CreateBrokerRequest) SetFolderId 

func (m *CreateBrokerRequest) SetFolderId(v string)

func (*CreateBrokerRequest) SetLabels 

func (m *CreateBrokerRequest) SetLabels(v map[string]string)

func (*CreateBrokerRequest) SetLogOptions 

func (m *CreateBrokerRequest) SetLogOptions(v *LogOptions)

func (*CreateBrokerRequest) SetName 

func (m *CreateBrokerRequest) SetName(v string)

func (*CreateBrokerRequest) SetPassword 

func (m *CreateBrokerRequest) SetPassword(v string)

func (*CreateBrokerRequest) String 

func (x *CreateBrokerRequest) String() string

type CreateBrokerRequest_Certificate 

type CreateBrokerRequest_Certificate struct {

	// Public part of the broker certificate.
	CertificateData string `protobuf:"bytes,1,opt,name=certificate_data,json=certificateData,proto3" json:"certificate_data,omitempty"`
	// contains filtered or unexported fields
}

Specification of a broker certificate.

func (*CreateBrokerRequest_Certificate) Descriptor deprecated 

func (*CreateBrokerRequest_Certificate) Descriptor() ([]byte, []int)

Deprecated: Use CreateBrokerRequest_Certificate.ProtoReflect.Descriptor instead.

func (*CreateBrokerRequest_Certificate) GetCertificateData 

func (x *CreateBrokerRequest_Certificate) GetCertificateData() string

func (*CreateBrokerRequest_Certificate) ProtoMessage 

func (*CreateBrokerRequest_Certificate) ProtoMessage()

func (*CreateBrokerRequest_Certificate) ProtoReflect 

func (x *CreateBrokerRequest_Certificate) ProtoReflect() protoreflect.Message

func (*CreateBrokerRequest_Certificate) Reset 

func (x *CreateBrokerRequest_Certificate) Reset()

func (*CreateBrokerRequest_Certificate) SetCertificateData 

func (m *CreateBrokerRequest_Certificate) SetCertificateData(v string)

func (*CreateBrokerRequest_Certificate) String 

func (x *CreateBrokerRequest_Certificate) String() string

type DeleteBrokerCertificateMetadata 

type DeleteBrokerCertificateMetadata struct {

	// ID of a broker for which the certificate is being delete.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Fingerprint of the certificate to deleted.
	Fingerprint string `protobuf:"bytes,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBrokerCertificateMetadata) Descriptor deprecated 

func (*DeleteBrokerCertificateMetadata) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBrokerCertificateMetadata.ProtoReflect.Descriptor instead.

func (*DeleteBrokerCertificateMetadata) GetBrokerId 

func (x *DeleteBrokerCertificateMetadata) GetBrokerId() string

func (*DeleteBrokerCertificateMetadata) GetFingerprint 

func (x *DeleteBrokerCertificateMetadata) GetFingerprint() string

func (*DeleteBrokerCertificateMetadata) ProtoMessage 

func (*DeleteBrokerCertificateMetadata) ProtoMessage()

func (*DeleteBrokerCertificateMetadata) ProtoReflect 

func (x *DeleteBrokerCertificateMetadata) ProtoReflect() protoreflect.Message

func (*DeleteBrokerCertificateMetadata) Reset 

func (x *DeleteBrokerCertificateMetadata) Reset()

func (*DeleteBrokerCertificateMetadata) SetBrokerId 

func (m *DeleteBrokerCertificateMetadata) SetBrokerId(v string)

func (*DeleteBrokerCertificateMetadata) SetFingerprint 

func (m *DeleteBrokerCertificateMetadata) SetFingerprint(v string)

func (*DeleteBrokerCertificateMetadata) String 

func (x *DeleteBrokerCertificateMetadata) String() string

type DeleteBrokerCertificateRequest 

type DeleteBrokerCertificateRequest struct {

	// ID of the broker to delete a certificate for.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Fingerprint of the certificate that is being deleted.
	Fingerprint string `protobuf:"bytes,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBrokerCertificateRequest) Descriptor deprecated 

func (*DeleteBrokerCertificateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBrokerCertificateRequest.ProtoReflect.Descriptor instead.

func (*DeleteBrokerCertificateRequest) GetBrokerId 

func (x *DeleteBrokerCertificateRequest) GetBrokerId() string

func (*DeleteBrokerCertificateRequest) GetFingerprint 

func (x *DeleteBrokerCertificateRequest) GetFingerprint() string

func (*DeleteBrokerCertificateRequest) ProtoMessage 

func (*DeleteBrokerCertificateRequest) ProtoMessage()

func (*DeleteBrokerCertificateRequest) ProtoReflect 

func (x *DeleteBrokerCertificateRequest) ProtoReflect() protoreflect.Message

func (*DeleteBrokerCertificateRequest) Reset 

func (x *DeleteBrokerCertificateRequest) Reset()

func (*DeleteBrokerCertificateRequest) SetBrokerId 

func (m *DeleteBrokerCertificateRequest) SetBrokerId(v string)

func (*DeleteBrokerCertificateRequest) SetFingerprint 

func (m *DeleteBrokerCertificateRequest) SetFingerprint(v string)

func (*DeleteBrokerCertificateRequest) String 

func (x *DeleteBrokerCertificateRequest) String() string

type DeleteBrokerMetadata 

type DeleteBrokerMetadata struct {

	// ID of the broker that is being deleted.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBrokerMetadata) Descriptor deprecated 

func (*DeleteBrokerMetadata) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBrokerMetadata.ProtoReflect.Descriptor instead.

func (*DeleteBrokerMetadata) GetBrokerId 

func (x *DeleteBrokerMetadata) GetBrokerId() string

func (*DeleteBrokerMetadata) ProtoMessage 

func (*DeleteBrokerMetadata) ProtoMessage()

func (*DeleteBrokerMetadata) ProtoReflect 

func (x *DeleteBrokerMetadata) ProtoReflect() protoreflect.Message

func (*DeleteBrokerMetadata) Reset 

func (x *DeleteBrokerMetadata) Reset()

func (*DeleteBrokerMetadata) SetBrokerId 

func (m *DeleteBrokerMetadata) SetBrokerId(v string)

func (*DeleteBrokerMetadata) String 

func (x *DeleteBrokerMetadata) String() string

type DeleteBrokerPasswordMetadata 

type DeleteBrokerPasswordMetadata struct {

	// ID of a broker for which the password is being delete.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// ID of the password to delete.
	//
	// To get a password ID make a [BrokerService.ListPasswords] request.
	PasswordId string `protobuf:"bytes,2,opt,name=password_id,json=passwordId,proto3" json:"password_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBrokerPasswordMetadata) Descriptor deprecated 

func (*DeleteBrokerPasswordMetadata) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBrokerPasswordMetadata.ProtoReflect.Descriptor instead.

func (*DeleteBrokerPasswordMetadata) GetBrokerId 

func (x *DeleteBrokerPasswordMetadata) GetBrokerId() string

func (*DeleteBrokerPasswordMetadata) GetPasswordId 

func (x *DeleteBrokerPasswordMetadata) GetPasswordId() string

func (*DeleteBrokerPasswordMetadata) ProtoMessage 

func (*DeleteBrokerPasswordMetadata) ProtoMessage()

func (*DeleteBrokerPasswordMetadata) ProtoReflect 

func (x *DeleteBrokerPasswordMetadata) ProtoReflect() protoreflect.Message

func (*DeleteBrokerPasswordMetadata) Reset 

func (x *DeleteBrokerPasswordMetadata) Reset()

func (*DeleteBrokerPasswordMetadata) SetBrokerId 

func (m *DeleteBrokerPasswordMetadata) SetBrokerId(v string)

func (*DeleteBrokerPasswordMetadata) SetPasswordId 

func (m *DeleteBrokerPasswordMetadata) SetPasswordId(v string)

func (*DeleteBrokerPasswordMetadata) String 

func (x *DeleteBrokerPasswordMetadata) String() string

type DeleteBrokerPasswordRequest 

type DeleteBrokerPasswordRequest struct {

	// ID of the broker to delete a password for.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// ID of the password to delete.
	//
	// To get a password ID make a [BrokerService.ListPasswords] request.
	PasswordId string `protobuf:"bytes,2,opt,name=password_id,json=passwordId,proto3" json:"password_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBrokerPasswordRequest) Descriptor deprecated 

func (*DeleteBrokerPasswordRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBrokerPasswordRequest.ProtoReflect.Descriptor instead.

func (*DeleteBrokerPasswordRequest) GetBrokerId 

func (x *DeleteBrokerPasswordRequest) GetBrokerId() string

func (*DeleteBrokerPasswordRequest) GetPasswordId 

func (x *DeleteBrokerPasswordRequest) GetPasswordId() string

func (*DeleteBrokerPasswordRequest) ProtoMessage 

func (*DeleteBrokerPasswordRequest) ProtoMessage()

func (*DeleteBrokerPasswordRequest) ProtoReflect 

func (x *DeleteBrokerPasswordRequest) ProtoReflect() protoreflect.Message

func (*DeleteBrokerPasswordRequest) Reset 

func (x *DeleteBrokerPasswordRequest) Reset()

func (*DeleteBrokerPasswordRequest) SetBrokerId 

func (m *DeleteBrokerPasswordRequest) SetBrokerId(v string)

func (*DeleteBrokerPasswordRequest) SetPasswordId 

func (m *DeleteBrokerPasswordRequest) SetPasswordId(v string)

func (*DeleteBrokerPasswordRequest) String 

func (x *DeleteBrokerPasswordRequest) String() string

type DeleteBrokerRequest 

type DeleteBrokerRequest struct {

	// ID of the broker to delete.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBrokerRequest) Descriptor deprecated 

func (*DeleteBrokerRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBrokerRequest.ProtoReflect.Descriptor instead.

func (*DeleteBrokerRequest) GetBrokerId 

func (x *DeleteBrokerRequest) GetBrokerId() string

func (*DeleteBrokerRequest) ProtoMessage 

func (*DeleteBrokerRequest) ProtoMessage()

func (*DeleteBrokerRequest) ProtoReflect 

func (x *DeleteBrokerRequest) ProtoReflect() protoreflect.Message

func (*DeleteBrokerRequest) Reset 

func (x *DeleteBrokerRequest) Reset()

func (*DeleteBrokerRequest) SetBrokerId 

func (m *DeleteBrokerRequest) SetBrokerId(v string)

func (*DeleteBrokerRequest) String 

func (x *DeleteBrokerRequest) String() string

type GetBrokerRequest 

type GetBrokerRequest struct {

	// ID of the broker to return.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBrokerRequest) Descriptor deprecated 

func (*GetBrokerRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetBrokerRequest.ProtoReflect.Descriptor instead.

func (*GetBrokerRequest) GetBrokerId 

func (x *GetBrokerRequest) GetBrokerId() string

func (*GetBrokerRequest) ProtoMessage 

func (*GetBrokerRequest) ProtoMessage()

func (*GetBrokerRequest) ProtoReflect 

func (x *GetBrokerRequest) ProtoReflect() protoreflect.Message

func (*GetBrokerRequest) Reset 

func (x *GetBrokerRequest) Reset()

func (*GetBrokerRequest) SetBrokerId 

func (m *GetBrokerRequest) SetBrokerId(v string)

func (*GetBrokerRequest) String 

func (x *GetBrokerRequest) String() string

type ListBrokerCertificatesRequest 

type ListBrokerCertificatesRequest struct {

	// ID of the broker to list certificates for.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokerCertificatesRequest) Descriptor deprecated 

func (*ListBrokerCertificatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokerCertificatesRequest.ProtoReflect.Descriptor instead.

func (*ListBrokerCertificatesRequest) GetBrokerId 

func (x *ListBrokerCertificatesRequest) GetBrokerId() string

func (*ListBrokerCertificatesRequest) ProtoMessage 

func (*ListBrokerCertificatesRequest) ProtoMessage()

func (*ListBrokerCertificatesRequest) ProtoReflect 

func (x *ListBrokerCertificatesRequest) ProtoReflect() protoreflect.Message

func (*ListBrokerCertificatesRequest) Reset 

func (x *ListBrokerCertificatesRequest) Reset()

func (*ListBrokerCertificatesRequest) SetBrokerId 

func (m *ListBrokerCertificatesRequest) SetBrokerId(v string)

func (*ListBrokerCertificatesRequest) String 

func (x *ListBrokerCertificatesRequest) String() string

type ListBrokerCertificatesResponse 

type ListBrokerCertificatesResponse struct {

	// List of certificates for the specified broker.
	Certificates []*BrokerCertificate `protobuf:"bytes,1,rep,name=certificates,proto3" json:"certificates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokerCertificatesResponse) Descriptor deprecated 

func (*ListBrokerCertificatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokerCertificatesResponse.ProtoReflect.Descriptor instead.

func (*ListBrokerCertificatesResponse) GetCertificates 

func (x *ListBrokerCertificatesResponse) GetCertificates() []*BrokerCertificate

func (*ListBrokerCertificatesResponse) ProtoMessage 

func (*ListBrokerCertificatesResponse) ProtoMessage()

func (*ListBrokerCertificatesResponse) ProtoReflect 

func (x *ListBrokerCertificatesResponse) ProtoReflect() protoreflect.Message

func (*ListBrokerCertificatesResponse) Reset 

func (x *ListBrokerCertificatesResponse) Reset()

func (*ListBrokerCertificatesResponse) SetCertificates 

func (m *ListBrokerCertificatesResponse) SetCertificates(v []*BrokerCertificate)

func (*ListBrokerCertificatesResponse) String 

func (x *ListBrokerCertificatesResponse) String() string

type ListBrokerOperationsRequest 

type ListBrokerOperationsRequest struct {

	// ID of the broker to list operations for.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// The maximum number of results per page that should be returned. If the number of available
	// results is larger than `page_size`, the service returns a [ListBrokerOperationsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListBrokerOperationsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	// Currently you can use filtering only on [Broker.name] field.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokerOperationsRequest) Descriptor deprecated 

func (*ListBrokerOperationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokerOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListBrokerOperationsRequest) GetBrokerId 

func (x *ListBrokerOperationsRequest) GetBrokerId() string

func (*ListBrokerOperationsRequest) GetFilter 

func (x *ListBrokerOperationsRequest) GetFilter() string

func (*ListBrokerOperationsRequest) GetPageSize 

func (x *ListBrokerOperationsRequest) GetPageSize() int64

func (*ListBrokerOperationsRequest) GetPageToken 

func (x *ListBrokerOperationsRequest) GetPageToken() string

func (*ListBrokerOperationsRequest) ProtoMessage 

func (*ListBrokerOperationsRequest) ProtoMessage()

func (*ListBrokerOperationsRequest) ProtoReflect 

func (x *ListBrokerOperationsRequest) ProtoReflect() protoreflect.Message

func (*ListBrokerOperationsRequest) Reset 

func (x *ListBrokerOperationsRequest) Reset()

func (*ListBrokerOperationsRequest) SetBrokerId 

func (m *ListBrokerOperationsRequest) SetBrokerId(v string)

func (*ListBrokerOperationsRequest) SetFilter 

func (m *ListBrokerOperationsRequest) SetFilter(v string)

func (*ListBrokerOperationsRequest) SetPageSize 

func (m *ListBrokerOperationsRequest) SetPageSize(v int64)

func (*ListBrokerOperationsRequest) SetPageToken 

func (m *ListBrokerOperationsRequest) SetPageToken(v string)

func (*ListBrokerOperationsRequest) String 

func (x *ListBrokerOperationsRequest) String() string

type ListBrokerOperationsResponse 

type ListBrokerOperationsResponse struct {

	// List of operations for the specified broker.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListBrokerOperationsRequest.page_size], use `next_page_token` as the value
	// for the [ListBrokerOperationsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokerOperationsResponse) Descriptor deprecated 

func (*ListBrokerOperationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokerOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListBrokerOperationsResponse) GetNextPageToken 

func (x *ListBrokerOperationsResponse) GetNextPageToken() string

func (*ListBrokerOperationsResponse) GetOperations 

func (x *ListBrokerOperationsResponse) GetOperations() []*operation.Operation

func (*ListBrokerOperationsResponse) ProtoMessage 

func (*ListBrokerOperationsResponse) ProtoMessage()

func (*ListBrokerOperationsResponse) ProtoReflect 

func (x *ListBrokerOperationsResponse) ProtoReflect() protoreflect.Message

func (*ListBrokerOperationsResponse) Reset 

func (x *ListBrokerOperationsResponse) Reset()

func (*ListBrokerOperationsResponse) SetNextPageToken 

func (m *ListBrokerOperationsResponse) SetNextPageToken(v string)

func (*ListBrokerOperationsResponse) SetOperations 

func (m *ListBrokerOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListBrokerOperationsResponse) String 

func (x *ListBrokerOperationsResponse) String() string

type ListBrokerPasswordsRequest 

type ListBrokerPasswordsRequest struct {

	// ID of the broker to list passwords in.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokerPasswordsRequest) Descriptor deprecated 

func (*ListBrokerPasswordsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokerPasswordsRequest.ProtoReflect.Descriptor instead.

func (*ListBrokerPasswordsRequest) GetBrokerId 

func (x *ListBrokerPasswordsRequest) GetBrokerId() string

func (*ListBrokerPasswordsRequest) ProtoMessage 

func (*ListBrokerPasswordsRequest) ProtoMessage()

func (*ListBrokerPasswordsRequest) ProtoReflect 

func (x *ListBrokerPasswordsRequest) ProtoReflect() protoreflect.Message

func (*ListBrokerPasswordsRequest) Reset 

func (x *ListBrokerPasswordsRequest) Reset()

func (*ListBrokerPasswordsRequest) SetBrokerId 

func (m *ListBrokerPasswordsRequest) SetBrokerId(v string)

func (*ListBrokerPasswordsRequest) String 

func (x *ListBrokerPasswordsRequest) String() string

type ListBrokerPasswordsResponse 

type ListBrokerPasswordsResponse struct {

	// List of passwords for the specified broker.
	Passwords []*BrokerPassword `protobuf:"bytes,1,rep,name=passwords,proto3" json:"passwords,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokerPasswordsResponse) Descriptor deprecated 

func (*ListBrokerPasswordsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokerPasswordsResponse.ProtoReflect.Descriptor instead.

func (*ListBrokerPasswordsResponse) GetPasswords 

func (x *ListBrokerPasswordsResponse) GetPasswords() []*BrokerPassword

func (*ListBrokerPasswordsResponse) ProtoMessage 

func (*ListBrokerPasswordsResponse) ProtoMessage()

func (*ListBrokerPasswordsResponse) ProtoReflect 

func (x *ListBrokerPasswordsResponse) ProtoReflect() protoreflect.Message

func (*ListBrokerPasswordsResponse) Reset 

func (x *ListBrokerPasswordsResponse) Reset()

func (*ListBrokerPasswordsResponse) SetPasswords 

func (m *ListBrokerPasswordsResponse) SetPasswords(v []*BrokerPassword)

func (*ListBrokerPasswordsResponse) String 

func (x *ListBrokerPasswordsResponse) String() string

type ListBrokersRequest 

type ListBrokersRequest struct {

	// ID of the folder to list brokers in.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page that should be returned. If the number of available
	// results is larger than `page_size`, the service returns a [ListBrokersResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListBrokersResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokersRequest) Descriptor deprecated 

func (*ListBrokersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokersRequest.ProtoReflect.Descriptor instead.

func (*ListBrokersRequest) GetFolderId 

func (x *ListBrokersRequest) GetFolderId() string

func (*ListBrokersRequest) GetPageSize 

func (x *ListBrokersRequest) GetPageSize() int64

func (*ListBrokersRequest) GetPageToken 

func (x *ListBrokersRequest) GetPageToken() string

func (*ListBrokersRequest) ProtoMessage 

func (*ListBrokersRequest) ProtoMessage()

func (*ListBrokersRequest) ProtoReflect 

func (x *ListBrokersRequest) ProtoReflect() protoreflect.Message

func (*ListBrokersRequest) Reset 

func (x *ListBrokersRequest) Reset()

func (*ListBrokersRequest) SetFolderId 

func (m *ListBrokersRequest) SetFolderId(v string)

func (*ListBrokersRequest) SetPageSize 

func (m *ListBrokersRequest) SetPageSize(v int64)

func (*ListBrokersRequest) SetPageToken 

func (m *ListBrokersRequest) SetPageToken(v string)

func (*ListBrokersRequest) String 

func (x *ListBrokersRequest) String() string

type ListBrokersResponse 

type ListBrokersResponse struct {

	// List of brokers.
	Brokers []*Broker `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListBrokersRequest.page_size], use `next_page_token` as the value
	// for the [ListBrokersRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBrokersResponse) Descriptor deprecated 

func (*ListBrokersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListBrokersResponse.ProtoReflect.Descriptor instead.

func (*ListBrokersResponse) GetBrokers 

func (x *ListBrokersResponse) GetBrokers() []*Broker

func (*ListBrokersResponse) GetNextPageToken 

func (x *ListBrokersResponse) GetNextPageToken() string

func (*ListBrokersResponse) ProtoMessage 

func (*ListBrokersResponse) ProtoMessage()

func (*ListBrokersResponse) ProtoReflect 

func (x *ListBrokersResponse) ProtoReflect() protoreflect.Message

func (*ListBrokersResponse) Reset 

func (x *ListBrokersResponse) Reset()

func (*ListBrokersResponse) SetBrokers 

func (m *ListBrokersResponse) SetBrokers(v []*Broker)

func (*ListBrokersResponse) SetNextPageToken 

func (m *ListBrokersResponse) SetNextPageToken(v string)

func (*ListBrokersResponse) String 

func (x *ListBrokersResponse) String() string

type LogOptions 

type LogOptions struct {

	// Is logging from broker disabled.
	Disabled bool `protobuf:"varint,1,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// Log entries destination.
	//
	// Types that are assignable to Destination:
	//
	//	*LogOptions_LogGroupId
	//	*LogOptions_FolderId
	Destination isLogOptions_Destination `protobuf_oneof:"destination"`
	// Minimum log entry level.
	//
	// See [LogLevel.Level] for details.
	MinLevel v1.LogLevel_Level `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogOptions) Descriptor deprecated 

func (*LogOptions) Descriptor() ([]byte, []int)

Deprecated: Use LogOptions.ProtoReflect.Descriptor instead.

func (*LogOptions) GetDestination 

func (m *LogOptions) GetDestination() isLogOptions_Destination

func (*LogOptions) GetDisabled 

func (x *LogOptions) GetDisabled() bool

func (*LogOptions) GetFolderId 

func (x *LogOptions) GetFolderId() string

func (*LogOptions) GetLogGroupId 

func (x *LogOptions) GetLogGroupId() string

func (*LogOptions) GetMinLevel 

func (x *LogOptions) GetMinLevel() v1.LogLevel_Level

func (*LogOptions) ProtoMessage 

func (*LogOptions) ProtoMessage()

func (*LogOptions) ProtoReflect 

func (x *LogOptions) ProtoReflect() protoreflect.Message

func (*LogOptions) Reset 

func (x *LogOptions) Reset()

func (*LogOptions) SetDestination 

func (m *LogOptions) SetDestination(v LogOptions_Destination)

func (*LogOptions) SetDisabled 

func (m *LogOptions) SetDisabled(v bool)

func (*LogOptions) SetFolderId 

func (m *LogOptions) SetFolderId(v string)

func (*LogOptions) SetLogGroupId 

func (m *LogOptions) SetLogGroupId(v string)

func (*LogOptions) SetMinLevel 

func (m *LogOptions) SetMinLevel(v v1.LogLevel_Level)

func (*LogOptions) String 

func (x *LogOptions) String() string

type LogOptions_Destination 

type LogOptions_Destination = isLogOptions_Destination

type LogOptions_FolderId 

type LogOptions_FolderId struct {
	// Entry should be written to default log group for specified folder.
	FolderId string `protobuf:"bytes,3,opt,name=folder_id,json=folderId,proto3,oneof"`
}

type LogOptions_LogGroupId 

type LogOptions_LogGroupId struct {
	// Entry should be written to log group resolved by ID.
	LogGroupId string `protobuf:"bytes,2,opt,name=log_group_id,json=logGroupId,proto3,oneof"`
}

type PublishBrokerDataRequest 

type PublishBrokerDataRequest struct {

	// ID of broker publishing message
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Topic where message should be published
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Content of the message
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishBrokerDataRequest) Descriptor deprecated 

func (*PublishBrokerDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishBrokerDataRequest.ProtoReflect.Descriptor instead.

func (*PublishBrokerDataRequest) GetBrokerId 

func (x *PublishBrokerDataRequest) GetBrokerId() string

func (*PublishBrokerDataRequest) GetData 

func (x *PublishBrokerDataRequest) GetData() []byte

func (*PublishBrokerDataRequest) GetTopic 

func (x *PublishBrokerDataRequest) GetTopic() string

func (*PublishBrokerDataRequest) ProtoMessage 

func (*PublishBrokerDataRequest) ProtoMessage()

func (*PublishBrokerDataRequest) ProtoReflect 

func (x *PublishBrokerDataRequest) ProtoReflect() protoreflect.Message

func (*PublishBrokerDataRequest) Reset 

func (x *PublishBrokerDataRequest) Reset()

func (*PublishBrokerDataRequest) SetBrokerId 

func (m *PublishBrokerDataRequest) SetBrokerId(v string)

func (*PublishBrokerDataRequest) SetData 

func (m *PublishBrokerDataRequest) SetData(v []byte)

func (*PublishBrokerDataRequest) SetTopic 

func (m *PublishBrokerDataRequest) SetTopic(v string)

func (*PublishBrokerDataRequest) String 

func (x *PublishBrokerDataRequest) String() string

type PublishBrokerDataResponse 

type PublishBrokerDataResponse struct {
	// contains filtered or unexported fields
}

func (*PublishBrokerDataResponse) Descriptor deprecated 

func (*PublishBrokerDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishBrokerDataResponse.ProtoReflect.Descriptor instead.

func (*PublishBrokerDataResponse) ProtoMessage 

func (*PublishBrokerDataResponse) ProtoMessage()

func (*PublishBrokerDataResponse) ProtoReflect 

func (x *PublishBrokerDataResponse) ProtoReflect() protoreflect.Message

func (*PublishBrokerDataResponse) Reset 

func (x *PublishBrokerDataResponse) Reset()

func (*PublishBrokerDataResponse) String 

func (x *PublishBrokerDataResponse) String() string

type UnimplementedBrokerDataServiceServer 

type UnimplementedBrokerDataServiceServer struct{}

UnimplementedBrokerDataServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedBrokerDataServiceServer) Publish 

func (UnimplementedBrokerDataServiceServer) Publish(context.Context, *PublishBrokerDataRequest) (*PublishBrokerDataResponse, error)

type UnimplementedBrokerServiceServer 

type UnimplementedBrokerServiceServer struct{}

UnimplementedBrokerServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedBrokerServiceServer) AddCertificate 

func (UnimplementedBrokerServiceServer) AddCertificate(context.Context, *AddBrokerCertificateRequest) (*operation.Operation, error)

func (UnimplementedBrokerServiceServer) AddPassword 

func (UnimplementedBrokerServiceServer) AddPassword(context.Context, *AddBrokerPasswordRequest) (*operation.Operation, error)

func (UnimplementedBrokerServiceServer) Create 

func (UnimplementedBrokerServiceServer) Create(context.Context, *CreateBrokerRequest) (*operation.Operation, error)

func (UnimplementedBrokerServiceServer) Delete 

func (UnimplementedBrokerServiceServer) Delete(context.Context, *DeleteBrokerRequest) (*operation.Operation, error)

func (UnimplementedBrokerServiceServer) DeleteCertificate 

func (UnimplementedBrokerServiceServer) DeleteCertificate(context.Context, *DeleteBrokerCertificateRequest) (*operation.Operation, error)

func (UnimplementedBrokerServiceServer) DeletePassword 

func (UnimplementedBrokerServiceServer) DeletePassword(context.Context, *DeleteBrokerPasswordRequest) (*operation.Operation, error)

func (UnimplementedBrokerServiceServer) Get 

func (UnimplementedBrokerServiceServer) Get(context.Context, *GetBrokerRequest) (*Broker, error)

func (UnimplementedBrokerServiceServer) List 

func (UnimplementedBrokerServiceServer) List(context.Context, *ListBrokersRequest) (*ListBrokersResponse, error)

func (UnimplementedBrokerServiceServer) ListCertificates 

func (UnimplementedBrokerServiceServer) ListCertificates(context.Context, *ListBrokerCertificatesRequest) (*ListBrokerCertificatesResponse, error)

func (UnimplementedBrokerServiceServer) ListOperations 

func (UnimplementedBrokerServiceServer) ListOperations(context.Context, *ListBrokerOperationsRequest) (*ListBrokerOperationsResponse, error)

func (UnimplementedBrokerServiceServer) ListPasswords 

func (UnimplementedBrokerServiceServer) ListPasswords(context.Context, *ListBrokerPasswordsRequest) (*ListBrokerPasswordsResponse, error)

func (UnimplementedBrokerServiceServer) Update 

func (UnimplementedBrokerServiceServer) Update(context.Context, *UpdateBrokerRequest) (*operation.Operation, error)

type UnsafeBrokerDataServiceServer 

type UnsafeBrokerDataServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBrokerDataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BrokerDataServiceServer will result in compilation errors.

type UnsafeBrokerServiceServer 

type UnsafeBrokerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBrokerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BrokerServiceServer will result in compilation errors.

type UpdateBrokerMetadata 

type UpdateBrokerMetadata struct {

	// ID of the broker that is being updated.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBrokerMetadata) Descriptor deprecated 

func (*UpdateBrokerMetadata) Descriptor() ([]byte, []int)

Deprecated: Use UpdateBrokerMetadata.ProtoReflect.Descriptor instead.

func (*UpdateBrokerMetadata) GetBrokerId 

func (x *UpdateBrokerMetadata) GetBrokerId() string

func (*UpdateBrokerMetadata) ProtoMessage 

func (*UpdateBrokerMetadata) ProtoMessage()

func (*UpdateBrokerMetadata) ProtoReflect 

func (x *UpdateBrokerMetadata) ProtoReflect() protoreflect.Message

func (*UpdateBrokerMetadata) Reset 

func (x *UpdateBrokerMetadata) Reset()

func (*UpdateBrokerMetadata) SetBrokerId 

func (m *UpdateBrokerMetadata) SetBrokerId(v string)

func (*UpdateBrokerMetadata) String 

func (x *UpdateBrokerMetadata) String() string

type UpdateBrokerRequest 

type UpdateBrokerRequest struct {

	// ID of the broker to update.
	//
	// To get a broker ID make a [BrokerService.List] request.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// Field mask that specifies which fields of the broker are going to be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Name of the broker. The name must be unique within the folder.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the broker.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs.
	//
	// Existing set of `labels` is completely replaced by the provided set.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Options for logging broker events
	LogOptions *LogOptions `protobuf:"bytes,6,opt,name=log_options,json=logOptions,proto3" json:"log_options,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBrokerRequest) Descriptor deprecated 

func (*UpdateBrokerRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateBrokerRequest.ProtoReflect.Descriptor instead.

func (*UpdateBrokerRequest) GetBrokerId 

func (x *UpdateBrokerRequest) GetBrokerId() string

func (*UpdateBrokerRequest) GetDescription 

func (x *UpdateBrokerRequest) GetDescription() string

func (*UpdateBrokerRequest) GetLabels 

func (x *UpdateBrokerRequest) GetLabels() map[string]string

func (*UpdateBrokerRequest) GetLogOptions 

func (x *UpdateBrokerRequest) GetLogOptions() *LogOptions

func (*UpdateBrokerRequest) GetName 

func (x *UpdateBrokerRequest) GetName() string

func (*UpdateBrokerRequest) GetUpdateMask 

func (x *UpdateBrokerRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateBrokerRequest) ProtoMessage 

func (*UpdateBrokerRequest) ProtoMessage()

func (*UpdateBrokerRequest) ProtoReflect 

func (x *UpdateBrokerRequest) ProtoReflect() protoreflect.Message

func (*UpdateBrokerRequest) Reset 

func (x *UpdateBrokerRequest) Reset()

func (*UpdateBrokerRequest) SetBrokerId 

func (m *UpdateBrokerRequest) SetBrokerId(v string)

func (*UpdateBrokerRequest) SetDescription 

func (m *UpdateBrokerRequest) SetDescription(v string)

func (*UpdateBrokerRequest) SetLabels 

func (m *UpdateBrokerRequest) SetLabels(v map[string]string)

func (*UpdateBrokerRequest) SetLogOptions 

func (m *UpdateBrokerRequest) SetLogOptions(v *LogOptions)

func (*UpdateBrokerRequest) SetName 

func (m *UpdateBrokerRequest) SetName(v string)

func (*UpdateBrokerRequest) SetUpdateMask 

func (m *UpdateBrokerRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateBrokerRequest) String 

func (x *UpdateBrokerRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.