forked from redpanda-data/connect
-
Notifications
You must be signed in to change notification settings - Fork 0
/
pulsar.go
25 lines (22 loc) · 785 Bytes
/
pulsar.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package input
import (
"github.com/dafanshu/benthos/v3/internal/impl/pulsar/auth"
)
// PulsarConfig contains configuration for the Pulsar input type.
type PulsarConfig struct {
URL string `json:"url" yaml:"url"`
Topics []string `json:"topics" yaml:"topics"`
SubscriptionName string `json:"subscription_name" yaml:"subscription_name"`
SubscriptionType string `json:"subscription_type" yaml:"subscription_type"`
Auth auth.Config `json:"auth" yaml:"auth"`
}
// NewPulsarConfig creates a new PulsarConfig with default values.
func NewPulsarConfig() PulsarConfig {
return PulsarConfig{
URL: "",
Topics: []string{},
SubscriptionName: "",
SubscriptionType: "",
Auth: auth.New(),
}
}