Documentation
¶
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 YAMLDecoder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 Cpx 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 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
Source Files