adapter

Jan 29, 2024

Changes in this version

+ var AvailableVersions = map[string]bool

+ var HelmCharts = "HELM_CHARTS"

+ var MeshmodelComponents = filepath.Join(basePath, "templates", "meshmodel", "components")

+ func ErrRegisterComponents(err error) error

+ func RegisterMeshModelComponents(uuid, runtime, host, port string) error

Aug 15, 2023

Changes in this version

type OperationRequest

+ Version string

type Version

+ func (v Version) String() string

Mar 20, 2023

Changes in this version

type MeshModelConfig

+ CategoryMetadata map[string]interface{}

Nov 29, 2022

Changes in this version

+ type MeshModelConfig struct

+ Category string

+ Metadata map[string]interface{}

+ SubCategory string

type StaticCompConfig

+ MeshModelConfig MeshModelConfig

Nov 21, 2022

Changes in this version

+ type MeshModelRegistrant struct

+ HTTPRegistry string

+ Paths []MeshModelRegistrantDefinitionPath

+ func NewMeshModelRegistrant(paths []MeshModelRegistrantDefinitionPath, HTTPRegistry string) *MeshModelRegistrant

+ func (or *MeshModelRegistrant) Register(ctxID string) error

+ type MeshModelRegistrantDefinitionPath struct

+ EntityDefintionPath string

+ Host string

+ Port int

+ Type types.CapabilityType

type StaticCompConfig

+ MeshModelName string

+ MeshModelPath string

+ OAMPath string

Aug 26, 2022

Changes in this version

type Adapter

+ EventStreamer *events.EventStreamer

May 31, 2022

Changes in this version

type Adapter

+ func (a *Adapter) SetChannel(hchan *chan interface{})

type OAMRequest

+ K8sConfigs []string

type OperationRequest

+ K8sConfigs []string

type SMITestOptions

+ Kubeconfigs []string

Jan 17, 2022

Changes in this version

+ const ErrCreatingComponentsCode

+ func CreateComponents(scfg StaticCompConfig) error

+ func ErrCreatingComponents(err error) error

+ type StaticCompConfig struct

+ Config manifests.Config

+ DirName string

+ Force bool

+ Method string

+ Path string

+ URL string

Dec 14, 2021

Changes in this version

+ const ErrAuthInfosInvalidMsgCode

Sep 3, 2021

Changes in this version

+ const ErrGenerateComponentsCode

+ const HelmCHARTS

+ const Manifests

+ const OAMAdapterNameMetadataKey

+ const OAMComponentCategoryMetadataKey

+ func ErrGenerateComponents(err error) error

+ func RegisterWorkLoadsDynamically(runtime, host string, dc *DynamicComponentsConfig) error

+ type DynamicComponentsConfig struct

+ Config manifests.Config

+ GenerationMethod string

+ Operation string

+ TimeoutInMinutes time.Duration

+ URL string

Jun 23, 2021

Changes in this version

+ const ErrConnectSmiCode

+ const ErrDeleteSmiCode

+ const ErrInstallSmiCode

+ const ErrSmiInitCode

May 31, 2021

Changes in this version

type OAMRegistrantData

+ Metadata map[string]string

+ Restricted bool

type OAMRegistrantDefinitionPath

+ Metadata map[string]string

+ Restricted bool

May 17, 2021

Changes in this version

+ const ErrJSONMarshalCode

+ const ErrOAMRetryCode

+ const ErrOpenOAMDefintionFileCode

+ const ErrOpenOAMRefFileCode

+ func ErrJSONMarshal(err error) error

+ func ErrOAMRetry(err error) error

+ func ErrOpenOAMDefintionFile(err error) error

+ func ErrOpenOAMRefFile(err error) error

+ type OAMRegistrant struct

+ OAMHTTPRegistry string

+ Paths []OAMRegistrantDefinitionPath

+ func NewOAMRegistrant(paths []OAMRegistrantDefinitionPath, oamHTTPRegistry string) *OAMRegistrant

+ func (or *OAMRegistrant) Register() error

+ type OAMRegistrantData struct

+ Host string

+ OAMDefinition interface{}

+ OAMRefSchema string

+ type OAMRegistrantDefinitionPath struct

+ Host string

+ OAMDefintionPath string

+ OAMRefSchemaPath string

Apr 9, 2021

Changes in this version

type Adapter

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

type Handler

+ GetComponentInfo func(interface{}) error

Apr 6, 2021

Changes in this version

+ const ErrNoResponseCode

+ var ErrNoResponse = errors.NewDefault(ErrNoResponseCode, "No response from the smi tool")

type Adapter

+ func (h *Adapter) ProcessOAM(context.Context, OAMRequest) (string, error)

type Handler

+ ProcessOAM func(ctx context.Context, srv OAMRequest) (string, error)

+ type OAMRequest struct

+ DeleteOp bool

+ OamComps []string

+ OamConfig string

+ Username string

Jan 27, 2021

Changes in this version

type Adapter

+ func (h *Adapter) GetType() string

type Spec

+ Type string

Dec 24, 2020

Changes in this version

+ var ErrAuthInfosInvalidMsg = fmt.Errorf(...)

Dec 15, 2020

Changes in this version

+ func ErrConnectSmi(err error) error

+ func ErrDeleteSmi(err error) error

+ func ErrInstallSmi(err error) error

+ func ErrSmiInit(des string) error

type Adapter

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

+ type Detail struct

+ Assertions string

+ Capability string

+ Reason string

+ Result string

+ SmiSpecification string

+ SmiVersion string

+ Status string

+ Time string

+ type Response struct

+ CasesPassed string

+ Date string

+ ID string

+ MeshName string

+ MeshVersion string

+ MoreDetails []*Detail

+ PassingPercentage string

+ Status string

+ type SMITest struct

+ type SMITestOptions struct

+ Annotations map[string]string

+ Ctx context.Context

+ Labels map[string]string

+ Manifest string

+ Namespace string

+ OperationID string

Dec 8, 2020

Changes in this version

type Operation

+ Services []Service

+ type Service string

Nov 23, 2020

Changes in this version

type Adapter

+ MesheryKubeclient *mesherykube.Client

Nov 19, 2020

Changes in this version

type Adapter

+ KubeconfigHandler config.Handler

Nov 18, 2020

Changes in this version

+ const ErrCreateInstanceCode

+ const ErrValidateKubeconfigCode

+ var NoneTemplate = []Template

+ var NoneVersion = []Version

+ func ErrCreateInstance(err error) error

+ func ErrValidateKubeconfig(err error) error

type Adapter

+ ClientcmdConfig *clientcmdapi.Config

+ RestConfig rest.Config

type Operation

+ AdditionalProperties map[string]string

+ Description string

+ Templates []Template

+ Versions []Version

+ type Template string

+ func (t Template) String() string

+ type Version string

Nov 9, 2020

Changes in this version

+ const ErrApplyOperationCode

+ const ErrClientConfigCode

+ const ErrClientSetCode

+ const ErrGetNameCode

+ const ErrInstallMeshCode

+ const ErrListOperationsCode

+ const ErrMeshConfigCode

+ const ErrNewSmiCode

+ const ErrOpInvalidCode

+ const ErrPortForwardCode

+ const ErrRunSmiCode

+ const ErrStreamEventCode

+ func ErrListOperations(err error) error

+ func ErrNewSmi(err error) error

+ func ErrRunSmi(err error) error

type Adapter

+ func (h *Adapter) GetVersion() string

+ func (h *Adapter) ValidateSMIConformance(opts *SmiTestOptions) error

+ type SmiTestOptions struct

+ Annotations map[string]string

+ Ctx context.Context

+ Labels map[string]string

+ OpID string

Nov 4, 2020

Changes in this version

+ const OperationDescriptionKey

+ const OperationServiceNameKey

+ const OperationTemplateNameKey

+ const OperationVersionKey

+ var ErrGetName = errors.NewDefault(errors.ErrGetName, "Unable to get mesh name")

+ var ErrOpInvalid = errors.NewDefault(errors.ErrOpInvalid, "Invalid operation")

+ var KubeconfigPathKey = fmt.Sprintf("%s/.kube/config", utils.GetHome())

+ var MeshInstanceKey = "instance"

+ var MeshSpecKey = "mesh"

+ var OperationsKey = "operations"

+ var ServerKey = "server"

+ func ErrClientConfig(err error) error

+ func ErrClientSet(err error) error

+ func ErrInstallMesh(err error) error

+ func ErrMeshConfig(err error) error

+ func ErrPortForward(err error) error

+ func ErrStreamEvent(err error) error

+ func NewDocumentDecoder(r io.ReadCloser) io.ReadCloser

+ type Adapter struct

+ Channel *chan interface{}

+ Config config.Handler

+ DynamicKubeClient dynamic.Interface

+ KubeClient *kubernetes.Clientset

+ KubeConfigPath string

+ Log logger.Handler

+ SmiChart string

+ func (h *Adapter) ApplyKubernetesManifest(request OperationRequest, operation Operation, mergeData map[string]string, ...) error

+ func (h *Adapter) ApplyOperation(context.Context, OperationRequest) error

+ func (h *Adapter) CreateInstance(kubeconfig []byte, contextName string, ch *chan interface{}) error

+ func (h *Adapter) CreateNamespace(isDelete bool, namespace string) error

+ func (h *Adapter) GetName() string

+ func (h *Adapter) GetServicePorts(serviceName, namespace string) ([]int64, error)

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

+ func (h *Adapter) StreamErr(e *Event, err error)

+ func (h *Adapter) StreamInfo(e *Event)

+ type Event struct

+ Details string

+ EType int32

+ Operationid string

+ Summary string

+ type Handler interface

+ ApplyOperation func(context.Context, OperationRequest) error

+ CreateInstance func([]byte, string, *chan interface{}) error

+ GetName func() string

+ ListOperations func() (Operations, error)

+ StreamErr func(*Event, error)

+ StreamInfo func(*Event)

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

+ type Operation struct

+ Properties map[string]string

+ Type int32

+ type OperationRequest struct

+ CustomBody string

+ IsDeleteOperation bool

+ Namespace string

+ OperationID string

+ OperationName string

+ Username string

+ type Operations map[string]*Operation

+ type Spec struct

+ Name string

+ Status string

+ Version string

+ type YAMLDecoder struct

+ func (d *YAMLDecoder) Close() error

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