benthos

type BenthosPlugin string

type Config struct {
	Input any // "benthos input"

	// TODO(sr): TLS
	Path              string `json:"path"`
	RegoTransformRule string `json:"rego_transform"`
	// contains filtered or unexported fields
}

type Data struct {
	Config Config

	*transform.Rego
	// contains filtered or unexported fields
}

type PulsarAuth struct {
	OAuth2 PulsarOAuth2 `json:"oauth2,omitempty"`
	Token  PulsarToken  `json:"token,omitempty"`
}

type PulsarConfig struct {
	URL                         string   `json:"url"`
	Topics                      []string `json:"topics"`
	SubscriptionName            string   `json:"subscription_name"`
	SubscriptionType            string   `json:"subscription_type"`
	SubscriptionInitialPosition string   `json:"subscription_initial_position"`

	Auth *PulsarAuth `json:"auth,omitempty"`
}

type PulsarOAuth2 struct {
	Enabled        bool   `json:"enabled"`
	Audience       string `json:"audience"`
	IssuerURL      string `json:"issuer_url"`
	Scope          string `json:"scope"`
	PrivateKeyFile string `json:"private_key_file"`
}

type PulsarToken struct {
	Enabled bool   `json:"enabled"`
	Token   string `json:"token"`
}