Versions in this module Expand all Collapse all v0 v0.3.8 Jul 6, 2026 v0.3.2 May 13, 2026 Changes in this version + var AckPolicy_name = map[int32]string + var AckPolicy_value = map[string]int32 + var DeliverPolicy_name = map[int32]string + var DeliverPolicy_value = map[string]int32 + var File_eventbus_proto protoreflect.FileDescriptor + var KafkaSaslMechanism_name = map[int32]string + var KafkaSaslMechanism_value = map[string]int32 + var KafkaSecurityProtocol_name = map[int32]string + var KafkaSecurityProtocol_value = map[string]int32 + var RetentionPolicy_name = map[int32]string + var RetentionPolicy_value = map[string]int32 + type AckPolicy int32 + const AckPolicy_ACK_POLICY_ALL + const AckPolicy_ACK_POLICY_EXPLICIT + const AckPolicy_ACK_POLICY_NONE + const AckPolicy_ACK_POLICY_UNSPECIFIED + func (AckPolicy) Descriptor() protoreflect.EnumDescriptor + func (AckPolicy) EnumDescriptor() ([]byte, []int) + func (AckPolicy) Type() protoreflect.EnumType + func (x AckPolicy) Enum() *AckPolicy + func (x AckPolicy) Number() protoreflect.EnumNumber + func (x AckPolicy) String() string + type AckRequest struct + AckToken string + BrokerRef string + func (*AckRequest) Descriptor() ([]byte, []int) + func (*AckRequest) ProtoMessage() + func (x *AckRequest) GetAckToken() string + func (x *AckRequest) GetBrokerRef() string + func (x *AckRequest) ProtoReflect() protoreflect.Message + func (x *AckRequest) Reset() + func (x *AckRequest) String() string + type AckResponse struct + func (*AckResponse) Descriptor() ([]byte, []int) + func (*AckResponse) ProtoMessage() + func (x *AckResponse) ProtoReflect() protoreflect.Message + func (x *AckResponse) Reset() + func (x *AckResponse) String() string + type ClusterConfig struct + BrokerTarget string + DeployTarget string + Dsn string + Jetstream *JetStreamConfig + Kafka *KafkaConfig + Kinesis *KinesisConfig + Limits *ResourceLimits + MaxConns int32 + PollInterval string + Provider string + Replicas int32 + Version string + func (*ClusterConfig) Descriptor() ([]byte, []int) + func (*ClusterConfig) ProtoMessage() + func (x *ClusterConfig) GetBrokerTarget() string + func (x *ClusterConfig) GetDeployTarget() string + func (x *ClusterConfig) GetDsn() string + func (x *ClusterConfig) GetJetstream() *JetStreamConfig + func (x *ClusterConfig) GetKafka() *KafkaConfig + func (x *ClusterConfig) GetKinesis() *KinesisConfig + func (x *ClusterConfig) GetLimits() *ResourceLimits + func (x *ClusterConfig) GetMaxConns() int32 + func (x *ClusterConfig) GetPollInterval() string + func (x *ClusterConfig) GetProvider() string + func (x *ClusterConfig) GetReplicas() int32 + func (x *ClusterConfig) GetVersion() string + func (x *ClusterConfig) ProtoReflect() protoreflect.Message + func (x *ClusterConfig) Reset() + func (x *ClusterConfig) String() string + type ConsumeRequest struct + BatchSize int32 + BrokerRef string + Consumer string + MaxWait *durationpb.Duration + func (*ConsumeRequest) Descriptor() ([]byte, []int) + func (*ConsumeRequest) ProtoMessage() + func (x *ConsumeRequest) GetBatchSize() int32 + func (x *ConsumeRequest) GetBrokerRef() string + func (x *ConsumeRequest) GetConsumer() string + func (x *ConsumeRequest) GetMaxWait() *durationpb.Duration + func (x *ConsumeRequest) ProtoReflect() protoreflect.Message + func (x *ConsumeRequest) Reset() + func (x *ConsumeRequest) String() string + type ConsumeResponse struct + Messages []*Message + func (*ConsumeResponse) Descriptor() ([]byte, []int) + func (*ConsumeResponse) ProtoMessage() + func (x *ConsumeResponse) GetMessages() []*Message + func (x *ConsumeResponse) ProtoReflect() protoreflect.Message + func (x *ConsumeResponse) Reset() + func (x *ConsumeResponse) String() string + type ConsumerConfig struct + AckPolicy AckPolicy + BrokerRef string + DeliverPolicy DeliverPolicy + FilterSubject string + MaxDeliver int32 + Name string + StreamName string + func (*ConsumerConfig) Descriptor() ([]byte, []int) + func (*ConsumerConfig) ProtoMessage() + func (x *ConsumerConfig) GetAckPolicy() AckPolicy + func (x *ConsumerConfig) GetBrokerRef() string + func (x *ConsumerConfig) GetDeliverPolicy() DeliverPolicy + func (x *ConsumerConfig) GetFilterSubject() string + func (x *ConsumerConfig) GetMaxDeliver() int32 + func (x *ConsumerConfig) GetName() string + func (x *ConsumerConfig) GetStreamName() string + func (x *ConsumerConfig) ProtoReflect() protoreflect.Message + func (x *ConsumerConfig) Reset() + func (x *ConsumerConfig) String() string + type DeliverPolicy int32 + const DeliverPolicy_DELIVER_POLICY_ALL + const DeliverPolicy_DELIVER_POLICY_BY_START_SEQUENCE + const DeliverPolicy_DELIVER_POLICY_BY_START_TIME + const DeliverPolicy_DELIVER_POLICY_LAST + const DeliverPolicy_DELIVER_POLICY_NEW + const DeliverPolicy_DELIVER_POLICY_UNSPECIFIED + func (DeliverPolicy) Descriptor() protoreflect.EnumDescriptor + func (DeliverPolicy) EnumDescriptor() ([]byte, []int) + func (DeliverPolicy) Type() protoreflect.EnumType + func (x DeliverPolicy) Enum() *DeliverPolicy + func (x DeliverPolicy) Number() protoreflect.EnumNumber + func (x DeliverPolicy) String() string + type JetStreamConfig struct + Enabled bool + MaxAge *durationpb.Duration + MaxMemoryBytes int64 + MaxStorageBytes int64 + func (*JetStreamConfig) Descriptor() ([]byte, []int) + func (*JetStreamConfig) ProtoMessage() + func (x *JetStreamConfig) GetEnabled() bool + func (x *JetStreamConfig) GetMaxAge() *durationpb.Duration + func (x *JetStreamConfig) GetMaxMemoryBytes() int64 + func (x *JetStreamConfig) GetMaxStorageBytes() int64 + func (x *JetStreamConfig) ProtoReflect() protoreflect.Message + func (x *JetStreamConfig) Reset() + func (x *JetStreamConfig) String() string + type KafkaConfig struct + BootstrapServers string + DefaultReplicationFactor int32 + MinInsyncReplicas int32 + SaslMechanism KafkaSaslMechanism + SecurityProtocol KafkaSecurityProtocol + func (*KafkaConfig) Descriptor() ([]byte, []int) + func (*KafkaConfig) ProtoMessage() + func (x *KafkaConfig) GetBootstrapServers() string + func (x *KafkaConfig) GetDefaultReplicationFactor() int32 + func (x *KafkaConfig) GetMinInsyncReplicas() int32 + func (x *KafkaConfig) GetSaslMechanism() KafkaSaslMechanism + func (x *KafkaConfig) GetSecurityProtocol() KafkaSecurityProtocol + func (x *KafkaConfig) ProtoReflect() protoreflect.Message + func (x *KafkaConfig) Reset() + func (x *KafkaConfig) String() string + type KafkaSaslMechanism int32 + const KafkaSaslMechanism_KAFKA_SASL_MECHANISM_PLAIN + const KafkaSaslMechanism_KAFKA_SASL_MECHANISM_SCRAM_SHA_256 + const KafkaSaslMechanism_KAFKA_SASL_MECHANISM_SCRAM_SHA_512 + const KafkaSaslMechanism_KAFKA_SASL_MECHANISM_UNSPECIFIED + func (KafkaSaslMechanism) Descriptor() protoreflect.EnumDescriptor + func (KafkaSaslMechanism) EnumDescriptor() ([]byte, []int) + func (KafkaSaslMechanism) Type() protoreflect.EnumType + func (x KafkaSaslMechanism) Enum() *KafkaSaslMechanism + func (x KafkaSaslMechanism) Number() protoreflect.EnumNumber + func (x KafkaSaslMechanism) String() string + type KafkaSecurityProtocol int32 + const KafkaSecurityProtocol_KAFKA_SECURITY_PROTOCOL_PLAINTEXT + const KafkaSecurityProtocol_KAFKA_SECURITY_PROTOCOL_SASL_PLAINTEXT + const KafkaSecurityProtocol_KAFKA_SECURITY_PROTOCOL_SASL_SSL + const KafkaSecurityProtocol_KAFKA_SECURITY_PROTOCOL_SSL + const KafkaSecurityProtocol_KAFKA_SECURITY_PROTOCOL_UNSPECIFIED + func (KafkaSecurityProtocol) Descriptor() protoreflect.EnumDescriptor + func (KafkaSecurityProtocol) EnumDescriptor() ([]byte, []int) + func (KafkaSecurityProtocol) Type() protoreflect.EnumType + func (x KafkaSecurityProtocol) Enum() *KafkaSecurityProtocol + func (x KafkaSecurityProtocol) Number() protoreflect.EnumNumber + func (x KafkaSecurityProtocol) String() string + type KinesisConfig struct + Region string + RetentionPeriodHours int32 + ShardCount int32 + func (*KinesisConfig) Descriptor() ([]byte, []int) + func (*KinesisConfig) ProtoMessage() + func (x *KinesisConfig) GetRegion() string + func (x *KinesisConfig) GetRetentionPeriodHours() int32 + func (x *KinesisConfig) GetShardCount() int32 + func (x *KinesisConfig) ProtoReflect() protoreflect.Message + func (x *KinesisConfig) Reset() + func (x *KinesisConfig) String() string + type Message struct + AckToken string + Headers map[string]string + Payload []byte + PublishedAt string + Sequence string + Subject string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetAckToken() string + func (x *Message) GetHeaders() map[string]string + func (x *Message) GetPayload() []byte + func (x *Message) GetPublishedAt() string + func (x *Message) GetSequence() string + func (x *Message) GetSubject() string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type PublishRequest struct + BrokerRef string + CorrelationId string + Headers map[string]string + Payload []byte + Subject string + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (x *PublishRequest) GetBrokerRef() string + func (x *PublishRequest) GetCorrelationId() string + func (x *PublishRequest) GetHeaders() map[string]string + func (x *PublishRequest) GetPayload() []byte + func (x *PublishRequest) GetSubject() string + func (x *PublishRequest) ProtoReflect() protoreflect.Message + func (x *PublishRequest) Reset() + func (x *PublishRequest) String() string + type PublishResponse struct + AckedAt string + Sequence string + func (*PublishResponse) Descriptor() ([]byte, []int) + func (*PublishResponse) ProtoMessage() + func (x *PublishResponse) GetAckedAt() string + func (x *PublishResponse) GetSequence() string + func (x *PublishResponse) ProtoReflect() protoreflect.Message + func (x *PublishResponse) Reset() + func (x *PublishResponse) String() string + type ResourceLimits struct + Cpu string + Memory string + Storage string + func (*ResourceLimits) Descriptor() ([]byte, []int) + func (*ResourceLimits) ProtoMessage() + func (x *ResourceLimits) GetCpu() string + func (x *ResourceLimits) GetMemory() string + func (x *ResourceLimits) GetStorage() string + func (x *ResourceLimits) ProtoReflect() protoreflect.Message + func (x *ResourceLimits) Reset() + func (x *ResourceLimits) String() string + type RetentionPolicy int32 + const RetentionPolicy_RETENTION_POLICY_INTEREST + const RetentionPolicy_RETENTION_POLICY_LIMITS + const RetentionPolicy_RETENTION_POLICY_UNSPECIFIED + const RetentionPolicy_RETENTION_POLICY_WORKQUEUE + func (RetentionPolicy) Descriptor() protoreflect.EnumDescriptor + func (RetentionPolicy) EnumDescriptor() ([]byte, []int) + func (RetentionPolicy) Type() protoreflect.EnumType + func (x RetentionPolicy) Enum() *RetentionPolicy + func (x RetentionPolicy) Number() protoreflect.EnumNumber + func (x RetentionPolicy) String() string + type StreamConfig struct + AckWait *durationpb.Duration + BrokerRef string + MaxAge *durationpb.Duration + MaxBytes int64 + Name string + NumReplicas int32 + RetentionPolicy RetentionPolicy + Subjects []string + func (*StreamConfig) Descriptor() ([]byte, []int) + func (*StreamConfig) ProtoMessage() + func (x *StreamConfig) GetAckWait() *durationpb.Duration + func (x *StreamConfig) GetBrokerRef() string + func (x *StreamConfig) GetMaxAge() *durationpb.Duration + func (x *StreamConfig) GetMaxBytes() int64 + func (x *StreamConfig) GetName() string + func (x *StreamConfig) GetNumReplicas() int32 + func (x *StreamConfig) GetRetentionPolicy() RetentionPolicy + func (x *StreamConfig) GetSubjects() []string + func (x *StreamConfig) ProtoReflect() protoreflect.Message + func (x *StreamConfig) Reset() + func (x *StreamConfig) String() string
Go to main page