adapter

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 19 Imported by: 44

Documentation

Overview

Package adapter provides the default implementation of an adapter Handler, called by the MeshServiceServer implementation.

It implements also common Kubernetes operations, leveraging the comparatively low-level client-go library, and handling of YAML-documents.

Index

Constants

View Source 
const (
	ErrGetNameCode             = "1000"
	ErrCreateInstanceCode      = "1001"
	ErrMeshConfigCode          = "1002"
	ErrValidateKubeconfigCode  = "1003"
	ErrClientConfigCode        = "1004"
	ErrClientSetCode           = "1005"
	ErrStreamEventCode         = "1006"
	ErrOpInvalidCode           = "1007"
	ErrApplyOperationCode      = "1008"
	ErrListOperationsCode      = "1009"
	ErrNewSmiCode              = "1010"
	ErrRunSmiCode              = "1011"
	ErrNoResponseCode          = "1011"
	ErrJSONMarshalCode         = "1015"
	ErrSmiInitCode             = "1007"
	ErrInstallSmiCode          = "1008"
	ErrConnectSmiCode          = "1009"
	ErrDeleteSmiCode           = "1010"
	ErrGenerateComponentsCode  = "1011"
	ErrAuthInfosInvalidMsgCode = "1012"
	ErrCreatingComponentsCode  = "1013"
)
View Source 
const (
	ServerKey         = "server"
	MeshSpecKey       = "mesh"
	OperationsKey     = "operations"
	KubeconfigPathKey = "kubeconfig-path"
)

Variables

View Source 
var (
	ErrGetName    = errors.New(ErrGetNameCode, errors.Alert, []string{"Unable to get mesh name"}, []string{}, []string{}, []string{})
	ErrOpInvalid  = errors.New(ErrOpInvalidCode, errors.Alert, []string{"Invalid operation"}, []string{}, []string{}, []string{})
	ErrNoResponse = errors.New(ErrNoResponseCode, errors.Alert, []string{"No response from the smi tool"}, []string{}, []string{}, []string{})
	// ErrAuthInfosInvalidMsg is the error message when the all of auth infos have invalid or inaccessible paths
	// as there certificate paths
	ErrAuthInfosInvalidMsg = errors.New(
		ErrAuthInfosInvalidMsgCode,
		errors.Alert,
		[]string{"none of the auth info is valid. Certificate path is invalid or is inaccessible"},
		[]string{"One or more Kubernetes authentication info is either invalid or the certificate paths are invalid causing Meshery adapter setup failure"},
		[]string{"kubeconfig passed to Meshery may be referring to a \"context\" whose auth info is a file path", "adapter may have cached a copy of kubeconfig"},
		[]string{"ensure kubeconfig passed to Meshery is flattened", "if running adapter in Kubernetes, attempt to restart the pod; in development environment try deleting ~/.meshery s"},
	)
)
View Source 
var (
	NoneVersion  = []Version{"none"}
	NoneTemplate = []Template{"none"}
)

Functions

func ErrClientConfig 

func ErrClientConfig(err error) error

func ErrClientSet 

func ErrClientSet(err error) error

func ErrConnectSmi added in v0.1.10 

func ErrConnectSmi(err error) error

ErrConnectSmi is the error for connecting to smi tool

func ErrCreateInstance added in v0.1.4 

func ErrCreateInstance(err error) error

func ErrCreatingComponents added in v0.5.2 

func ErrCreatingComponents(err error) error

ErrCreatingComponents

func ErrDeleteSmi added in v0.1.10 

func ErrDeleteSmi(err error) error

ErrDeleteSmi is the error for deleting smi tool

func ErrGenerateComponents added in v0.1.23 

func ErrGenerateComponents(err error) error

will be depracated

func ErrInstallSmi added in v0.1.10 

func ErrInstallSmi(err error) error

ErrInstallSmi is the error for installing smi tool

func ErrListOperations added in v0.1.2 

func ErrListOperations(err error) error

func ErrMeshConfig 

func ErrMeshConfig(err error) error

func ErrNewSmi added in v0.1.2 

func ErrNewSmi(err error) error

func ErrRunSmi added in v0.1.2 

func ErrRunSmi(err error) error

func ErrSmiInit added in v0.1.10 

func ErrSmiInit(des string) error

ErrSmiInit is the error for smi init method

func ErrStreamEvent 

func ErrStreamEvent(err error) error

func ErrValidateKubeconfig added in v0.1.4 

func ErrValidateKubeconfig(err error) error

Types

type Adapter 

type Adapter struct {
	Config            meshkitCfg.Handler
	KubeconfigHandler meshkitCfg.Handler
	Log               logger.Handler
	EventStreamer     *events.EventStreamer
}

Adapter contains all handlers, channels, clients, and other parameters for an adapter. Use type embedding in a specific adapter to extend it.

func (*Adapter) ApplyOperation 

func (h *Adapter) ApplyOperation(ctx context.Context, op OperationRequest, hchan *chan interface{}) error

Applies an adapter operation. This is adapter specific and needs to be implemented by each adapter.

func (*Adapter) GetComponentInfo added in v0.1.14 

