brokerv1

package
v0.2.10 Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2025 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_runtime_broker_v1_broker_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_kafka_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_mqtt_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_nats_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_nsq_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_pulsar_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_rabbitmq_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_redis_mq_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_rocketmq_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_sqs_proto protoreflect.FileDescriptor
View Source 
var File_runtime_broker_v1_stomp_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 *KafkaConfig `protobuf:"bytes,3,opt,name=kafka,proto3,oneof" json:"kafka,omitempty"`
	// Optional RabbitMQ configuration.
	Rabbitmq *RabbitMQConfig `protobuf:"bytes,4,opt,name=rabbitmq,proto3,oneof" json:"rabbitmq,omitempty"`
	// Optional MQTT configuration.
	Mqtt *MqttConfig `protobuf:"bytes,5,opt,name=mqtt,proto3,oneof" json:"mqtt,omitempty"`
	// Optional NATS configuration.
	Nats *NatsConfig `protobuf:"bytes,6,opt,name=nats,proto3,oneof" json:"nats,omitempty"`
	// Optional NSQ configuration.
	Nsq *NsqConfig `protobuf:"bytes,7,opt,name=nsq,proto3,oneof" json:"nsq,omitempty"`
	// Optional Pulsar configuration.
	Pulsar *PulsarConfig `protobuf:"bytes,8,opt,name=pulsar,proto3,oneof" json:"pulsar,omitempty"`
	// Optional Redis (as MQ) configuration.
	RedisMq *RedisMqConfig `protobuf:"bytes,9,opt,name=redis_mq,proto3,oneof" json:"redis_mq,omitempty"`
	// Optional RocketMQ configuration.
	Rocketmq *RocketMQConfig `protobuf:"bytes,10,opt,name=rocketmq,proto3,oneof" json:"rocketmq,omitempty"`
	// Optional SQS configuration.
	Sqs *SqsConfig `protobuf:"bytes,11,opt,name=sqs,proto3,oneof" json:"sqs,omitempty"`
	// Optional STOMP configuration.
	Stomp *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() *KafkaConfig

func (*Broker) GetMqtt 

func (x *Broker) GetMqtt() *MqttConfig

func (*Broker) GetName 

func (x *Broker) GetName() string

func (*Broker) GetNats 

func (x *Broker) GetNats() *NatsConfig

func (*Broker) GetNsq 

func (x *Broker) GetNsq() *NsqConfig

func (*Broker) GetPulsar 

func (x *Broker) GetPulsar() *PulsarConfig

func (*Broker) GetRabbitmq 

func (x *Broker) GetRabbitmq() *RabbitMQConfig

func (*Broker) GetRedisMq 

func (x *Broker) GetRedisMq() *RedisMqConfig

func (*Broker) GetRocketmq 

func (x *Broker) GetRocketmq() *RocketMQConfig

func (*Broker) GetSqs 

func (x *Broker) GetSqs() *SqsConfig

func (*Broker) GetStomp 

func (x *Broker) GetStomp() *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.

type KafkaConfig 

