nst

type Account struct {
	Users     Users             `json:"users,omitempty"`
	JetStream *AccountJetStream `json:"jetstream,omitempty"`
}

type AccountJetStream struct {
	Enabled            bool   `json:"-"`
	MaxMemory          uint64 `json:"max_memory,omitempty"`
	MaxStore           uint64 `json:"max_store,omitempty"`
	MaxStreams         int    `json:"max_streams,omitempty"`
	MaxConsumers       int    `json:"max_consumers,omitempty"`
	MaxBytesRequired   bool   `json:"max_bytes_required,omitempty"`
	MemMaxStreamBytes  int64  `json:"mem_max_stream_bytes,omitempty"`
	DiskMaxStreamBytes int64  `json:"disk_max_stream_bytes,omitempty"`
	MaxAckPending      int    `json:"max_ack_pending,omitempty"`
}

type AccountJetStreamOpt func(*AccountJetStream)

type Accounts map[string]Account

type AllowDeny struct {
	Allow jwt.StringList `json:"allow,omitempty"`
	Deny  jwt.StringList `json:"deny,omitempty"`
}

type AuthCallout struct {
	// AuthUsers is a list of authorized users under Account that will handle callout requests
	AuthUsers jwt.StringList `json:"auth_users"`
	// Account containing the AuthUsers
	Account string `json:"account,omitempty"`
	// Issuer the public key that will issue jwt.AuthorizationResponseClaims
	Issuer string `json:"issuer"`
	// XKey optional public curve key, activates encryption
	XKey string `json:"xkey,omitempty"`
	// AllowedAccounts optional public list of accounts that users can be placed in
	AllowedAccounts jwt.StringList `json:"allowed_accounts,omitempty"`
}

type Authorization struct {
	Token       string       `json:"token,omitempty"`
	Users       Users        `json:"users,omitempty"`
	AuthCallout *AuthCallout `json:"auth_callout,omitempty"`
}

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

type Cluster struct {
	Name           string                `json:"name,omitempty"`
	Port           int                   `json:"port,omitempty"`
	NoAdvertise    bool                  `json:"no_advertise,omitempty"`
	ConnectRetries int                   `json:"connect_retries,omitempty"`
	Authorization  *ClusterAuthorization `json:"authorization,omitempty"`
	Routes         []string              `json:"routes,omitempty"`
}

type ClusterAuthorization struct {
	User     string `json:"user,omitempty"`
	Password string `json:"password,omitempty"`
	Timeout  string `json:"timeout,omitempty"`
}

type Conf struct {
	PortsFileDir    string        `json:"ports_file_dir,omitempty"`
	Debug           bool          `json:"debug,omitempty"`
	Trace           bool          `json:"trace,omitempty"`
	Port            int           `json:"port,omitempty"`
	Include         string        `json:"include,omitempty"`
	Accounts        Accounts      `json:"accounts,omitempty"`
	SystemAccount   *string       `json:"system_account,omitempty"`
	Authorization   Authorization `json:"authorization,omitempty"`
	DefaultSentinel string        `json:"default_sentinel,omitempty"`
	JetStream       *JetStream    `json:"jetstream,omitempty"`
	LeafNodes       *LeafNodes    `json:"leafnodes,omitempty"`
	WriteDeadline   string        `json:"write_deadline,omitempty"`
	WebSocket       *WebSocket    `json:"websocket,omitempty"`
	MonitoringPort  int           `json:"http,omitempty"`
	Cluster         *Cluster      `json:"cluster,omitempty"`
	MaxPending      int           `json:"max_pending,omitempty"`
}

type ConnectionPorts struct {
	Nats       []string
	WebSocket  []string
	Cluster    []string
	Monitoring []string
}

type Connections struct {
	ConnectionPorts
	sync.Mutex
	Conns []*nats.Conn
	// contains filtered or unexported fields
}

type ErrorDetails struct {
	Account     string `json:"account"`
	Code        int    `json:"code"`
	Description string `json:"description"`
}

type ExternalNatsServer struct {
	Process *exec.Cmd
	Connections
	// contains filtered or unexported fields
}

type JetStream struct {
	StoreDir string `json:"store_dir,omitempty"`
	Domain   string `json:"domain,omitempty"`
	MaxMem   uint64 `json:"max_mem,omitempty"`
	MaxFile  uint64 `json:"max_file,omitempty"`
}

type LeafNodes struct {
	Compression string   `json:"compression,omitempty"`
	Port        int      `json:"port,omitempty"`
	Remotes     []Remote `json:"remotes,omitempty"`
}

