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 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 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.