istio

Documentation

Overview

Package istio to connect, secure, control, and observe services

Index

• func NewDocumentDecoder(r io.ReadCloser) io.ReadCloser
• type Client
  • func (iClient *Client) AddLabel(namespace string, remove bool) error
  • func (iClient *Client) ApplyOperation(ctx context.Context, arReq *meshes.ApplyRuleRequest) (*meshes.ApplyRuleResponse, error)
  • func (iClient *Client) CreateMeshInstance(_ context.Context, k8sReq *meshes.CreateMeshInstanceRequest) (*meshes.CreateMeshInstanceResponse, error)
  • func (iClient *Client) MeshName(context.Context, *meshes.MeshNameRequest) (*meshes.MeshNameResponse, error)
  • func (iClient *Client) StreamEvents(in *meshes.EventsRequest, stream meshes.MeshService_StreamEventsServer) error
  • func (iClient *Client) SupportedOperations(context.Context, *meshes.SupportedOperationsRequest) (*meshes.SupportedOperationsResponse, error)
• type Kubeconfig
• type YAMLDecoder
  • func (d *YAMLDecoder) Close() error
  • func (d *YAMLDecoder) Read(data []byte) (n int, err error)

Functions

func NewDocumentDecoder

func NewDocumentDecoder(r io.ReadCloser) io.ReadCloser

NewDocumentDecoder decodes YAML documents from the provided stream in chunks by converting each document (as defined by the YAML spec) into its own chunk. io.ErrShortBuffer will be returned if the entire buffer could not be read to assist the caller in framing the chunk.

Types

type Client

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

Client represents an Istio client in Meshery

func (*Client) AddLabel

func (iClient *Client) AddLabel(namespace string, remove bool) error

AddLabel injects label into namespace

func (*Client) ApplyOperation

func (iClient *Client) ApplyOperation(ctx context.Context, arReq *meshes.ApplyRuleRequest) (*meshes.ApplyRuleResponse, error)

ApplyOperation is a method invoked to apply a particular operation on the mesh in a namespace

func (*Client) CreateMeshInstance

func (iClient *Client) CreateMeshInstance(_ context.Context, k8sReq *meshes.CreateMeshInstanceRequest) (*meshes.CreateMeshInstanceResponse, error)

CreateMeshInstance is called from UI

func (*Client) MeshName

func (iClient *Client) MeshName(context.Context, *meshes.MeshNameRequest) (*meshes.MeshNameResponse, error)

MeshName just returns the name of the mesh the client is representing

func (*Client) StreamEvents

func (iClient *Client) StreamEvents(in *meshes.EventsRequest, stream meshes.MeshService_StreamEventsServer) error

StreamEvents - streams generated/collected events to the client

func (*Client) SupportedOperations

func (iClient *Client) SupportedOperations(context.Context, *meshes.SupportedOperationsRequest) (*meshes.SupportedOperationsResponse, error)

SupportedOperations - returns a list of supported operations on the mesh

type Kubeconfig

type Kubeconfig struct {
	APIVersion string `yaml:"apiVersion,omitempty" json:"apiVersion,omitempty"`
	Clusters   []struct {
		Cluster struct {
			CertificateAuthorityData string `yaml:"certificate-authority-data,omitempty" json:"certificate-authority-data,omitempty"`
			Server                   string `yaml:"server,omitempty" json:"server,omitempty"`
		} `yaml:"cluster,omitempty" json:"cluster,omitempty"`
		Name string `yaml:"name,omitempty" json:"name,omitempty"`
	} `yaml:"clusters,omitempty" json:"clusters,omitempty"`
	Contexts []struct {
		Context struct {
			Cluster   string `yaml:"cluster,omitempty" json:"cluster,omitempty"`
			Namespace string `yaml:"namespace,omitempty" json:"namespace,omitempty"`
			User      string `yaml:"user,omitempty" json:"user,omitempty"`
		} `yaml:"context,omitempty" json:"context,omitempty"`
		Name string `yaml:"name,omitempty" json:"name,omitempty"`
	} `yaml:"contexts,omitempty" json:"contexts,omitempty"`
	CurrentContext string `yaml:"current-context,omitempty" json:"current-context,omitempty"`
	Kind           string `yaml:"kind,omitempty" json:"kind,omitempty"`
	Preferences    struct {
	} `yaml:"preferences,omitempty" json:"preferences,omitempty"`
	Users []struct {
		Name string `yaml:"name,omitempty" json:"name,omitempty"`
		User struct {
			Exec struct {
				APIVersion string   `yaml:"apiVersion,omitempty" json:"apiVersion,omitempty"`
				Args       []string `yaml:"args,omitempty" json:"args,omitempty"`
				Command    string   `yaml:"command,omitempty" json:"command,omitempty"`
				Env        []struct {
					Name  string `yaml:"name,omitempty" json:"name,omitempty"`
					Value string `yaml:"value,omitempty" json:"value,omitempty"`
				} `yaml:"env,omitempty" json:"env,omitempty"`
			} `yaml:"exec,omitempty" json:"exec,omitempty"`
			AuthProvider struct {
				Config struct {
					AccessToken string    `yaml:"access-token,omitempty" json:"access-token,omitempty"`
					CmdArgs     string    `yaml:"cmd-args,omitempty" json:"cmd-args,omitempty"`
					CmdPath     string    `yaml:"cmd-path,omitempty" json:"cmd-path,omitempty"`
					Expiry      time.Time `yaml:"expiry,omitempty" json:"expiry,omitempty"`
					ExpiryKey   string    `yaml:"expiry-key,omitempty" json:"expiry-key,omitempty"`
					TokenKey    string    `yaml:"token-key,omitempty" json:"token-key,omitempty"`
				} `yaml:"config,omitempty" json:"config,omitempty"`
				Name string `yaml:"name,omitempty" json:"name,omitempty"`
			} `yaml:"auth-provider,omitempty" json:"auth-provider,omitempty"`
			ClientCertificateData string `yaml:"client-certificate-data,omitempty" json:"client-certificate-data,omitempty"`
			ClientKeyData         string `yaml:"client-key-data,omitempty" json:"client-key-data,omitempty"`
			Token                 string `yaml:"token,omitempty" json:"token,omitempty"`
		} `yaml:"user,omitempty,omitempty" json:"user,omitempty,omitempty"`
	} `yaml:"users,omitempty" json:"users,omitempty"`
}

Kubeconfig is structure of the kubeconfig file

type YAMLDecoder

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

YAMLDecoder reads chunks of objects and returns ErrShortBuffer if the data is not sufficient. borrowed from APIMachinery

func (*YAMLDecoder) Close

func (d *YAMLDecoder) Close() error

Close closes the decoder

func (*YAMLDecoder) Read

func (d *YAMLDecoder) Read(data []byte) (n int, err error)

Read reads the previous slice into the buffer, or attempts to read the next chunk.