pulsar

type Athenz struct {
	ProviderDomain  string
	TenantDomain    string
	TenantService   string
	PrivateKey      string
	KeyID           string
	PrincipalHeader string
	ZtsURL          string
}

type Authentication struct {
	TLS    *TLS
	Token  *Token
	Athenz *Athenz
	OAuth2 *OAuth2
}

type FlusherPulsar struct {
	// URL for the Pulsar service
	URL string
	// SendTimeout send timeout
	SendTimeout time.Duration
	// OperationTimeout sets producer-create, subscribe and unsubscribe operations timeout (default: 30 seconds)
	OperationTimeout time.Duration
	// ConnectionTimeout timeout for the establishment of a TCP connection (default: 5 seconds)
	ConnectionTimeout time.Duration
	// MaxConnectionsPerBroker max number of connections to a single broker that will kept in the pool. (default: 1 connection)
	MaxConnectionsPerBroker int
	// Topic The name of the pulsar topic
	Topic string
	// Name  The producer name
	Name string
	// Convert  ilogtail data convert config
	Convert convertConfig
	// Configure whether the Pulsar client accept untrusted TLS certificate from broker (default: false)
	// EnableTLS
	EnableTLS bool
	// Set the path to the trusted TLS certificate file
	TLSTrustCertsFilePath string
	// Authentication support tls
	Authentication Authentication

	// MaxReconnectToBroker specifies the maximum retry number of reconnectToBroker. (default: ultimate)
	MaxReconnectToBroker *uint
	// DisableBlockIfQueueFull controls whether Send and SendAsync block if producer's message queue is full
	DisableBlockIfQueueFull bool
	// CompressionType  Codec used to produce messages,NONE,LZ4,ZLIB,ZSTD
	CompressionType string
	// HashingScheme is used to define the partition on where to publish a particular message
	HashingScheme string
	// BatchingMaxPublishDelay the batch push delay
	BatchingMaxPublishDelay time.Duration
	// BatchingMaxMessages maximum number of messages in a batch
	BatchingMaxMessages uint
	// MaxCacheProducers Specify the max cache(lru) producers of dynamic topic
	MaxCacheProducers int

	PartitionKeys []string
	ClientID      string
	// contains filtered or unexported fields
}

type OAuth2 struct {
	Enabled    bool
	IssuerURL  string
	Audience   string
	PrivateKey string
	Scope      string
}

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

type TLS struct {
	// Path to the TLS cert to use for TLS required connections. (optional)
	CertFile string
	// Path to the TLS key to use for TLS required connections. (optional)
	KeyFile string
}

type Token struct {
	Token string
}