operator

package
v0.0.0-...-97dd610 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ComponentMap = map[string]ComponentName{
	"admin":      Admin,
	"grafana":    Grafana,
	"nacos":      Nacos,
	"zookeeper":  Zookeeper,
	"prometheus": Prometheus,
	"skywalking": Skywalking,
	"zipkin":     Zipkin,
}

Functions

This section is empty.

Types

type AdminComponent 

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

func (*AdminComponent) RenderManifest 

func (ac *AdminComponent) RenderManifest() (string, error)

func (*AdminComponent) Run 

func (ac *AdminComponent) Run() error

type Component 

type Component interface {
	Run() error
	RenderManifest() (string, error)
}

Component is used to represent dubbo control plane module, eg: zookeeper

func NewAdminComponent 

func NewAdminComponent(spec *v1alpha1.AdminSpec, opts ...ComponentOption) (Component, error)

func NewGrafanaComponent 

func NewGrafanaComponent(spec *v1alpha1.GrafanaSpec, opts ...ComponentOption) (Component, error)

func NewNacosComponent 

func NewNacosComponent(spec *v1alpha1.NacosSpec, opts ...ComponentOption) (Component, error)

func NewPrometheusComponent 

func NewPrometheusComponent(spec *v1alpha1.PrometheusSpec, opts ...ComponentOption) (Component, error)

func NewSkywalkingComponent 

func NewSkywalkingComponent(spec *v1alpha1.SkywalkingSpec, opts ...ComponentOption) (Component, error)

func NewZipkinComponent 

func NewZipkinComponent(spec *v1alpha1.ZipkinSpec, opts ...ComponentOption) (Component, error)

func NewZookeeperComponent 

func NewZookeeperComponent(spec *v1alpha1.ZookeeperSpec, opts ...ComponentOption) (Component, error)

type ComponentName 

type ComponentName string
const (
	Admin      ComponentName = "admin"
	Grafana    ComponentName = "grafana"
	Nacos      ComponentName = "nacos"
	Zookeeper  ComponentName = "zookeeper"
	Prometheus ComponentName = "prometheus"
	Skywalking ComponentName = "skywalking"
	Zipkin     ComponentName = "zipkin"
)

type ComponentOption 

type ComponentOption func(*ComponentOptions)

func WithChartPath 

func WithChartPath(path string) ComponentOption

func WithNamespace 

func WithNamespace(namespace string) ComponentOption

func WithRepoURL 

func WithRepoURL(url string) ComponentOption

func WithVersion 

func WithVersion(version string) ComponentOption

type ComponentOptions 

type ComponentOptions struct {
	Namespace string

	// local
	ChartPath string

	// remote
	RepoURL string
	Version string
}

type DubboOperator 

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

func NewDubboOperator 

func NewDubboOperator(spec *v1alpha1.DubboConfigSpec, cli *kube.CtlClient) (*DubboOperator, error)

NewDubboOperator accepts cli directly for testing and normal use. For now, every related command needs a dedicated DubboOperator.

func (*DubboOperator) ApplyManifest 

func (do *DubboOperator) ApplyManifest(manifestMap map[ComponentName]string) error

ApplyManifest apply component manifests to k8s cluster

func (*DubboOperator) RemoveManifest 

func (do *DubboOperator) RemoveManifest(manifestMap map[ComponentName]string) error

RemoveManifest removes resources represented by component manifests

func (*DubboOperator) RenderManifest 

func (do *DubboOperator) RenderManifest() (map[ComponentName]string, error)

RenderManifest renders component manifests specified by DubboConfigSpec.

func (*DubboOperator) Run 

func (do *DubboOperator) Run() error

Run must be invoked before invoking other functions.

type GrafanaComponent 

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

func (*GrafanaComponent) RenderManifest 

func (gc *GrafanaComponent) RenderManifest() (string, error)

func (*GrafanaComponent) Run 

func (gc *GrafanaComponent) Run() error

type NacosComponent 

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

func (*NacosComponent) RenderManifest 

func (nc *NacosComponent) RenderManifest() (string, error)

func (*NacosComponent) Run 

func (nc *NacosComponent) Run() error

type PrometheusComponent 

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

func (*PrometheusComponent) RenderManifest 

func (pc *PrometheusComponent) RenderManifest() (string, error)

func (*PrometheusComponent) Run 

func (pc *PrometheusComponent) Run() error

type SkywalkingComponent 

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

func (*SkywalkingComponent) RenderManifest 

func (sc *SkywalkingComponent) RenderManifest() (string, error)

func (*SkywalkingComponent) Run 

func (sc *SkywalkingComponent) Run() error

type ZipkinComponent 

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

func (*ZipkinComponent) RenderManifest 

func (zc *ZipkinComponent) RenderManifest() (string, error)

func (*ZipkinComponent) Run 

func (zc *ZipkinComponent) Run() error

type ZookeeperComponent 

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

func (*ZookeeperComponent) RenderManifest 

func (zc *ZookeeperComponent) RenderManifest() (string, error)

func (*ZookeeperComponent) Run 

func (zc *ZookeeperComponent) Run() error

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.