func (h *Adapter) GetComponentInfo(svc interface{}) error

func (*Adapter) GetName 

func (h *Adapter) GetName() string

func (*Adapter) GetVersion added in v0.1.2 

func (h *Adapter) GetVersion() string

func (*Adapter) ListOperations 

func (h *Adapter) ListOperations() (Operations, error)

List all operations an adapter supports.

func (*Adapter) RunSMITest added in v0.1.10 

func (h *Adapter) RunSMITest(opts SMITestOptions) (Response, error)

RunSMITest runs the SMI test on the adapter's service mesh

func (*Adapter) StreamErr 

func (h *Adapter) StreamErr(e *meshes.EventsResponse, err error)

func (*Adapter) StreamInfo 

func (h *Adapter) StreamInfo(e *meshes.EventsResponse)

type Detail added in v0.1.10 

type Detail struct {
	SmiSpecification string `json:"smi_specification,omitempty"`
	SmiVersion       string `json:"smi_version,omitempty"`
	Time             string `json:"time,omitempty"`
	Assertions       string `json:"assertions,omitempty"`
	Result           string `json:"result,omitempty"`
	Reason           string `json:"reason,omitempty"`
	Capability       string `json:"capability,omitempty"`
	Status           string `json:"status,omitempty"`
}

type Handler 

type Handler interface {
	GetName() string                    // Returns the name of the adapter.
	GetComponentInfo(interface{}) error // Returns the component info.
	// CreateInstance(*chan interface{}) error                 // Instantiates clients used in deploying and managing mesh instances, e.g. Kubernetes clients.
	ApplyOperation(context.Context, OperationRequest) error // Applies an adapter operation. This is adapter specific and needs to be implemented by each adapter.
	ListOperations() (Operations, error)                    // List all operations an adapter supports.
	StreamErr(*meshes.EventsResponse, error)                // Streams an error event, e.g. to a channel
	StreamInfo(*meshes.EventsResponse)                      // Streams an informational event, e.g. to a channel
}

Interface Handler is extended by adapters, and used in package api/grpc that implements the MeshServiceServer.

func AddLogger 

func AddLogger(logger logger.Handler, h Handler) Handler

type Operation 

type Operation struct {
	Type                 int32             `json:"type,string,omitempty"`
	Description          string            `json:"description,omitempty"`
	Versions             []Version         `json:"versions,omitempty"`
	Templates            []Template        `json:"templates,omitempty"`
	Services             []Service         `json:"services,omitempty"`
	AdditionalProperties map[string]string `json:"additional_properties,omitempty"`
}

Operation represents an operation of a given Type (see meshes.OpCategory), with a set of properties.

type OperationRequest 

type OperationRequest struct {
	OperationName     string // The identifier of the operation. It is used as key in the Operations map. Avoid using a verb as part of the name, as it designates both provisioning as deprovisioning operations.
	Namespace         string // The namespace to use in the environment, e.g. Kubernetes, where the operation is applied.
	Username          string // User to execute operation as, if any.
	CustomBody        string // Custom operation manifest, in the case of a custom operation (OpCategory_CUSTOM).
	IsDeleteOperation bool   // If true, the operation specified by OperationName is reverted, i.e. all resources created are deleted.
	OperationID       string // ID of the operation, if any. This identifies a specific operation invocation.
	K8sConfigs        []string
	Version           string // Service mesh version to be installed, defaults to latest version.
}

OperationRequest contains the request data from meshes.ApplyRuleRequest.

type Operations 

type Operations map[string]*Operation

Operations contains all operations supported by an adapter.

type Response added in v0.1.10 

type Response struct {
	ID                string    `json:"id,omitempty"`
	Date              string    `json:"date,omitempty"`
	MeshName          string    `json:"mesh_name,omitempty"`
	MeshVersion       string    `json:"mesh_version,omitempty"`
	CasesPassed       string    `json:"cases_passed,omitempty"`
	PassingPercentage string    `json:"passing_percentage,omitempty"`
	Status            string    `json:"status,omitempty"`
	MoreDetails       []*Detail `json:"more_details,omitempty"`
}

type SMITest added in v0.1.10 

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

type SMITestOptions added in v0.1.10 

type SMITestOptions struct {
	Ctx         context.Context
	OperationID string

	// Namespace is the namespace where the SMI conformance
	// must be installed
	//
	// Defaults to "meshery"
	Namespace string

	// Manifest is the remote location of manifest
	Manifest string

	// Labels is the standard kubernetes labels
	Labels map[string]string

	// Annotations is the standard kubernetes annotations
	Annotations map[string]string

	Kubeconfigs []string
}

SMITestOptions describes the options for the SMI Test runner

type Service added in v0.1.8 

type Service string

type Spec 

type Spec struct {
	Name    string `json:"name"`
	Status  string `json:"status"`
	Version string `json:"version"`
}

type Template added in v0.1.4 

type Template string

func (Template) String added in v0.1.4 

func (t Template) String() string

type Version added in v0.1.4 

type Version string

func (Version) String added in v0.6.9 

func (v Version) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.