kafka

type AwsClients struct {
	ConsumerGroup sarama.ConsumerGroup
	Producer      sarama.SyncProducer
	// contains filtered or unexported fields
}

type BulkEventHandler func(ctx context.Context, msg *KafkaBulkMessage) ([]pubsub.BulkSubscribeResponseEntry, error)

type EventHandler func(ctx context.Context, msg *NewEvent) error

type Kafka struct {

	// The default value should be true for kafka pubsub component and false for kafka binding component
	// This default value can be overridden by metadata consumeRetryEnabled
	DefaultConsumeRetryEnabled bool
	// contains filtered or unexported fields
}

type KafkaBulkMessage struct {
	Entries  []KafkaBulkMessageEntry `json:"entries"`
	Topic    string                  `json:"topic"`
	Metadata map[string]string       `json:"metadata"`
}

type KafkaBulkMessageEntry struct {
	EntryId     string            `json:"entryId"` //nolint:stylecheck
	Event       []byte            `json:"event"`
	ContentType string            `json:"contentType,omitempty"`
	Metadata    map[string]string `json:"metadata"`
}

type KafkaMetadata struct {
	Brokers string `mapstructure:"brokers"`

	ConsumerGroup string `mapstructure:"consumerGroup"`
	ClientID      string `mapstructure:"clientId"`
	AuthType      string `mapstructure:"authType"`
	SaslUsername  string `mapstructure:"saslUsername"`
	SaslPassword  string `mapstructure:"saslPassword"`
	SaslMechanism string `mapstructure:"saslMechanism"`
	InitialOffset string `mapstructure:"initialOffset"`

	MaxMessageBytes         int    `mapstructure:"maxMessageBytes"`
	OidcTokenEndpoint       string `mapstructure:"oidcTokenEndpoint"`
	OidcClientID            string `mapstructure:"oidcClientID"`
	OidcClientSecret        string `mapstructure:"oidcClientSecret"`
	OidcScopes              string `mapstructure:"oidcScopes"`
	OidcExtensions          string `mapstructure:"oidcExtensions"`
	OidcClientAssertionCert string `mapstructure:"oidcClientAssertionCert"`
	OidcClientAssertionKey  string `mapstructure:"oidcClientAssertionKey"`
	OidcResource            string `mapstructure:"oidcResource"`
	OidcAudience            string `mapstructure:"oidcAudience"`
	OidcKid                 string `mapstructure:"oidcKid"`

	TLSDisable           bool          `mapstructure:"disableTls"`
	TLSSkipVerify        bool          `mapstructure:"skipVerify"`
	TLSCaCert            string        `mapstructure:"caCert"`
	TLSClientCert        string        `mapstructure:"clientCert"`
	TLSClientKey         string        `mapstructure:"clientKey"`
	ConsumeRetryEnabled  bool          `mapstructure:"consumeRetryEnabled"`
	ConsumeRetryInterval time.Duration `mapstructure:"consumeRetryInterval"`
	HeartbeatInterval    time.Duration `mapstructure:"heartbeatInterval"`
	SessionTimeout       time.Duration `mapstructure:"sessionTimeout"`
	Version              string        `mapstructure:"version"`
	EscapeHeaders        bool          `mapstructure:"escapeHeaders"`

	// configs for kafka client
	ClientConnectionTopicMetadataRefreshInterval time.Duration `mapstructure:"clientConnectionTopicMetadataRefreshInterval"`
	ClientConnectionKeepAliveInterval            time.Duration `mapstructure:"clientConnectionKeepAliveInterval"`

	// Net timeout tunables.
	// Defaults preserve Sarama's built-in values (30 s each) so unset
	// deployments behave identically to previous releases.
	DialTimeout  time.Duration `mapstructure:"dialTimeout"`
	ReadTimeout  time.Duration `mapstructure:"readTimeout"`
	WriteTimeout time.Duration `mapstructure:"writeTimeout"`
	// MetadataTimeout is the per-request metadata timeout passed to
	// Sarama's Metadata.Timeout. When 0 (default) Sarama's own default
	// applies (disabled, computed from Net timeouts × retry count).
	MetadataTimeout time.Duration `mapstructure:"metadataTimeout"`

	ConsumerGroupRebalanceStrategy string `mapstructure:"consumerGroupRebalanceStrategy"`

	// configs for kafka producer
	Compression string `mapstructure:"compression"`

	// Producer tunables.
	// ProducerRequiredAcks accepts "all" (default), "local", or "none".
	ProducerRequiredAcks string `mapstructure:"producerRequiredAcks"`

	// ProducerRetryMax is the number of times to retry sending a message (default 5).
	ProducerRetryMax int `mapstructure:"producerRetryMax"`

	// schema registry
	SchemaRegistryURL           string        `mapstructure:"schemaRegistryURL"`
	SchemaRegistryAPIKey        string        `mapstructure:"schemaRegistryAPIKey"`
	SchemaRegistryAPISecret     string        `mapstructure:"schemaRegistryAPISecret"`
	SchemaCachingEnabled        bool          `mapstructure:"schemaCachingEnabled"`
	SchemaLatestVersionCacheTTL time.Duration `mapstructure:"schemaLatestVersionCacheTTL"`
	UseAvroJSON                 bool          `mapstructure:"useAvroJSON"`

	// header from/to metadata excluded keys regex
	ExcludeHeaderMetaRegex string `mapstructure:"excludeHeaderMetaRegex"`
	// contains filtered or unexported fields
}

type KafkaOptions struct {
	Config         *sarama.Config
	ConsumerGroup  string
	Brokers        []string
	ProducerConfig ProducerConfig
}

type NewEvent struct {
	Data        []byte            `json:"data"`
	Topic       string            `json:"topic"`
	Metadata    map[string]string `json:"metadata"`
	ContentType *string           `json:"contentType,omitempty"`
}

type OAuthTokenSource struct {
	CachedToken   oauth2.Token
	Extensions    map[string]string
	TokenEndpoint oauth2.Endpoint
	ClientID      string
	ClientSecret  string
	Scopes        []string
	// contains filtered or unexported fields
}

type OAuthTokenSourcePrivateKeyJWT struct {
	CachedToken   oauth2.Token
	Extensions    map[string]string
	TokenEndpoint oauth2.Endpoint
	ClientID      string
	ClientSecret  string
	Scopes        []string

	ClientAuthMethod    string
	ClientAssertionCert string
	ClientAssertionKey  string
	Resource            string
	Audience            string
	Kid                 string
	// contains filtered or unexported fields
}

type ProducerConfig struct {
	RequiredAcks    sarama.RequiredAcks
	RetryMax        int
	MaxMessageBytes int
}

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

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

type SchemaType int

type SubscriptionHandlerConfig struct {
	IsBulkSubscribe bool
	SubscribeConfig pubsub.BulkSubscribeConfig
	BulkHandler     BulkEventHandler
	Handler         EventHandler
	ValueSchemaType SchemaType
}

type TopicHandlerConfig map[string]SubscriptionHandlerConfig

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}