type KafkaConfig struct {

	// List of Kafka broker addresses (e.g., "localhost:9092").
	Addresses []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// Default topic for producers or consumers.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Consumer group ID for Kafka consumers.
	ConsumerGroupId *string `protobuf:"bytes,3,opt,name=consumer_group_id,json=consumerGroupId,proto3,oneof" json:"consumer_group_id,omitempty"`
	// Client ID for the Kafka client.
	ClientId *string `protobuf:"bytes,4,opt,name=client_id,json=clientId,proto3,oneof" json:"client_id,omitempty"`
	// SASL mechanism for authentication (e.g., "PLAIN", "SCRAM-SHA-256").
	SaslMechanism *string `protobuf:"bytes,5,opt,name=sasl_mechanism,json=saslMechanism,proto3,oneof" json:"sasl_mechanism,omitempty"`
	// SASL username.
	SaslUsername *string `protobuf:"bytes,6,opt,name=sasl_username,json=saslUsername,proto3,oneof" json:"sasl_username,omitempty"`
	// SASL password.
	SaslPassword *string `protobuf:"bytes,7,opt,name=sasl_password,json=saslPassword,proto3,oneof" json:"sasl_password,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,8,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,9,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,10,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 136-byte string literal not displayed */
	// Auto offset reset policy (e.g., "earliest", "latest", "none").
	AutoOffsetReset *string `protobuf:"bytes,12,opt,name=auto_offset_reset,json=autoOffsetReset,proto3,oneof" json:"auto_offset_reset,omitempty"`
	// Max bytes per partition for fetching messages.
	MaxBytesPerPartition *int32 `` /* 133-byte string literal not displayed */
	// Max wait time in milliseconds for fetching messages.
	MaxWaitMs *int32 `protobuf:"varint,14,opt,name=max_wait_ms,json=maxWaitMs,proto3,oneof" json:"max_wait_ms,omitempty"`
	// Whether to enable idempotence for producers.
	EnableIdempotence *bool `protobuf:"varint,15,opt,name=enable_idempotence,json=enableIdempotence,proto3,oneof" json:"enable_idempotence,omitempty"`
	// Acknowledge level for producers (e.g., "all", "1", "0").
	Acks *string `protobuf:"bytes,16,opt,name=acks,proto3,oneof" json:"acks,omitempty"`
	// Compression type for producers (e.g., "none", "gzip", "snappy", "lz4", "zstd").
	CompressionType *string `protobuf:"bytes,17,opt,name=compression_type,json=compressionType,proto3,oneof" json:"compression_type,omitempty"`
	// contains filtered or unexported fields
}

KafkaConfig defines the configuration for a Kafka message queue.

func (*KafkaConfig) Descriptor deprecated 

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

Deprecated: Use KafkaConfig.ProtoReflect.Descriptor instead.

func (*KafkaConfig) GetAcks 

func (x *KafkaConfig) GetAcks() string

func (*KafkaConfig) GetAddresses 

func (x *KafkaConfig) GetAddresses() []string

func (*KafkaConfig) GetAutoOffsetReset 

func (x *KafkaConfig) GetAutoOffsetReset() string

func (*KafkaConfig) GetClientId 

func (x *KafkaConfig) GetClientId() string

func (*KafkaConfig) GetCompressionType 

func (x *KafkaConfig) GetCompressionType() string

func (*KafkaConfig) GetConsumerGroupId 

func (x *KafkaConfig) GetConsumerGroupId() string

func (*KafkaConfig) GetEnableIdempotence 

func (x *KafkaConfig) GetEnableIdempotence() bool

func (*KafkaConfig) GetMaxBytesPerPartition 

func (x *KafkaConfig) GetMaxBytesPerPartition() int32

func (*KafkaConfig) GetMaxWaitMs 

func (x *KafkaConfig) GetMaxWaitMs() int32

func (*KafkaConfig) GetSaslMechanism 

func (x *KafkaConfig) GetSaslMechanism() string

func (*KafkaConfig) GetSaslPassword 

func (x *KafkaConfig) GetSaslPassword() string

func (*KafkaConfig) GetSaslUsername 

func (x *KafkaConfig) GetSaslUsername() string

func (*KafkaConfig) GetTlsCaCertFile 

func (x *KafkaConfig) GetTlsCaCertFile() string

func (*KafkaConfig) GetTlsClientCertFile 

func (x *KafkaConfig) GetTlsClientCertFile() string

func (*KafkaConfig) GetTlsClientKeyFile 

func (x *KafkaConfig) GetTlsClientKeyFile() string

func (*KafkaConfig) GetTlsInsecureSkipVerify 

func (x *KafkaConfig) GetTlsInsecureSkipVerify() bool

func (*KafkaConfig) GetTopic 

func (x *KafkaConfig) GetTopic() string

func (*KafkaConfig) ProtoMessage 

func (*KafkaConfig) ProtoMessage()

func (*KafkaConfig) ProtoReflect 

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

func (*KafkaConfig) Reset 

func (x *KafkaConfig) Reset()

func (*KafkaConfig) String 

func (x *KafkaConfig) String() string

func (*KafkaConfig) Validate 

func (m *KafkaConfig) Validate() error

Validate checks the field values on KafkaConfig 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 (*KafkaConfig) ValidateAll 

func (m *KafkaConfig) ValidateAll() error

ValidateAll checks the field values on KafkaConfig 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 KafkaConfigMultiError, or nil if none found.

type KafkaConfigMultiError 

type KafkaConfigMultiError []error

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

func (KafkaConfigMultiError) AllErrors 

func (m KafkaConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KafkaConfigMultiError) Error 

func (m KafkaConfigMultiError) Error() string

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

type KafkaConfigValidationError 

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

KafkaConfigValidationError is the validation error returned by KafkaConfig.Validate if the designated constraints aren't met.

func (KafkaConfigValidationError) Cause 

func (e KafkaConfigValidationError) Cause() error

Cause function returns cause value.

func (KafkaConfigValidationError) Error 

func (e KafkaConfigValidationError) Error() string

Error satisfies the builtin error interface

func (KafkaConfigValidationError) ErrorName 

func (e KafkaConfigValidationError) ErrorName() string

ErrorName returns error name.

func (KafkaConfigValidationError) Field 

func (e KafkaConfigValidationError) Field() string

Field function returns field value.

func (KafkaConfigValidationError) Key 

func (e KafkaConfigValidationError) Key() bool

Key function returns key value.

func (KafkaConfigValidationError) Reason 

func (e KafkaConfigValidationError) Reason() string

Reason function returns reason value.

type MqttConfig 

type MqttConfig struct {

	// MQTT broker address (e.g., "tcp://localhost:1883").
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Client ID for the MQTT client.
	ClientId *string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3,oneof" json:"client_id,omitempty"`
	// Username for authentication.
	Username *string `protobuf:"bytes,3,opt,name=username,proto3,oneof" json:"username,omitempty"`
	// Password for authentication.
	Password *string `protobuf:"bytes,4,opt,name=password,proto3,oneof" json:"password,omitempty"`
	// Default topic for publishing or subscribing.
	Topic *string `protobuf:"bytes,5,opt,name=topic,proto3,oneof" json:"topic,omitempty"`
	// QoS level for messages (0, 1, or 2).
	Qos *int32 `protobuf:"varint,6,opt,name=qos,proto3,oneof" json:"qos,omitempty"`
	// Whether to retain messages.
	Retained *bool `protobuf:"varint,7,opt,name=retained,proto3,oneof" json:"retained,omitempty"`
	// Whether to enable TLS.
	TlsEnabled *bool `protobuf:"varint,8,opt,name=tls_enabled,json=tlsEnabled,proto3,oneof" json:"tls_enabled,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,9,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,10,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,11,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 136-byte string literal not displayed */
	// Keep alive interval in seconds.
	KeepAliveIntervalSeconds *int32 `` /* 145-byte string literal not displayed */
	// Clean session flag.
	CleanSession *bool `protobuf:"varint,14,opt,name=clean_session,json=cleanSession,proto3,oneof" json:"clean_session,omitempty"`
	// contains filtered or unexported fields
}

MqttConfig defines the configuration for an MQTT message queue.

func (*MqttConfig) Descriptor deprecated 

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

Deprecated: Use MqttConfig.ProtoReflect.Descriptor instead.

func (*MqttConfig) GetAddress 

func (x *MqttConfig) GetAddress() string

func (*MqttConfig) GetCleanSession 

func (x *MqttConfig) GetCleanSession() bool

func (*MqttConfig) GetClientId 

func (x *MqttConfig) GetClientId() string

func (*MqttConfig) GetKeepAliveIntervalSeconds 

func (x *MqttConfig) GetKeepAliveIntervalSeconds() int32

func (*MqttConfig) GetPassword 

func (x *MqttConfig) GetPassword() string

func (*MqttConfig) GetQos 

func (x *MqttConfig) GetQos() int32

func (*MqttConfig) GetRetained 

func (x *MqttConfig) GetRetained() bool

func (*MqttConfig) GetTlsCaCertFile 

func (x *MqttConfig) GetTlsCaCertFile() string

func (*MqttConfig) GetTlsClientCertFile 

func (x *MqttConfig) GetTlsClientCertFile() string

func (*MqttConfig) GetTlsClientKeyFile 

func (x *MqttConfig) GetTlsClientKeyFile() string

func (*MqttConfig) GetTlsEnabled 

func (x *MqttConfig) GetTlsEnabled() bool

func (*MqttConfig) GetTlsInsecureSkipVerify 

func (x *MqttConfig) GetTlsInsecureSkipVerify() bool

func (*MqttConfig) GetTopic 

func (x *MqttConfig) GetTopic() string

func (*MqttConfig) GetUsername 

func (x *MqttConfig) GetUsername() string

func (*MqttConfig) ProtoMessage 

func (*MqttConfig) ProtoMessage()

func (*MqttConfig) ProtoReflect 

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

func (*MqttConfig) Reset 

func (x *MqttConfig) Reset()

func (*MqttConfig) String 

func (x *MqttConfig) String() string

func (*MqttConfig) Validate 

func (m *MqttConfig) Validate() error

Validate checks the field values on MqttConfig 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 (*MqttConfig) ValidateAll 

func (m *MqttConfig) ValidateAll() error

ValidateAll checks the field values on MqttConfig 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 MqttConfigMultiError, or nil if none found.

type MqttConfigMultiError 

type MqttConfigMultiError []error

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

func (MqttConfigMultiError) AllErrors 

func (m MqttConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MqttConfigMultiError) Error 

func (m MqttConfigMultiError) Error() string

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

type MqttConfigValidationError 

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

MqttConfigValidationError is the validation error returned by MqttConfig.Validate if the designated constraints aren't met.

func (MqttConfigValidationError) Cause 

func (e MqttConfigValidationError) Cause() error

Cause function returns cause value.

func (MqttConfigValidationError) Error 

func (e MqttConfigValidationError) Error() string

Error satisfies the builtin error interface

func (MqttConfigValidationError) ErrorName 

func (e MqttConfigValidationError) ErrorName() string

ErrorName returns error name.

func (MqttConfigValidationError) Field 

func (e MqttConfigValidationError) Field() string

Field function returns field value.

func (MqttConfigValidationError) Key 

func (e MqttConfigValidationError) Key() bool

Key function returns key value.

func (MqttConfigValidationError) Reason 

func (e MqttConfigValidationError) Reason() string

Reason function returns reason value.

type NatsConfig 

type NatsConfig struct {

	// NATS server address (e.g., "nats://localhost:4222").
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Default subject for publishing or subscribing.
	Subject *string `protobuf:"bytes,2,opt,name=subject,proto3,oneof" json:"subject,omitempty"`
	// Queue group name for subscribers.
	QueueGroup *string `protobuf:"bytes,3,opt,name=queue_group,json=queueGroup,proto3,oneof" json:"queue_group,omitempty"`
	// Path to a user credentials file (.creds).
	UserCredentialsFile *string `` /* 126-byte string literal not displayed */
	// NKey seed file for authentication.
	NkeySeedFile *string `protobuf:"bytes,5,opt,name=nkey_seed_file,json=nkeySeedFile,proto3,oneof" json:"nkey_seed_file,omitempty"`
	// JWT for authentication.
	Jwt *string `protobuf:"bytes,6,opt,name=jwt,proto3,oneof" json:"jwt,omitempty"`
	// Authentication token.
	Token *string `protobuf:"bytes,7,opt,name=token,proto3,oneof" json:"token,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,8,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,9,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,10,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 136-byte string literal not displayed */
	// Whether to use JetStream for persistence.
	JetstreamEnabled *bool `protobuf:"varint,12,opt,name=jetstream_enabled,json=jetstreamEnabled,proto3,oneof" json:"jetstream_enabled,omitempty"`
	// JetStream stream name.
	JetstreamStreamName *string `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

NatsConfig defines the configuration for a NATS message queue.

func (*NatsConfig) Descriptor deprecated 

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

Deprecated: Use NatsConfig.ProtoReflect.Descriptor instead.

func (*NatsConfig) GetAddress 

func (x *NatsConfig) GetAddress() string

func (*NatsConfig) GetJetstreamEnabled 

func (x *NatsConfig) GetJetstreamEnabled() bool

func (*NatsConfig) GetJetstreamStreamName 

func (x *NatsConfig) GetJetstreamStreamName() string

func (*NatsConfig) GetJwt 

func (x *NatsConfig) GetJwt() string

func (*NatsConfig) GetNkeySeedFile 

func (x *NatsConfig) GetNkeySeedFile() string

func (*NatsConfig) GetQueueGroup 

func (x *NatsConfig) GetQueueGroup() string

func (*NatsConfig) GetSubject 

func (x *NatsConfig) GetSubject() string

func (*NatsConfig) GetTlsCaCertFile 

func (x *NatsConfig) GetTlsCaCertFile() string

func (*NatsConfig) GetTlsClientCertFile 

func (x *NatsConfig) GetTlsClientCertFile() string

func (*NatsConfig) GetTlsClientKeyFile 

func (x *NatsConfig) GetTlsClientKeyFile() string

func (*NatsConfig) GetTlsInsecureSkipVerify 

func (x *NatsConfig) GetTlsInsecureSkipVerify() bool

func (*NatsConfig) GetToken 

func (x *NatsConfig) GetToken() string

func (*NatsConfig) GetUserCredentialsFile 

func (x *NatsConfig) GetUserCredentialsFile() string

func (*NatsConfig) ProtoMessage 

func (*NatsConfig) ProtoMessage()

func (*NatsConfig) ProtoReflect 

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

func (*NatsConfig) Reset 

func (x *NatsConfig) Reset()

func (*NatsConfig) String 

func (x *NatsConfig) String() string

func (*NatsConfig) Validate 

func (m *NatsConfig) Validate() error

Validate checks the field values on NatsConfig 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 (*NatsConfig) ValidateAll 

func (m *NatsConfig) ValidateAll() error

ValidateAll checks the field values on NatsConfig 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 NatsConfigMultiError, or nil if none found.

type NatsConfigMultiError 

type NatsConfigMultiError []error

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

func (NatsConfigMultiError) AllErrors 

func (m NatsConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NatsConfigMultiError) Error 

func (m NatsConfigMultiError) Error() string

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

type NatsConfigValidationError 

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

NatsConfigValidationError is the validation error returned by NatsConfig.Validate if the designated constraints aren't met.

func (NatsConfigValidationError) Cause 

func (e NatsConfigValidationError) Cause() error

Cause function returns cause value.

func (NatsConfigValidationError) Error 

func (e NatsConfigValidationError) Error() string

Error satisfies the builtin error interface

func (NatsConfigValidationError) ErrorName 

func (e NatsConfigValidationError) ErrorName() string

ErrorName returns error name.

func (NatsConfigValidationError) Field 

func (e NatsConfigValidationError) Field() string

Field function returns field value.

func (NatsConfigValidationError) Key 

func (e NatsConfigValidationError) Key() bool

Key function returns key value.

func (NatsConfigValidationError) Reason 

func (e NatsConfigValidationError) Reason() string

Reason function returns reason value.

type NsqConfig 

type NsqConfig struct {

	// List of NSQD addresses (e.g., "localhost:4150").
	NsqdAddresses []string `protobuf:"bytes,1,rep,name=nsqd_addresses,json=nsqdAddresses,proto3" json:"nsqd_addresses,omitempty"`
	// List of NSQLookupD addresses (e.g., "localhost:4161").
	NsqlookupdAddresses []string `protobuf:"bytes,2,rep,name=nsqlookupd_addresses,json=nsqlookupdAddresses,proto3" json:"nsqlookupd_addresses,omitempty"`
	// Default topic for publishing or subscribing.
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// Channel name for consumers.
	Channel *string `protobuf:"bytes,4,opt,name=channel,proto3,oneof" json:"channel,omitempty"`
	// Max in flight messages for consumers.
	MaxInFlight *int32 `protobuf:"varint,5,opt,name=max_in_flight,json=maxInFlight,proto3,oneof" json:"max_in_flight,omitempty"`
	// Lookupd poll interval in seconds.
	LookupdPollIntervalSeconds *int32 `` /* 150-byte string literal not displayed */
	// Whether to enable TLS.
	TlsEnabled *bool `protobuf:"varint,7,opt,name=tls_enabled,json=tlsEnabled,proto3,oneof" json:"tls_enabled,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,8,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,9,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,10,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

NsqConfig defines the configuration for an NSQ message queue.

func (*NsqConfig) Descriptor deprecated 

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

Deprecated: Use NsqConfig.ProtoReflect.Descriptor instead.

func (*NsqConfig) GetChannel 

func (x *NsqConfig) GetChannel() string

func (*NsqConfig) GetLookupdPollIntervalSeconds 

func (x *NsqConfig) GetLookupdPollIntervalSeconds() int32

func (*NsqConfig) GetMaxInFlight 

func (x *NsqConfig) GetMaxInFlight() int32

func (*NsqConfig) GetNsqdAddresses 

func (x *NsqConfig) GetNsqdAddresses() []string

func (*NsqConfig) GetNsqlookupdAddresses 

func (x *NsqConfig) GetNsqlookupdAddresses() []string

func (*NsqConfig) GetTlsCaCertFile 

func (x *NsqConfig) GetTlsCaCertFile() string

func (*NsqConfig) GetTlsClientCertFile 

func (x *NsqConfig) GetTlsClientCertFile() string

func (*NsqConfig) GetTlsClientKeyFile 

func (x *NsqConfig) GetTlsClientKeyFile() string

func (*NsqConfig) GetTlsEnabled 

func (x *NsqConfig) GetTlsEnabled() bool

func (*NsqConfig) GetTlsInsecureSkipVerify 

func (x *NsqConfig) GetTlsInsecureSkipVerify() bool

func (*NsqConfig) GetTopic 

func (x *NsqConfig) GetTopic() string

func (*NsqConfig) ProtoMessage 

func (*NsqConfig) ProtoMessage()

func (*NsqConfig) ProtoReflect 

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

func (*NsqConfig) Reset 

func (x *NsqConfig) Reset()

func (*NsqConfig) String 

func (x *NsqConfig) String() string

func (*NsqConfig) Validate 

func (m *NsqConfig) Validate() error

Validate checks the field values on NsqConfig 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 (*NsqConfig) ValidateAll 

func (m *NsqConfig) ValidateAll() error

ValidateAll checks the field values on NsqConfig 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 NsqConfigMultiError, or nil if none found.

type NsqConfigMultiError 

type NsqConfigMultiError []error

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

func (NsqConfigMultiError) AllErrors 

func (m NsqConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NsqConfigMultiError) Error 

func (m NsqConfigMultiError) Error() string

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

type NsqConfigValidationError 

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

NsqConfigValidationError is the validation error returned by NsqConfig.Validate if the designated constraints aren't met.

func (NsqConfigValidationError) Cause 

func (e NsqConfigValidationError) Cause() error

Cause function returns cause value.

func (NsqConfigValidationError) Error 

func (e NsqConfigValidationError) Error() string

Error satisfies the builtin error interface

func (NsqConfigValidationError) ErrorName 

func (e NsqConfigValidationError) ErrorName() string

ErrorName returns error name.

func (NsqConfigValidationError) Field 

func (e NsqConfigValidationError) Field() string

Field function returns field value.

func (NsqConfigValidationError) Key 

func (e NsqConfigValidationError) Key() bool

Key function returns key value.

func (NsqConfigValidationError) Reason 

func (e NsqConfigValidationError) Reason() string

Reason function returns reason value.

type PulsarConfig 

type PulsarConfig struct {

	// Pulsar broker service URL (e.g., "pulsar://localhost:6650").
	ServiceUrl string `protobuf:"bytes,1,opt,name=service_url,json=serviceUrl,proto3" json:"service_url,omitempty"`
	// Default topic for producers or consumers.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Subscription name for consumers.
	SubscriptionName *string `protobuf:"bytes,3,opt,name=subscription_name,json=subscriptionName,proto3,oneof" json:"subscription_name,omitempty"`
	// Authentication token.
	AuthToken *string `protobuf:"bytes,4,opt,name=auth_token,json=authToken,proto3,oneof" json:"auth_token,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,5,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,6,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,7,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 135-byte string literal not displayed */
	// Operation timeout in milliseconds.
	OperationTimeoutMs *int32 `protobuf:"varint,9,opt,name=operation_timeout_ms,json=operationTimeoutMs,proto3,oneof" json:"operation_timeout_ms,omitempty"`
	// Number of message listeners.
	NumMessageListeners *int32 `` /* 128-byte string literal not displayed */
	// Max pending messages.
	MaxPendingMessages *int32 `protobuf:"varint,11,opt,name=max_pending_messages,json=maxPendingMessages,proto3,oneof" json:"max_pending_messages,omitempty"`
	// contains filtered or unexported fields
}

PulsarConfig defines the configuration for a Pulsar message queue.

func (*PulsarConfig) Descriptor deprecated 

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

Deprecated: Use PulsarConfig.ProtoReflect.Descriptor instead.

func (*PulsarConfig) GetAuthToken 

func (x *PulsarConfig) GetAuthToken() string

func (*PulsarConfig) GetMaxPendingMessages 

func (x *PulsarConfig) GetMaxPendingMessages() int32

func (*PulsarConfig) GetNumMessageListeners 

func (x *PulsarConfig) GetNumMessageListeners() int32

func (*PulsarConfig) GetOperationTimeoutMs 

func (x *PulsarConfig) GetOperationTimeoutMs() int32

func (*PulsarConfig) GetServiceUrl 

func (x *PulsarConfig) GetServiceUrl() string

func (*PulsarConfig) GetSubscriptionName 

func (x *PulsarConfig) GetSubscriptionName() string

func (*PulsarConfig) GetTlsCaCertFile 

func (x *PulsarConfig) GetTlsCaCertFile() string

func (*PulsarConfig) GetTlsClientCertFile 

func (x *PulsarConfig) GetTlsClientCertFile() string

func (*PulsarConfig) GetTlsClientKeyFile 

func (x *PulsarConfig) GetTlsClientKeyFile() string

func (*PulsarConfig) GetTlsInsecureSkipVerify 

func (x *PulsarConfig) GetTlsInsecureSkipVerify() bool

func (*PulsarConfig) GetTopic 

func (x *PulsarConfig) GetTopic() string

func (*PulsarConfig) ProtoMessage 

func (*PulsarConfig) ProtoMessage()

func (*PulsarConfig) ProtoReflect 

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

func (*PulsarConfig) Reset 

func (x *PulsarConfig) Reset()

func (*PulsarConfig) String 

func (x *PulsarConfig) String() string

func (*PulsarConfig) Validate 

func (m *PulsarConfig) Validate() error

Validate checks the field values on PulsarConfig 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 (*PulsarConfig) ValidateAll 

func (m *PulsarConfig) ValidateAll() error

ValidateAll checks the field values on PulsarConfig 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 PulsarConfigMultiError, or nil if none found.

type PulsarConfigMultiError 

type PulsarConfigMultiError []error

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

func (PulsarConfigMultiError) AllErrors 

func (m PulsarConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PulsarConfigMultiError) Error 

func (m PulsarConfigMultiError) Error() string

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

type PulsarConfigValidationError 

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

PulsarConfigValidationError is the validation error returned by PulsarConfig.Validate if the designated constraints aren't met.

func (PulsarConfigValidationError) Cause 

func (e PulsarConfigValidationError) Cause() error

Cause function returns cause value.

func (PulsarConfigValidationError) Error 

func (e PulsarConfigValidationError) Error() string

Error satisfies the builtin error interface

func (PulsarConfigValidationError) ErrorName 

func (e PulsarConfigValidationError) ErrorName() string

ErrorName returns error name.

func (PulsarConfigValidationError) Field 

func (e PulsarConfigValidationError) Field() string

Field function returns field value.

func (PulsarConfigValidationError) Key 

func (e PulsarConfigValidationError) Key() bool

Key function returns key value.

func (PulsarConfigValidationError) Reason 

func (e PulsarConfigValidationError) Reason() string

Reason function returns reason value.

type RabbitMQConfig 

type RabbitMQConfig struct {

	// RabbitMQ connection URI (e.g., "amqp://guest:guest@localhost:5672/").
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// Default exchange name.
	Exchange *string `protobuf:"bytes,2,opt,name=exchange,proto3,oneof" json:"exchange,omitempty"`
	// Default queue name.
	Queue *string `protobuf:"bytes,3,opt,name=queue,proto3,oneof" json:"queue,omitempty"`
	// Virtual host to connect to.
	Vhost *string `protobuf:"bytes,4,opt,name=vhost,proto3,oneof" json:"vhost,omitempty"`
	// Username for authentication.
	Username *string `protobuf:"bytes,5,opt,name=username,proto3,oneof" json:"username,omitempty"`
	// Password for authentication.
	Password *string `protobuf:"bytes,6,opt,name=password,proto3,oneof" json:"password,omitempty"`
	// Whether to enable TLS.
	TlsEnabled *bool `protobuf:"varint,7,opt,name=tls_enabled,json=tlsEnabled,proto3,oneof" json:"tls_enabled,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,8,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,9,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,10,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 136-byte string literal not displayed */
	// Consumer tag for consumers.
	ConsumerTag *string `protobuf:"bytes,12,opt,name=consumer_tag,json=consumerTag,proto3,oneof" json:"consumer_tag,omitempty"`
	// Qos prefetch count.
	QosPrefetchCount *int32 `protobuf:"varint,13,opt,name=qos_prefetch_count,json=qosPrefetchCount,proto3,oneof" json:"qos_prefetch_count,omitempty"`
	// Qos prefetch size.
	QosPrefetchSize *int32 `protobuf:"varint,14,opt,name=qos_prefetch_size,json=qosPrefetchSize,proto3,oneof" json:"qos_prefetch_size,omitempty"`
	// Qos global.
	QosGlobal *bool `protobuf:"varint,15,opt,name=qos_global,json=qosGlobal,proto3,oneof" json:"qos_global,omitempty"`
	// Whether to auto-ack messages.
	AutoAck *bool `protobuf:"varint,16,opt,name=auto_ack,json=autoAck,proto3,oneof" json:"auto_ack,omitempty"`
	// Whether to publish messages as persistent.
	PersistentMessages *bool `protobuf:"varint,17,opt,name=persistent_messages,json=persistentMessages,proto3,oneof" json:"persistent_messages,omitempty"`
	// contains filtered or unexported fields
}

RabbitMQConfig defines the configuration for a RabbitMQ message queue.

func (*RabbitMQConfig) Descriptor deprecated 

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

Deprecated: Use RabbitMQConfig.ProtoReflect.Descriptor instead.

func (*RabbitMQConfig) GetAutoAck 

func (x *RabbitMQConfig) GetAutoAck() bool

func (*RabbitMQConfig) GetConsumerTag 

func (x *RabbitMQConfig) GetConsumerTag() string

func (*RabbitMQConfig) GetExchange 

func (x *RabbitMQConfig) GetExchange() string

func (*RabbitMQConfig) GetPassword 

func (x *RabbitMQConfig) GetPassword() string

func (*RabbitMQConfig) GetPersistentMessages 

func (x *RabbitMQConfig) GetPersistentMessages() bool

func (*RabbitMQConfig) GetQosGlobal 

func (x *RabbitMQConfig) GetQosGlobal() bool

func (*RabbitMQConfig) GetQosPrefetchCount 

func (x *RabbitMQConfig) GetQosPrefetchCount() int32

func (*RabbitMQConfig) GetQosPrefetchSize 

func (x *RabbitMQConfig) GetQosPrefetchSize() int32

func (*RabbitMQConfig) GetQueue 

func (x *RabbitMQConfig) GetQueue() string

func (*RabbitMQConfig) GetTlsCaCertFile 

func (x *RabbitMQConfig) GetTlsCaCertFile() string

func (*RabbitMQConfig) GetTlsClientCertFile 

func (x *RabbitMQConfig) GetTlsClientCertFile() string

func (*RabbitMQConfig) GetTlsClientKeyFile 

func (x *RabbitMQConfig) GetTlsClientKeyFile() string

func (*RabbitMQConfig) GetTlsEnabled 

func (x *RabbitMQConfig) GetTlsEnabled() bool

func (*RabbitMQConfig) GetTlsInsecureSkipVerify 

func (x *RabbitMQConfig) GetTlsInsecureSkipVerify() bool

func (*RabbitMQConfig) GetUri 

func (x *RabbitMQConfig) GetUri() string

func (*RabbitMQConfig) GetUsername 

func (x *RabbitMQConfig) GetUsername() string

func (*RabbitMQConfig) GetVhost 

func (x *RabbitMQConfig) GetVhost() string

func (*RabbitMQConfig) ProtoMessage 

func (*RabbitMQConfig) ProtoMessage()

func (*RabbitMQConfig) ProtoReflect 

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

func (*RabbitMQConfig) Reset 

func (x *RabbitMQConfig) Reset()

func (*RabbitMQConfig) String 

func (x *RabbitMQConfig) String() string

func (*RabbitMQConfig) Validate 

func (m *RabbitMQConfig) Validate() error

Validate checks the field values on RabbitMQConfig 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 (*RabbitMQConfig) ValidateAll 

func (m *RabbitMQConfig) ValidateAll() error

ValidateAll checks the field values on RabbitMQConfig 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 RabbitMQConfigMultiError, or nil if none found.

type RabbitMQConfigMultiError 

type RabbitMQConfigMultiError []error

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

func (RabbitMQConfigMultiError) AllErrors 

func (m RabbitMQConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RabbitMQConfigMultiError) Error 

func (m RabbitMQConfigMultiError) Error() string

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

type RabbitMQConfigValidationError 

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

RabbitMQConfigValidationError is the validation error returned by RabbitMQConfig.Validate if the designated constraints aren't met.

func (RabbitMQConfigValidationError) Cause 

func (e RabbitMQConfigValidationError) Cause() error

Cause function returns cause value.

func (RabbitMQConfigValidationError) Error 

func (e RabbitMQConfigValidationError) Error() string

Error satisfies the builtin error interface

func (RabbitMQConfigValidationError) ErrorName 

func (e RabbitMQConfigValidationError) ErrorName() string

ErrorName returns error name.

func (RabbitMQConfigValidationError) Field 

func (e RabbitMQConfigValidationError) Field() string

Field function returns field value.

func (RabbitMQConfigValidationError) Key 

func (e RabbitMQConfigValidationError) Key() bool

Key function returns key value.

func (RabbitMQConfigValidationError) Reason 

func (e RabbitMQConfigValidationError) Reason() string

Reason function returns reason value.

type RedisMqConfig 

type RedisMqConfig struct {

	// Redis address (e.g., "localhost:6379").
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Redis password.
	Password *string `protobuf:"bytes,2,opt,name=password,proto3,oneof" json:"password,omitempty"`
	// Redis DB number.
	Db *int32 `protobuf:"varint,3,opt,name=db,proto3,oneof" json:"db,omitempty"`
	// Default channel or list key for Pub/Sub or List operations.
	ChannelOrListKey string `protobuf:"bytes,4,opt,name=channel_or_list_key,json=channelOrListKey,proto3" json:"channel_or_list_key,omitempty"`
	// Whether to use Redis Pub/Sub (true) or List (false) for messaging.
	UsePubsub *bool `protobuf:"varint,5,opt,name=use_pubsub,json=usePubsub,proto3,oneof" json:"use_pubsub,omitempty"`
	// Max number of messages to block for when using List as a queue.
	ListBlockTimeoutSeconds *int32 `` /* 141-byte string literal not displayed */
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,7,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,8,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,9,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

RedisMqConfig defines the configuration for Redis used as a message queue (Pub/Sub or List).

func (*RedisMqConfig) Descriptor deprecated 

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

Deprecated: Use RedisMqConfig.ProtoReflect.Descriptor instead.

func (*RedisMqConfig) GetAddress 

func (x *RedisMqConfig) GetAddress() string

func (*RedisMqConfig) GetChannelOrListKey 

func (x *RedisMqConfig) GetChannelOrListKey() string

func (*RedisMqConfig) GetDb 

func (x *RedisMqConfig) GetDb() int32

func (*RedisMqConfig) GetListBlockTimeoutSeconds 

func (x *RedisMqConfig) GetListBlockTimeoutSeconds() int32

func (*RedisMqConfig) GetPassword 

func (x *RedisMqConfig) GetPassword() string

func (*RedisMqConfig) GetTlsCaCertFile 

func (x *RedisMqConfig) GetTlsCaCertFile() string

func (*RedisMqConfig) GetTlsClientCertFile 

func (x *RedisMqConfig) GetTlsClientCertFile() string

func (*RedisMqConfig) GetTlsClientKeyFile 

func (x *RedisMqConfig) GetTlsClientKeyFile() string

func (*RedisMqConfig) GetTlsInsecureSkipVerify 

func (x *RedisMqConfig) GetTlsInsecureSkipVerify() bool

func (*RedisMqConfig) GetUsePubsub 

func (x *RedisMqConfig) GetUsePubsub() bool

func (*RedisMqConfig) ProtoMessage 

func (*RedisMqConfig) ProtoMessage()

func (*RedisMqConfig) ProtoReflect 

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

func (*RedisMqConfig) Reset 

func (x *RedisMqConfig) Reset()

func (*RedisMqConfig) String 

func (x *RedisMqConfig) String() string

func (*RedisMqConfig) Validate 

func (m *RedisMqConfig) Validate() error

Validate checks the field values on RedisMqConfig 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 (*RedisMqConfig) ValidateAll 

func (m *RedisMqConfig) ValidateAll() error

ValidateAll checks the field values on RedisMqConfig 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 RedisMqConfigMultiError, or nil if none found.

type RedisMqConfigMultiError 

type RedisMqConfigMultiError []error

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

func (RedisMqConfigMultiError) AllErrors 

func (m RedisMqConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RedisMqConfigMultiError) Error 

func (m RedisMqConfigMultiError) Error() string

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

type RedisMqConfigValidationError 

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

RedisMqConfigValidationError is the validation error returned by RedisMqConfig.Validate if the designated constraints aren't met.

func (RedisMqConfigValidationError) Cause 

func (e RedisMqConfigValidationError) Cause() error

Cause function returns cause value.

func (RedisMqConfigValidationError) Error 

func (e RedisMqConfigValidationError) Error() string

Error satisfies the builtin error interface

func (RedisMqConfigValidationError) ErrorName 

func (e RedisMqConfigValidationError) ErrorName() string

ErrorName returns error name.

func (RedisMqConfigValidationError) Field 

func (e RedisMqConfigValidationError) Field() string

Field function returns field value.

func (RedisMqConfigValidationError) Key 

func (e RedisMqConfigValidationError) Key() bool

Key function returns key value.

func (RedisMqConfigValidationError) Reason 

func (e RedisMqConfigValidationError) Reason() string

Reason function returns reason value.

type RocketMQConfig 

type RocketMQConfig struct {

	// List of NameServer addresses (e.g., "localhost:9876").
	NameServerAddresses []string `protobuf:"bytes,1,rep,name=name_server_addresses,json=nameServerAddresses,proto3" json:"name_server_addresses,omitempty"`
	// Default topic for publishing or subscribing.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Consumer group ID for consumers.
	ConsumerGroupId *string `protobuf:"bytes,3,opt,name=consumer_group_id,json=consumerGroupId,proto3,oneof" json:"consumer_group_id,omitempty"`
	// Producer group ID for producers.
	ProducerGroupId *string `protobuf:"bytes,4,opt,name=producer_group_id,json=producerGroupId,proto3,oneof" json:"producer_group_id,omitempty"`
	// Access key for authentication.
	AccessKey *string `protobuf:"bytes,5,opt,name=access_key,json=accessKey,proto3,oneof" json:"access_key,omitempty"`
	// Secret key for authentication.
	SecretKey *string `protobuf:"bytes,6,opt,name=secret_key,json=secretKey,proto3,oneof" json:"secret_key,omitempty"`
	// Namespace for message isolation.
	Namespace *string `protobuf:"bytes,7,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// Send message timeout in milliseconds.
	SendTimeoutMs *int32 `protobuf:"varint,8,opt,name=send_timeout_ms,json=sendTimeoutMs,proto3,oneof" json:"send_timeout_ms,omitempty"`
	// Consume message timeout in milliseconds.
	ConsumeTimeoutMs *int32 `protobuf:"varint,9,opt,name=consume_timeout_ms,json=consumeTimeoutMs,proto3,oneof" json:"consume_timeout_ms,omitempty"`
	// Whether to enable TLS.
	TlsEnabled *bool `protobuf:"varint,10,opt,name=tls_enabled,json=tlsEnabled,proto3,oneof" json:"tls_enabled,omitempty"`
	// contains filtered or unexported fields
}

RocketMQConfig defines the configuration for a RocketMQ message queue.

func (*RocketMQConfig) Descriptor deprecated 

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

Deprecated: Use RocketMQConfig.ProtoReflect.Descriptor instead.

func (*RocketMQConfig) GetAccessKey 

func (x *RocketMQConfig) GetAccessKey() string

func (*RocketMQConfig) GetConsumeTimeoutMs 

func (x *RocketMQConfig) GetConsumeTimeoutMs() int32

func (*RocketMQConfig) GetConsumerGroupId 

func (x *RocketMQConfig) GetConsumerGroupId() string

func (*RocketMQConfig) GetNameServerAddresses 

func (x *RocketMQConfig) GetNameServerAddresses() []string

func (*RocketMQConfig) GetNamespace 

func (x *RocketMQConfig) GetNamespace() string

func (*RocketMQConfig) GetProducerGroupId 

func (x *RocketMQConfig) GetProducerGroupId() string

func (*RocketMQConfig) GetSecretKey 

func (x *RocketMQConfig) GetSecretKey() string

func (*RocketMQConfig) GetSendTimeoutMs 

func (x *RocketMQConfig) GetSendTimeoutMs() int32

func (*RocketMQConfig) GetTlsEnabled 

func (x *RocketMQConfig) GetTlsEnabled() bool

func (*RocketMQConfig) GetTopic 

func (x *RocketMQConfig) GetTopic() string

func (*RocketMQConfig) ProtoMessage 

func (*RocketMQConfig) ProtoMessage()

func (*RocketMQConfig) ProtoReflect 

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

func (*RocketMQConfig) Reset 

func (x *RocketMQConfig) Reset()

func (*RocketMQConfig) String 

func (x *RocketMQConfig) String() string

func (*RocketMQConfig) Validate 

func (m *RocketMQConfig) Validate() error

Validate checks the field values on RocketMQConfig 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 (*RocketMQConfig) ValidateAll 

func (m *RocketMQConfig) ValidateAll() error

ValidateAll checks the field values on RocketMQConfig 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 RocketMQConfigMultiError, or nil if none found.

type RocketMQConfigMultiError 

type RocketMQConfigMultiError []error

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

func (RocketMQConfigMultiError) AllErrors 

func (m RocketMQConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RocketMQConfigMultiError) Error 

func (m RocketMQConfigMultiError) Error() string

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

type RocketMQConfigValidationError 

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

RocketMQConfigValidationError is the validation error returned by RocketMQConfig.Validate if the designated constraints aren't met.

func (RocketMQConfigValidationError) Cause 

func (e RocketMQConfigValidationError) Cause() error

Cause function returns cause value.

func (RocketMQConfigValidationError) Error 

func (e RocketMQConfigValidationError) Error() string

Error satisfies the builtin error interface

func (RocketMQConfigValidationError) ErrorName 

func (e RocketMQConfigValidationError) ErrorName() string

ErrorName returns error name.

func (RocketMQConfigValidationError) Field 

func (e RocketMQConfigValidationError) Field() string

Field function returns field value.

func (RocketMQConfigValidationError) Key 

func (e RocketMQConfigValidationError) Key() bool

Key function returns key value.

func (RocketMQConfigValidationError) Reason 

func (e RocketMQConfigValidationError) Reason() string

Reason function returns reason value.

type SqsConfig 

type SqsConfig struct {

	// AWS region (e.g., "us-east-1").
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// AWS Access Key ID.
	AccessKeyId *string `protobuf:"bytes,2,opt,name=access_key_id,json=accessKeyId,proto3,oneof" json:"access_key_id,omitempty"`
	// AWS Secret Access Key.
	SecretAccessKey *string `protobuf:"bytes,3,opt,name=secret_access_key,json=secretAccessKey,proto3,oneof" json:"secret_access_key,omitempty"`
	// AWS Session Token (for temporary credentials).
	SessionToken *string `protobuf:"bytes,4,opt,name=session_token,json=sessionToken,proto3,oneof" json:"session_token,omitempty"`
	// SQS queue URL.
	QueueUrl string `protobuf:"bytes,5,opt,name=queue_url,json=queueUrl,proto3" json:"queue_url,omitempty"`
	// Max number of messages to receive in one request.
	MaxNumberOfMessages *int32 `` /* 129-byte string literal not displayed */
	// How long to wait for messages (in seconds) before returning.
	WaitTimeSeconds *int32 `protobuf:"varint,7,opt,name=wait_time_seconds,json=waitTimeSeconds,proto3,oneof" json:"wait_time_seconds,omitempty"`
	// Message visibility timeout in seconds.
	VisibilityTimeoutSeconds *int32 `` /* 142-byte string literal not displayed */
	// Whether to use long polling.
	LongPollingEnabled *bool `protobuf:"varint,9,opt,name=long_polling_enabled,json=longPollingEnabled,proto3,oneof" json:"long_polling_enabled,omitempty"`
	// contains filtered or unexported fields
}

SqsConfig defines the configuration for an AWS SQS message queue.

func (*SqsConfig) Descriptor deprecated 

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

Deprecated: Use SqsConfig.ProtoReflect.Descriptor instead.

func (*SqsConfig) GetAccessKeyId 

func (x *SqsConfig) GetAccessKeyId() string

func (*SqsConfig) GetLongPollingEnabled 

func (x *SqsConfig) GetLongPollingEnabled() bool

func (*SqsConfig) GetMaxNumberOfMessages 

func (x *SqsConfig) GetMaxNumberOfMessages() int32

func (*SqsConfig) GetQueueUrl 

func (x *SqsConfig) GetQueueUrl() string

func (*SqsConfig) GetRegion 

func (x *SqsConfig) GetRegion() string

func (*SqsConfig) GetSecretAccessKey 

func (x *SqsConfig) GetSecretAccessKey() string

func (*SqsConfig) GetSessionToken 

func (x *SqsConfig) GetSessionToken() string

func (*SqsConfig) GetVisibilityTimeoutSeconds 

func (x *SqsConfig) GetVisibilityTimeoutSeconds() int32

func (*SqsConfig) GetWaitTimeSeconds 

func (x *SqsConfig) GetWaitTimeSeconds() int32

func (*SqsConfig) ProtoMessage 

func (*SqsConfig) ProtoMessage()

func (*SqsConfig) ProtoReflect 

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

func (*SqsConfig) Reset 

func (x *SqsConfig) Reset()

func (*SqsConfig) String 

func (x *SqsConfig) String() string

func (*SqsConfig) Validate 

func (m *SqsConfig) Validate() error

Validate checks the field values on SqsConfig 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 (*SqsConfig) ValidateAll 

func (m *SqsConfig) ValidateAll() error

ValidateAll checks the field values on SqsConfig 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 SqsConfigMultiError, or nil if none found.

type SqsConfigMultiError 

type SqsConfigMultiError []error

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

func (SqsConfigMultiError) AllErrors 

func (m SqsConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SqsConfigMultiError) Error 

func (m SqsConfigMultiError) Error() string

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

type SqsConfigValidationError 

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

SqsConfigValidationError is the validation error returned by SqsConfig.Validate if the designated constraints aren't met.

func (SqsConfigValidationError) Cause 

func (e SqsConfigValidationError) Cause() error

Cause function returns cause value.

func (SqsConfigValidationError) Error 

func (e SqsConfigValidationError) Error() string

Error satisfies the builtin error interface

func (SqsConfigValidationError) ErrorName 

func (e SqsConfigValidationError) ErrorName() string

ErrorName returns error name.

func (SqsConfigValidationError) Field 

func (e SqsConfigValidationError) Field() string

Field function returns field value.

func (SqsConfigValidationError) Key 

func (e SqsConfigValidationError) Key() bool

Key function returns key value.

func (SqsConfigValidationError) Reason 

func (e SqsConfigValidationError) Reason() string

Reason function returns reason value.

type StompConfig 

type StompConfig struct {

	// STOMP broker address (e.g., "localhost:61613").
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Username for authentication.
	Username *string `protobuf:"bytes,2,opt,name=username,proto3,oneof" json:"username,omitempty"`
	// Password for authentication.
	Password *string `protobuf:"bytes,3,opt,name=password,proto3,oneof" json:"password,omitempty"`
	// Default destination for sending or subscribing.
	Destination string `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"`
	// Whether to enable TLS.
	TlsEnabled *bool `protobuf:"varint,5,opt,name=tls_enabled,json=tlsEnabled,proto3,oneof" json:"tls_enabled,omitempty"`
	// Path to TLS client certificate file.
	TlsClientCertFile *string `protobuf:"bytes,6,opt,name=tls_client_cert_file,json=tlsClientCertFile,proto3,oneof" json:"tls_client_cert_file,omitempty"`
	// Path to TLS client key file.
	TlsClientKeyFile *string `protobuf:"bytes,7,opt,name=tls_client_key_file,json=tlsClientKeyFile,proto3,oneof" json:"tls_client_key_file,omitempty"`
	// Path to TLS CA certificate file.
	TlsCaCertFile *string `protobuf:"bytes,8,opt,name=tls_ca_cert_file,json=tlsCaCertFile,proto3,oneof" json:"tls_ca_cert_file,omitempty"`
	// Whether to enable TLS insecure skip verify.
	TlsInsecureSkipVerify *bool `` /* 135-byte string literal not displayed */
	// Heartbeat interval in milliseconds.
	HeartbeatIntervalMs *int32 `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

StompConfig defines the configuration for a STOMP message queue.

func (*StompConfig) Descriptor deprecated 

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

Deprecated: Use StompConfig.ProtoReflect.Descriptor instead.

func (*StompConfig) GetAddress 

func (x *StompConfig) GetAddress() string

func (*StompConfig) GetDestination 

func (x *StompConfig) GetDestination() string

func (*StompConfig) GetHeartbeatIntervalMs 

func (x *StompConfig) GetHeartbeatIntervalMs() int32

func (*StompConfig) GetPassword 

func (x *StompConfig) GetPassword() string

func (*StompConfig) GetTlsCaCertFile 

func (x *StompConfig) GetTlsCaCertFile() string

func (*StompConfig) GetTlsClientCertFile 

func (x *StompConfig) GetTlsClientCertFile() string

func (*StompConfig) GetTlsClientKeyFile 

func (x *StompConfig) GetTlsClientKeyFile() string

func (*StompConfig) GetTlsEnabled 

func (x *StompConfig) GetTlsEnabled() bool

func (*StompConfig) GetTlsInsecureSkipVerify 

func (x *StompConfig) GetTlsInsecureSkipVerify() bool

func (*StompConfig) GetUsername 

func (x *StompConfig) GetUsername() string

func (*StompConfig) ProtoMessage 

func (*StompConfig) ProtoMessage()

func (*StompConfig) ProtoReflect 

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

func (*StompConfig) Reset 

func (x *StompConfig) Reset()

func (*StompConfig) String 

func (x *StompConfig) String() string

func (*StompConfig) Validate 

func (m *StompConfig) Validate() error

Validate checks the field values on StompConfig 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 (*StompConfig) ValidateAll 

func (m *StompConfig) ValidateAll() error

ValidateAll checks the field values on StompConfig 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 StompConfigMultiError, or nil if none found.

type StompConfigMultiError 

type StompConfigMultiError []error

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

func (StompConfigMultiError) AllErrors 

func (m StompConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StompConfigMultiError) Error 

func (m StompConfigMultiError) Error() string

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

type StompConfigValidationError 

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

StompConfigValidationError is the validation error returned by StompConfig.Validate if the designated constraints aren't met.

func (StompConfigValidationError) Cause 

func (e StompConfigValidationError) Cause() error

Cause function returns cause value.

func (StompConfigValidationError) Error 

func (e StompConfigValidationError) Error() string

Error satisfies the builtin error interface

func (StompConfigValidationError) ErrorName 

func (e StompConfigValidationError) ErrorName() string

ErrorName returns error name.

func (StompConfigValidationError) Field 

func (e StompConfigValidationError) Field() string

Field function returns field value.

func (StompConfigValidationError) Key 

func (e StompConfigValidationError) Key() bool

Key function returns key value.

func (StompConfigValidationError) Reason 

func (e StompConfigValidationError) 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.