kafkadriver

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

type Configuration struct {
	BootstrapServers                 []string                           `protobuf:"bytes,1,rep,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	MaxMessageBytes                  int64                              `protobuf:"varint,2,opt,name=max_message_bytes,json=maxMessageBytes,proto3" json:"max_message_bytes,omitempty"`
	MaxMessageCopyBytes              int64                              `protobuf:"varint,3,opt,name=max_message_copy_bytes,json=maxMessageCopyBytes,proto3" json:"max_message_copy_bytes,omitempty"`
	ReceiveMessageMaxBytes           int64                              `` /* 132-byte string literal not displayed */
	MaxInFlight                      int64                              `protobuf:"varint,5,opt,name=max_in_flight,json=maxInFlight,proto3" json:"max_in_flight,omitempty"`
	Debug                            string                             `protobuf:"bytes,6,opt,name=debug,proto3" json:"debug,omitempty"`
	ReconnectBackoffMs               int64                              `protobuf:"varint,7,opt,name=reconnect_backoff_ms,json=reconnectBackoffMs,proto3" json:"reconnect_backoff_ms,omitempty"`
	ReconnectBackoffMaxMs            int64                              `` /* 129-byte string literal not displayed */
	StatisticsIntervalMs             int64                              `protobuf:"varint,9,opt,name=statistics_interval_ms,json=statisticsIntervalMs,proto3" json:"statistics_interval_ms,omitempty"`
	ApiVersionRequest                bool                               `protobuf:"varint,10,opt,name=api_version_request,json=apiVersionRequest,proto3" json:"api_version_request,omitempty"`
	ApiVersionFallbackMs             int64                              `` /* 127-byte string literal not displayed */
	BrokerVersionFallback            string                             `` /* 127-byte string literal not displayed */
	SecurityProtocol                 string                             `protobuf:"bytes,13,opt,name=security_protocol,json=securityProtocol,proto3" json:"security_protocol,omitempty"`
	SslKeyLocation                   string                             `protobuf:"bytes,14,opt,name=ssl_key_location,json=sslKeyLocation,proto3" json:"ssl_key_location,omitempty"`
	SslCertificateLocation           string                             `` /* 130-byte string literal not displayed */
	SslCaLocation                    string                             `protobuf:"bytes,16,opt,name=ssl_ca_location,json=sslCaLocation,proto3" json:"ssl_ca_location,omitempty"`
	SslCrlLocation                   string                             `protobuf:"bytes,17,opt,name=ssl_crl_location,json=sslCrlLocation,proto3" json:"ssl_crl_location,omitempty"`
	EnableSslCertificateVerification bool                               `` /* 163-byte string literal not displayed */
	Consumers                        map[string]*Configuration_Consumer `` /* 160-byte string literal not displayed */
	Producers                        map[string]*Configuration_Producer `` /* 160-byte string literal not displayed */
	MessageKeyFrom                   IdentityFieldToMessageKey          `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Configuration_Consumer struct {
	SessionTimeoutMs        int64    `protobuf:"varint,1,opt,name=session_timeout_ms,json=sessionTimeoutMs,proto3" json:"session_timeout_ms,omitempty"`
	MaxPollIntervalMs       int64    `protobuf:"varint,2,opt,name=max_poll_interval_ms,json=maxPollIntervalMs,proto3" json:"max_poll_interval_ms,omitempty"`
	QueuedMinMessages       int64    `protobuf:"varint,3,opt,name=queued_min_messages,json=queuedMinMessages,proto3" json:"queued_min_messages,omitempty"`
	QueuedMaxMessagesKbytes int64    `` /* 135-byte string literal not displayed */
	FetchMessageMaxBytes    int64    `` /* 126-byte string literal not displayed */
	FetchErrorBackoffMs     int64    `protobuf:"varint,6,opt,name=fetch_error_backoff_ms,json=fetchErrorBackoffMs,proto3" json:"fetch_error_backoff_ms,omitempty"`
	ReadTimeoutMs           int64    `protobuf:"varint,7,opt,name=read_timeout_ms,json=readTimeoutMs,proto3" json:"read_timeout_ms,omitempty"`
	Topics                  []string `protobuf:"bytes,8,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

type Configuration_Producer struct {
	QueueBufferingMaxMs       int64  `protobuf:"varint,1,opt,name=queue_buffering_max_ms,json=queueBufferingMaxMs,proto3" json:"queue_buffering_max_ms,omitempty"`
	RetryBackoffMs            int64  `protobuf:"varint,2,opt,name=retry_backoff_ms,json=retryBackoffMs,proto3" json:"retry_backoff_ms,omitempty"`
	BatchNumMessages          int64  `protobuf:"varint,3,opt,name=batch_num_messages,json=batchNumMessages,proto3" json:"batch_num_messages,omitempty"`
	MessageTimeoutMs          int64  `protobuf:"varint,4,opt,name=message_timeout_ms,json=messageTimeoutMs,proto3" json:"message_timeout_ms,omitempty"`
	TransactionTimeoutMs      int64  `protobuf:"varint,5,opt,name=transaction_timeout_ms,json=transactionTimeoutMs,proto3" json:"transaction_timeout_ms,omitempty"`
	QueueBufferingMaxMessages int64  `` /* 141-byte string literal not displayed */
	QueueBufferingMaxKbytes   int64  `` /* 135-byte string literal not displayed */
	MessageSendMaxRetries     int64  `` /* 129-byte string literal not displayed */
	IsTransactional           bool   `protobuf:"varint,9,opt,name=is_transactional,json=isTransactional,proto3" json:"is_transactional,omitempty"`
	IsIdempotent              bool   `protobuf:"varint,10,opt,name=is_idempotent,json=isIdempotent,proto3" json:"is_idempotent,omitempty"`
	TransactionalId           string `protobuf:"bytes,11,opt,name=transactional_id,json=transactionalId,proto3" json:"transactional_id,omitempty"`
	// contains filtered or unexported fields
}

type Consumer struct {
	*kafka.Consumer

	MessagesCh chan *WrappedEvent
	// contains filtered or unexported fields
}

type Event struct {
	Name       string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Data       []byte              `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	MessageKey string              `protobuf:"bytes,3,opt,name=message_key,json=messageKey,proto3" json:"message_key,omitempty"`
	Topic      string              `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	Claim      *auth.ClaimEnvelope `protobuf:"bytes,5,opt,name=claim,proto3" json:"claim,omitempty"`
	// contains filtered or unexported fields
}

type EventMessageKey int

type IdentityFieldToMessageKey int32

type Producer struct {
	*kafka.Producer
	// contains filtered or unexported fields
}

type WrappedEvent struct {
	Event
	Raw *kafka.Message
}