type NatsServer interface {
	// RequireConnect creates a connection that is not expected to fail, if it fail test will fail
	RequireConnect(opts ...nats.Option) *nats.Conn
	// MaybeConnect attempts to create a TCP connection
	MaybeConnect(options ...nats.Option) (*nats.Conn, error)
	// WsMaybeConnect attempts to create a connection via WebSocket.
	WsMaybeConnect(opts ...nats.Option) (*nats.Conn, error)
	// TrackConn simply adds a connection made to the server via direct client API to be discarded on ShutDown
	TrackConn(conn ...*nats.Conn)
	// UntrackedConnection convenience function to create a connection that is not tracked
	UntrackedConnection(opts ...nats.Option) (*nats.Conn, error)
	// Shutdown stop the server closing all connections initiated via the API if tracked.
	Shutdown()
	// NatsURLs returns a list of all the connection URLs (tcp)
	NatsURLs() []string
	// WsURLs returns a list of all the connection URLs (websocket)
	WsURLs() []string
	// ClusterURLs returns a list of all the cluster connection URLs (tcp)
	ClusterURLs() []string
}

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

type Options struct {
	Debug      bool
	Trace      bool
	ConfigFile string
	Port       int
	JetStream  bool
	StoreDir   string
	InProcess  bool
}

type Permissions struct {
	Pub            AllowDeny `json:"publish,omitempty"`
	Sub            AllowDeny `json:"subscribe,omitempty"`
	AllowResponses bool      `json:"allow_responses,omitempty"`
}

type Ports struct {
	Nats       []string `json:"nats,omitempty"`
	Cluster    []string `json:"cluster,omitempty"`
	Monitoring []string `json:"monitoring,omitempty"`
	WebSocket  []string `json:"websocket,omitempty"`
}

type Remote struct {
	Urls        []string `json:"urls,omitempty"`
	Account     string   `json:"account,omitempty"`
	Credentials string   `json:"credentials,omitempty"`
}

type Resolver struct {
	Type           ResolverType `json:"type,omitempty"`
	Dir            string       `json:"dir,omitempty"`
	AllowDelete    bool         `json:"allow_delete,omitempty"`
	UpdateInterval string       `json:"interval,omitempty"`
	Timeout        string       `json:"timeout,omitempty"`
}

type ResolverConf struct {
	Conf
	Operator      string            `json:"operator,omitempty"`
	SystemAccount string            `json:"system_account,omitempty"`
	Resolver      *Resolver         `json:"resolver,omitempty"`
	Preload       map[string]string `json:"resolver_preload,omitempty"`
}

type ResolverListResponse struct {
	ResolverResponse
	Accounts []string `json:"data"`
}

type ResolverResponse struct {
	Error  *ErrorDetails `json:"error,omitempty"`
	Server ServerDetails `json:"server"`
}

type ResolverType string

type ResolverUpdateResponse struct {
	ResolverResponse
	UpdateData UpdateData `json:"data"`
}

type ServerDetails struct {
	Name      string    `json:"name"`
	Host      string    `json:"host"`
	ID        string    `json:"id"`
	Version   string    `json:"ver"`
	Jetstream bool      `json:"jetstream"`
	Flags     int       `json:"flags"`
	Sequence  int       `json:"seq"`
	Time      time.Time `json:"time"`
}

type TestDir struct {
	Dir string
	// contains filtered or unexported fields
}

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

type UpdateData struct {
	Account string `json:"account"`
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type User struct {
	User        string       `json:"user,omitempty"`
	Password    string       `json:"password,omitempty"`
	Token       string       `json:"token,omitempty"`
	NKEY        string       `json:"nkey,omitempty"`
	Permissions *Permissions `json:"permissions,omitempty"`
}

type UserData struct {
	User        string      `json:"user"`
	Account     string      `json:"account"`
	Permissions Permissions `json:"permissions"`
	Expires     int64       `json:"expires"`
}

type UserInfo struct {
	ServerDetails
	Data UserData `json:"data"`
}

type Users []User

type WebSocket struct {
	Port        int    `json:"port,omitempty"`
	NoTls       bool   `json:"no_tls,omitempty"`
	JwtCookie   string `json:"jwt_cookie,omitempty"`
	UserCookie  string `json:"user_cookie,omitempty"`
	PassCookie  string `json:"pass_cookie,omitempty"`
	TokenCookie string `json:"token_cookie,omitempty"`
}