Versions in this module Expand all Collapse all v0 v0.0.13 Nov 19, 2022 v0.0.12 Nov 19, 2022 v0.0.11 Nov 19, 2022 v0.0.10 Nov 18, 2022 v0.0.9 Nov 7, 2022 v0.0.8 Nov 7, 2022 v0.0.7 Nov 3, 2022 v0.0.6 Nov 3, 2022 Changes in this version type ProducerConf + Group string + func (x *ProducerConf) GetGroup() string v0.0.5 Nov 2, 2022 v0.0.4 Nov 1, 2022 v0.0.3 Nov 1, 2022 v0.0.2 Oct 30, 2022 Changes in this version + type ConsumerConf struct + BootstrapServers string + Group string + Sasl *SASL + SecurityProtocol string + Ssl *SSL + Topics []string + func (*ConsumerConf) Descriptor() ([]byte, []int) + func (*ConsumerConf) ProtoMessage() + func (m *ConsumerConf) Validate() error + func (m *ConsumerConf) ValidateAll() error + func (x *ConsumerConf) GetBootstrapServers() string + func (x *ConsumerConf) GetGroup() string + func (x *ConsumerConf) GetSasl() *SASL + func (x *ConsumerConf) GetSecurityProtocol() string + func (x *ConsumerConf) GetSsl() *SSL + func (x *ConsumerConf) GetTopics() []string + func (x *ConsumerConf) ProtoReflect() protoreflect.Message + func (x *ConsumerConf) Reset() + func (x *ConsumerConf) String() string + type ConsumerConfMultiError []error + func (m ConsumerConfMultiError) AllErrors() []error + func (m ConsumerConfMultiError) Error() string + type ConsumerConfValidationError struct + func (e ConsumerConfValidationError) Cause() error + func (e ConsumerConfValidationError) Error() string + func (e ConsumerConfValidationError) ErrorName() string + func (e ConsumerConfValidationError) Field() string + func (e ConsumerConfValidationError) Key() bool + func (e ConsumerConfValidationError) Reason() string + type ProducerConf struct + Acks int32 + BootstrapServers string + Partitioner string + RequestRequiredAcks int32 + RequestTimeoutMs int32 + Sasl *SASL + SecurityProtocol string + Ssl *SSL + Topic string + func (*ProducerConf) Descriptor() ([]byte, []int) + func (*ProducerConf) ProtoMessage() + func (m *ProducerConf) Validate() error + func (m *ProducerConf) ValidateAll() error + func (x *ProducerConf) GetAcks() int32 + func (x *ProducerConf) GetBootstrapServers() string + func (x *ProducerConf) GetPartitioner() string + func (x *ProducerConf) GetRequestRequiredAcks() int32 + func (x *ProducerConf) GetRequestTimeoutMs() int32 + func (x *ProducerConf) GetSasl() *SASL + func (x *ProducerConf) GetSecurityProtocol() string + func (x *ProducerConf) GetSsl() *SSL + func (x *ProducerConf) GetTopic() string + func (x *ProducerConf) ProtoReflect() protoreflect.Message + func (x *ProducerConf) Reset() + func (x *ProducerConf) String() string + type ProducerConfMultiError []error + func (m ProducerConfMultiError) AllErrors() []error + func (m ProducerConfMultiError) Error() string + type ProducerConfValidationError struct + func (e ProducerConfValidationError) Cause() error + func (e ProducerConfValidationError) Error() string + func (e ProducerConfValidationError) ErrorName() string + func (e ProducerConfValidationError) Field() string + func (e ProducerConfValidationError) Key() bool + func (e ProducerConfValidationError) Reason() string type SASL + func (m *SASL) ValidateAll() error + type SASLMultiError []error + func (m SASLMultiError) AllErrors() []error + func (m SASLMultiError) Error() string type SSL + func (m *SSL) ValidateAll() error + type SSLMultiError []error + func (m SSLMultiError) AllErrors() []error + func (m SSLMultiError) Error() string v0.0.1 Oct 23, 2022 Changes in this version + var File_client_confluent_conf_proto protoreflect.FileDescriptor + func MustNewPusher(c *Conf) queue.Pusher + func MustNewQueue(c *Conf, handler queue.ConsumeHandler) queue.MessageQueue + func NewPusher(c *Conf) (queue.Pusher, error) + func NewQueue(c *Conf, handler queue.ConsumeHandler) (queue.MessageQueue, error) + func WrapError(err error) error + type Conf struct + Acks int32 + BootstrapServers string + Group string + ReadTimeout *durationpb.Duration + Sasl *SASL + SecurityProtocol string + Ssl *SSL + Topic string + WriteTimeout *durationpb.Duration + func (*Conf) Descriptor() ([]byte, []int) + func (*Conf) ProtoMessage() + func (m *Conf) Validate() error + func (x *Conf) GetAcks() int32 + func (x *Conf) GetBootstrapServers() string + func (x *Conf) GetGroup() string + func (x *Conf) GetReadTimeout() *durationpb.Duration + func (x *Conf) GetSasl() *SASL + func (x *Conf) GetSecurityProtocol() string + func (x *Conf) GetSsl() *SSL + func (x *Conf) GetTopic() string + func (x *Conf) GetWriteTimeout() *durationpb.Duration + func (x *Conf) ProtoReflect() protoreflect.Message + func (x *Conf) Reset() + func (x *Conf) String() string + type ConfValidationError struct + func (e ConfValidationError) Cause() error + func (e ConfValidationError) Error() string + func (e ConfValidationError) ErrorName() string + func (e ConfValidationError) Field() string + func (e ConfValidationError) Key() bool + func (e ConfValidationError) Reason() string + type KafkaMessageTextMapCarrier struct + func (carrier *KafkaMessageTextMapCarrier) Get(key string) string + func (carrier *KafkaMessageTextMapCarrier) Keys() []string + func (carrier *KafkaMessageTextMapCarrier) Set(key string, value string) + type KafkaProducer struct + func (p *KafkaProducer) Close() error + func (p *KafkaProducer) Name() string + func (p *KafkaProducer) Push(ctx context.Context, key, value []byte) error + type SASL struct + Mechanisms string + Password string + User string + func (*SASL) Descriptor() ([]byte, []int) + func (*SASL) ProtoMessage() + func (m *SASL) Validate() error + func (x *SASL) GetMechanisms() string + func (x *SASL) GetPassword() string + func (x *SASL) GetUser() string + func (x *SASL) ProtoReflect() protoreflect.Message + func (x *SASL) Reset() + func (x *SASL) String() string + type SASLValidationError struct + func (e SASLValidationError) Cause() error + func (e SASLValidationError) Error() string + func (e SASLValidationError) ErrorName() string + func (e SASLValidationError) Field() string + func (e SASLValidationError) Key() bool + func (e SASLValidationError) Reason() string + type SSL struct + CaLocation string + CaPem string + func (*SSL) Descriptor() ([]byte, []int) + func (*SSL) ProtoMessage() + func (m *SSL) Validate() error + func (x *SSL) GetCaLocation() string + func (x *SSL) GetCaPem() string + func (x *SSL) ProtoReflect() protoreflect.Message + func (x *SSL) Reset() + func (x *SSL) String() string + type SSLValidationError struct + func (e SSLValidationError) Cause() error + func (e SSLValidationError) Error() string + func (e SSLValidationError) ErrorName() string + func (e SSLValidationError) Field() string + func (e SSLValidationError) Key() bool + func (e SSLValidationError) Reason() string
Go to main page