xds

Documentation

Index

• type Client
  • func NewClient(addr string) (*Client, error)
  • func (xds *Client) Close() error
  • func (xds *Client) List(ctx context.Context, gvk schema.GroupVersionKind) ([]runtime.Object, error)
  • func (xds *Client) Resources(ctx context.Context) ([]runtime.Object, error)
  • func (xds *Client) Version(ctx context.Context) (string, error)

Types

type Client

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

Client wraps Envoy XDS and exposes methods to query data.

func NewClient

func NewClient(addr string) (*Client, error)

NewClient creates an XDS client given a GRPC address.

func (*Client) Close

func (xds *Client) Close() error

Close closes the underlying gRPC connection if present.

func (*Client) List

func (xds *Client) List(ctx context.Context, gvk schema.GroupVersionKind) ([]runtime.Object, error)

List queries the XDS server for a given GroupVersionKind (e.g. security.istio.io/v1beta1/AuthorizationPolicy) and returns these resources as Kubernetes runtime.Objects.

func (*Client) Resources

func (xds *Client) Resources(ctx context.Context) ([]runtime.Object, error)

Resources queries all Istio resources from the client.

func (*Client) Version

func (xds *Client) Version(ctx context.Context) (string, error)

Version queries the XDS server and retrieves its version.

{
  "Component": "istiod",
  "ID": "istiod-568d797f55-vlxmt",
  "Info": {
    "version": "1.10.3",
    "revision": "61313778e0b785e401c696f5e92f47af069f96d0",
    "golang_version": "go1.16.6",
    "status": "Clean",
    "tag": "1.10.3"
  }
}