surveyor

type JSAdvisoriesExternalAccountConfig struct {
	// subject on which JS metrics from external accounts will be received.
	// if not set, metrics will be gathered from account set in AccountName.
	MetricsSubject string `json:"metrics_subject"`

	// position of account token in ExternalMetricsSubject
	MetricsAccountTokenPosition int `json:"metrics_account_token_position"`

	// subject on which JS advisories from external accounts will be received.
	// if not set, advisories will be gathered from account set in AccountName.
	AdvisorySubject string `json:"advisory_subject"`

	// position of account token in ExternalAdvisorySubject
	AdvisoryAccountTokenPosition int `json:"advisory_account_token_position"`
}

type JSAdvisoryConfig struct {
	// unique identifier
	ID string `json:"id"`

	// account name
	AccountName string `json:"name"`

	// optional configuration for importing JS metrics and advisories from other accounts
	// it can only be set via JSAdvisoryConfig directly (not from config file)
	ExternalAccountConfig *JSAdvisoriesExternalAccountConfig `json:"-"`

	// connection options
	JWT         string `json:"jwt"`
	Seed        string `json:"seed"`
	Credentials string `json:"credential"`
	Nkey        string `json:"nkey"`
	Token       string `json:"token"`
	Username    string `json:"username"`
	Password    string `json:"password"`
	TLSCA       string `json:"tls_ca"`
	TLSCert     string `json:"tls_cert"`
	TLSKey      string `json:"tls_key"`
}

type JSAdvisoryManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type Options struct {
	Name                 string
	URLs                 string
	Credentials          string
	Nkey                 string
	JWT                  string
	Seed                 string
	NATSUser             string
	NATSPassword         string
	PollTimeout          time.Duration
	ExpectedServers      int
	ServerResponseWait   time.Duration
	ListenAddress        string
	ListenPort           int
	CertFile             string
	KeyFile              string
	CaFile               string
	HTTPCertFile         string
	HTTPKeyFile          string
	HTTPCaFile           string
	HTTPUser             string // User in metrics scrape by Prometheus.
	HTTPPassword         string
	Prefix               string // TODO
	ObservationConfigDir string
	JetStreamConfigDir   string
	Accounts             bool
	Logger               *logrus.Logger    // not exposed by CLI
	NATSOpts             []nats.Option     // not exposed by CLI
	ConstLabels          prometheus.Labels // not exposed by CLI
	DisableHTTPServer    bool              // not exposed by CLI
}

type ServiceObsConfig struct {
	// unique identifier
	ID string `json:"id"`

	// service settings
	ServiceName string `json:"name"`
	Topic       string `json:"topic"`

	// optional configuration for importing observations from other accounts
	// it can only be set via ServiceObsConfig directly (not from config file)
	ExternalAccountConfig *ServiceObservationExternalAccountConfig `json:"-"`

	// connection options
	JWT         string `json:"jwt"`
	Seed        string `json:"seed"`
	Credentials string `json:"credential"`
	Nkey        string `json:"nkey"`
	Token       string `json:"token"`
	Username    string `json:"username"`
	Password    string `json:"password"`
	TLSCA       string `json:"tls_ca"`
	TLSCert     string `json:"tls_cert"`
	TLSKey      string `json:"tls_key"`
}

type ServiceObsManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type ServiceObservationExternalAccountConfig struct {
	// account name position in subject, used when aggregating services across multiple accounts
	AccountTokenPosition int `json:"account_token_position"`
	// optional service name position in subject, useful when aggregating services across multiple accounts
	// if not set, account name from account_token_position is used
	ServiceNamePosition int `json:"service_name_position"`
}

type StatzCollector struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Surveyor struct {
	sync.Mutex
	// contains filtered or unexported fields
}