client

type AllConfigsAPI struct {
	logging.LeveledLogger
	// contains filtered or unexported fields
}

type CDSClient struct {
	CdsApi
	// contains filtered or unexported fields
}

type CdsApi interface {
	// Endpoint returns the address of the server plus the WebSocket API endpoint.
	Endpoint() (string, string)
	// Get loads the config(s) from the API endpoint.
	Get(ctx context.Context) ([]*stnrv2.StunnerConfig, error)
	// Watch watches config(s) from the API endpoint of a CDS server. If the server is not
	// available watch will retry, and if the connection goes away it will create a new one. If
	// set, the suppressDelete instructs the API to ignore config delete updates from the
	// server.
	Watch(ctx context.Context, ch chan<- *stnrv2.StunnerConfig, suppressDelete bool) error
	// Poll creates a one-shot config watcher without the retry mechanics of Watch.
	Poll(ctx context.Context, ch chan<- *stnrv2.StunnerConfig, suppressDelete bool) error
	logging.LeveledLogger
}

type Client interface {
	// Load grabs a new configuration from the config client.
	Load() (*stnrv2.StunnerConfig, error)
	// Watch listens to new configs from a config origin (config file or CDS server) and
	// returns them on the given channel. The context cancels the watcher. If the origin is not
	// available watch will retry. If set, the suppressDelete flag instructs the client to
	// ignore delete config (essentially zero-configs) from the origin.
	Watch(ctx context.Context, ch chan<- *stnrv2.StunnerConfig, suppressDelete bool) error
	// Poll creates a one-shot config watcher without the retry mechanics of Watch.
	Poll(ctx context.Context, ch chan<- *stnrv2.StunnerConfig, suppressDelete bool) error
	fmt.Stringer
}

type ClientOption = api.ClientOption

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

type ConfigList struct {
	Version string            `json:"version"`
	Items   []json.RawMessage `json:"items"`
}

type ConfigNamespaceNameAPI struct {
	logging.LeveledLogger
	// contains filtered or unexported fields
}

type ConfigSkeleton struct {
	ApiVersion string `json:"version"`
}

type ConfigsNamespaceAPI struct {
	logging.LeveledLogger
	// contains filtered or unexported fields
}

type HttpRequestDoer = api.HttpRequestDoer

type JSONPathArg interface {
	Parse(arg string) (bool, error)
	Evaluate(data interface{}) (string, error)
}

type LicenseStatusClient interface {
	LicenseStatus(ctx context.Context) (stnrv2.LicenseStatus, error)
}

type Segment struct {
	// String is the actual text of the segment (if any).
	String string
	// JSONQuery is the actual query in the segment.
	JSONQuery *jsonpath.JSONPath
	// Type indicates whether this is a regular string or an expression.
	Type SegmentType
}

type SegmentType int