brokerv1

package
v0.2.11 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2025 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_runtime_broker_v1_broker_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Broker 

type Broker struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Optional Kafka configuration.
	Kafka *v1.KafkaConfig `protobuf:"bytes,3,opt,name=kafka,proto3,oneof" json:"kafka,omitempty"`
	// Optional RabbitMQ configuration.
	Rabbitmq *v11.RabbitMQConfig `protobuf:"bytes,4,opt,name=rabbitmq,proto3,oneof" json:"rabbitmq,omitempty"`
	// Optional MQTT configuration.
	Mqtt *v12.MqttConfig `protobuf:"bytes,5,opt,name=mqtt,proto3,oneof" json:"mqtt,omitempty"`
	// Optional NATS configuration.
	Nats *v13.NatsConfig `protobuf:"bytes,6,opt,name=nats,proto3,oneof" json:"nats,omitempty"`
	// Optional NSQ configuration.
	Nsq *v14.NsqConfig `protobuf:"bytes,7,opt,name=nsq,proto3,oneof" json:"nsq,omitempty"`
	// Optional Pulsar configuration.
	Pulsar *v15.PulsarConfig `protobuf:"bytes,8,opt,name=pulsar,proto3,oneof" json:"pulsar,omitempty"`
	// Optional Redis (as MQ) configuration.
	RedisMq *v16.RedisMqConfig `protobuf:"bytes,9,opt,name=redis_mq,proto3,oneof" json:"redis_mq,omitempty"`
	// Optional RocketMQ configuration.
	Rocketmq *v17.RocketMQConfig `protobuf:"bytes,10,opt,name=rocketmq,proto3,oneof" json:"rocketmq,omitempty"`
	// Optional SQS configuration.
	Sqs *v18.SqsConfig `protobuf:"bytes,11,opt,name=sqs,proto3,oneof" json:"sqs,omitempty"`
	// Optional STOMP configuration.
	Stomp *v19.StompConfig `protobuf:"bytes,12,opt,name=stomp,proto3,oneof" json:"stomp,omitempty"`
	// Optional customize configuration.
	Customize *structpb.Struct `protobuf:"bytes,100,opt,name=customize,proto3,oneof" json:"customize,omitempty"`
	// contains filtered or unexported fields
}

Broker defines the configuration for a message queue service. It can contain configurations for different message queue implementations.

func (*Broker) Descriptor deprecated 

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

Deprecated: Use Broker.ProtoReflect.Descriptor instead.

func (*Broker) GetCustomize 

func (x *Broker) GetCustomize() *structpb.Struct

func (*Broker) GetKafka 

func (x *Broker) GetKafka() *v1.KafkaConfig

func (*Broker) GetMqtt 

func (x *Broker) GetMqtt() *v12.MqttConfig

func (*Broker) GetName 

func (x *Broker) GetName() string

func (*Broker) GetNats 

func (x *Broker) GetNats() *v13.NatsConfig

func (*Broker) GetNsq 

func (x *Broker) GetNsq() *v14.NsqConfig

func (*Broker) GetPulsar 

func (x *Broker) GetPulsar() *v15.PulsarConfig

func (*Broker) GetRabbitmq 

func (x *Broker) GetRabbitmq() *v11.RabbitMQConfig

func (*Broker) GetRedisMq 

func (x *Broker) GetRedisMq() *v16.RedisMqConfig

func (*Broker) GetRocketmq 

func (x *Broker) GetRocketmq() *v17.RocketMQConfig

func (*Broker) GetSqs 

func (x *Broker) GetSqs() *v18.SqsConfig

func (*Broker) GetStomp 

func (x *Broker) GetStomp() *v19.StompConfig

func (*Broker) GetType 

func (x *Broker) GetType() string

func (*Broker) ProtoMessage 

func (*Broker) ProtoMessage()

func (*Broker) ProtoReflect 

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

