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) 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 ConformanceResponse
• type Failure
• type SingleConformanceResponse
• 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) 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 ConformanceResponse

type ConformanceResponse struct {
	Tests    string                       `json:"tests,omitempty"`
	Failures string                       `json:"failures,omitempty"`
	Results  []*SingleConformanceResponse `json:"results,omitempty"`
}

type Failure

type Failure struct {
	Text    string `json:"text,omitempty"`
	Message string `json:"message,omitempty"`
}

type SingleConformanceResponse

type SingleConformanceResponse struct {
	Name       string   `json:"name,omitempty"`
	Time       string   `json:"time,omitempty"`
	Assertions string   `json:"assertions,omitempty"`
	Failure    *Failure `json:"failure,omitempty"`
}

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.