config

type Auth struct {
	// the OAuth 2.0 issuer endpoint
	IssuerEndpoint string `yaml:"issuer"`
	// the audience identifier for the API server (default: server URL)
	Audience string `yaml:"audience"`
	// the client ID to use for authorization grants (note: not used for service accounts)
	ClientID string `yaml:"client-id"`
}

type AuthOptions struct {
	BackendOverride string

	// AuthOptions is a facade for the token store
	// note: call Complete before using the token store methods
	store.Store
	// contains filtered or unexported fields
}

type Context struct {
	Organization   string `yaml:"organization,omitempty"`
	PulsarInstance string `yaml:"pulsar-instance,omitempty"`
	PulsarCluster  string `yaml:"pulsar-cluster,omitempty"`
}

type ExternalKafka struct {
	BootstrapServers  string
	AuthType          string
	AuthMechanism     string
	AuthUser          string
	AuthPass          string
	UseTLS            bool
	ClientKeyFile     string
	ClientCertFile    string
	CaFile            string
	SchemaRegistryURL string

	SchemaRegistryAuthUser    string
	SchemaRegistryAuthPass    string
	SchemaRegistryBearerToken string
}

type ExternalPulsar struct {
	ServiceURL                    string
	WebServiceURL                 string
	Token                         string
	AuthPlugin                    string
	AuthParams                    string
	TLSAllowInsecureConnection    bool
	TLSEnableHostnameVerification bool
	TLSTrustCertsFilePath         string
	TLSCertFile                   string
	TLSKeyFile                    string
}

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

type Options struct {
	AuthOptions
	ConfigDir  string
	ConfigPath string
	Server     string
	// the OAuth 2.0 issuer endpoint
	IssuerEndpoint string
	// the audience identifier for the API server (default: server URL)
	Audience string
	// the client ID to use for authorization grants (note: not used for service accounts)
	ClientID       string
	Organization   string
	PulsarInstance string
	PulsarCluster  string
	ProxyLocation  string
	LogLocation    string
	KeyFile        string

	UseExternalKafka  bool
	UseExternalPulsar bool
	Kafka             ExternalKafka
	Pulsar            ExternalPulsar
}

type SnConfig struct {
	// the API server endpoint
	Server string `yaml:"server"`
	// CA bundle (base64, PEM)
	CertificateAuthorityData string `yaml:"certificate-authority-data"`
	// indicates whether to skip TLS verification
	InsecureSkipTLSVerify bool `yaml:"insecure-skip-tls-verify"`
	// user auth information
	Auth Auth `yaml:"auth"`
	// settable context
	Context       Context `yaml:"context"`
	ProxyLocation string  `yaml:"proxy-location"`
	LogLocation   string  `yaml:"log-location"`
	KeyFile       string  `yaml:"key-file"`

	ExternalKafka  *ExternalKafka  `yaml:"external-kafka"`
	ExternalPulsar *ExternalPulsar `yaml:"external-pulsar"`
}

type Storage interface {
	// Gets the config directory for configuration files, credentials and caches
	GetConfigDirectory() string

	// LoadConfig loads the raw configuration from storage.
	LoadConfig() (*SnConfig, error)

	// LoadConfigOrDie loads the raw configuration from storage, or dies if unable to.
	LoadConfigOrDie() *SnConfig

	// SaveConfig saves the given configuration to storage, overwriting any previous configuration.
	SaveConfig(config *SnConfig) error
}