func (*Broker) Reset 

func (x *Broker) Reset()

func (*Broker) String 

func (x *Broker) String() string

func (*Broker) Validate 

func (m *Broker) Validate() error

Validate checks the field values on Broker with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Broker) ValidateAll 

func (m *Broker) ValidateAll() error

ValidateAll checks the field values on Broker with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BrokerMultiError, or nil if none found.

type BrokerMultiError 

type BrokerMultiError []error

BrokerMultiError is an error wrapping multiple validation errors returned by Broker.ValidateAll() if the designated constraints aren't met.

func (BrokerMultiError) AllErrors 

func (m BrokerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BrokerMultiError) Error 

func (m BrokerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BrokerValidationError 

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

BrokerValidationError is the validation error returned by Broker.Validate if the designated constraints aren't met.

func (BrokerValidationError) Cause 

func (e BrokerValidationError) Cause() error

Cause function returns cause value.

func (BrokerValidationError) Error 

func (e BrokerValidationError) Error() string

Error satisfies the builtin error interface

func (BrokerValidationError) ErrorName 

func (e BrokerValidationError) ErrorName() string

ErrorName returns error name.

func (BrokerValidationError) Field 

func (e BrokerValidationError) Field() string

Field function returns field value.

func (BrokerValidationError) Key 

func (e BrokerValidationError) Key() bool

Key function returns key value.

func (BrokerValidationError) Reason 

func (e BrokerValidationError) Reason() string

Reason function returns reason value.

type Brokers 

type Brokers struct {
	Default *string   `protobuf:"bytes,1,opt,name=default,proto3,oneof" json:"default,omitempty"`
	Active  *string   `protobuf:"bytes,2,opt,name=active,proto3,oneof" json:"active,omitempty"`
	Brokers []*Broker `protobuf:"bytes,3,rep,name=brokers,proto3" json:"brokers,omitempty"`
	// contains filtered or unexported fields
}

func (*Brokers) Descriptor deprecated 

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

Deprecated: Use Brokers.ProtoReflect.Descriptor instead.

func (*Brokers) GetActive 

func (x *Brokers) GetActive() string

func (*Brokers) GetBrokers 

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

func (*Brokers) GetDefault 

func (x *Brokers) GetDefault() string

func (*Brokers) ProtoMessage 

func (*Brokers) ProtoMessage()

func (*Brokers) ProtoReflect 

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

func (*Brokers) Reset 

func (x *Brokers) Reset()

func (*Brokers) String 

func (x *Brokers) String() string

func (*Brokers) Validate 

func (m *Brokers) Validate() error

Validate checks the field values on Brokers with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Brokers) ValidateAll 

func (m *Brokers) ValidateAll() error

ValidateAll checks the field values on Brokers with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BrokersMultiError, or nil if none found.

type BrokersMultiError 

type BrokersMultiError []error

BrokersMultiError is an error wrapping multiple validation errors returned by Brokers.ValidateAll() if the designated constraints aren't met.

func (BrokersMultiError) AllErrors 

func (m BrokersMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BrokersMultiError) Error 

func (m BrokersMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BrokersValidationError 

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

BrokersValidationError is the validation error returned by Brokers.Validate if the designated constraints aren't met.

func (BrokersValidationError) Cause 

func (e BrokersValidationError) Cause() error

Cause function returns cause value.

func (BrokersValidationError) Error 

func (e BrokersValidationError) Error() string

Error satisfies the builtin error interface

func (BrokersValidationError) ErrorName 

func (e BrokersValidationError) ErrorName() string

ErrorName returns error name.

func (BrokersValidationError) Field 

func (e BrokersValidationError) Field() string

Field function returns field value.

func (BrokersValidationError) Key 

func (e BrokersValidationError) Key() bool

Key function returns key value.

func (BrokersValidationError) Reason 

func (e BrokersValidationError) Reason() string

Reason function returns reason value.

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.