broker

package
v0.0.0-...-5fa7aab Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 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 (*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

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 (*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 (*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.

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

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.

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

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) 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 (Broker_Status) String

func (x Broker_Status) String() string

func (Broker_Status) Type

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 (*CreateBrokerRequest_Certificate) Reset

func (*CreateBrokerRequest_Certificate) SetCertificateData

func (m *CreateBrokerRequest_Certificate) SetCertificateData(v string)

func (*CreateBrokerRequest_Certificate) 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 (*DeleteBrokerCertificateMetadata) Reset

func (*DeleteBrokerCertificateMetadata) SetBrokerId

func (m *DeleteBrokerCertificateMetadata) SetBrokerId(v string)

func (*DeleteBrokerCertificateMetadata) SetFingerprint

func (m *DeleteBrokerCertificateMetadata) SetFingerprint(v string)

func (*DeleteBrokerCertificateMetadata) 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 (*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

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 (*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

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 (*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 (*ListBrokerCertificatesRequest) Reset

func (x *ListBrokerCertificatesRequest) Reset()

func (*ListBrokerCertificatesRequest) SetBrokerId

func (m *ListBrokerCertificatesRequest) SetBrokerId(v string)

func (*ListBrokerCertificatesRequest) 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 (*ListBrokerCertificatesResponse) Reset

func (x *ListBrokerCertificatesResponse) Reset()

func (*ListBrokerCertificatesResponse) SetCertificates

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

func (*ListBrokerCertificatesResponse) 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 (*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 (*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

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 (*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 (*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 (*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.

type UnimplementedBrokerServiceServer

type UnimplementedBrokerServiceServer struct {
}

UnimplementedBrokerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBrokerServiceServer) AddCertificate

func (UnimplementedBrokerServiceServer) AddPassword

func (UnimplementedBrokerServiceServer) Create

func (UnimplementedBrokerServiceServer) Delete

func (UnimplementedBrokerServiceServer) DeleteCertificate

func (UnimplementedBrokerServiceServer) DeletePassword

func (UnimplementedBrokerServiceServer) Get

func (UnimplementedBrokerServiceServer) List

func (UnimplementedBrokerServiceServer) Update

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL