client

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

type AuthConfigFlags struct {
	// Addr is an explicit IP address for the server.
	Addr string
	// Namespace is the namespace of the server pod.
	Namespace string
	// Port is the port of the server pod.
	Port int
	// Enforce turn credential.
	TurnAuth bool
}

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

type CDSConfigFlags struct {
	// Addr is an explicit IP address for the CDS server.
	Addr string
	// Namespace is the namespace of the CDS server pod.
	Namespace string
	// Port is the port of the CDS server pod.
	Port int
}

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) ([]*stnrv1.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<- *stnrv1.StunnerConfig, suppressDelete bool) error
	// Poll creates a one-shot config watcher without the retry mechanincs of Watch.
	Poll(ctx context.Context, ch chan<- *stnrv1.StunnerConfig, suppressDelete bool) error
	logging.LeveledLogger
}

type Client interface {
	// Load grabs a new configuration from the config client.
	Load() (*stnrv1.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<- *stnrv1.StunnerConfig, suppressDelete bool) error
	// Poll creates a one-shot config watcher without the retry mechanincs of Watch.
	Poll(ctx context.Context, ch chan<- *stnrv1.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   []*stnrv1.StunnerConfig `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) (stnrv1.LicenseStatus, error)
}

type PodConfigFlags struct {
	// Addr is an explicit IP address for the pod.
	Addr string
	// Name is the name of the pod.
	Name string
	// Port is the port to use.
	Port int
}

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

type PodInfo struct {
	// Name of the pod.
	Name string
	// Namespace is the Kubernetes namespace of the pod.
	Namespace string
	// Addr is the Kubernetes namespace of the pod.
	Addr string
	// Proxy is a boolean telling whether the connection is proxied over a port-forwarder.
	Proxy bool
}

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