operator

Documentation

Index

• Variables
• type AdminComponent
  • func (ac *AdminComponent) RenderManifest() (string, error)
  • func (ac *AdminComponent) Run() error
• type Component
  • func NewAdminComponent(spec *v1alpha1.AdminSpec, opts ...ComponentOption) (Component, error)
  • func NewGrafanaComponent(spec *v1alpha1.GrafanaSpec, opts ...ComponentOption) (Component, error)
  • func NewNacosComponent(spec *v1alpha1.NacosSpec, opts ...ComponentOption) (Component, error)
  • func NewPrometheusComponent(spec *v1alpha1.PrometheusSpec, opts ...ComponentOption) (Component, error)
  • func NewSkywalkingComponent(spec *v1alpha1.SkywalkingSpec, opts ...ComponentOption) (Component, error)
  • func NewZipkinComponent(spec *v1alpha1.ZipkinSpec, opts ...ComponentOption) (Component, error)
  • func NewZookeeperComponent(spec *v1alpha1.ZookeeperSpec, opts ...ComponentOption) (Component, error)
• type ComponentName
• type ComponentOption
  • func WithChartPath(path string) ComponentOption
  • func WithNamespace(namespace string) ComponentOption
  • func WithRepoURL(url string) ComponentOption
  • func WithVersion(version string) ComponentOption
• type ComponentOptions
• type DubboOperator
  • func NewDubboOperator(spec *v1alpha1.DubboConfigSpec, cli *kube.CtlClient) (*DubboOperator, error)
  • func (do *DubboOperator) ApplyManifest(manifestMap map[ComponentName]string) error
  • func (do *DubboOperator) RemoveManifest(manifestMap map[ComponentName]string) error
  • func (do *DubboOperator) RenderManifest() (map[ComponentName]string, error)
  • func (do *DubboOperator) Run() error
• type GrafanaComponent
  • func (gc *GrafanaComponent) RenderManifest() (string, error)
  • func (gc *GrafanaComponent) Run() error
• type NacosComponent
  • func (nc *NacosComponent) RenderManifest() (string, error)
  • func (nc *NacosComponent) Run() error
• type PrometheusComponent
  • func (pc *PrometheusComponent) RenderManifest() (string, error)
  • func (pc *PrometheusComponent) Run() error
• type SkywalkingComponent
  • func (sc *SkywalkingComponent) RenderManifest() (string, error)
  • func (sc *SkywalkingComponent) Run() error
• type ZipkinComponent
  • func (zc *ZipkinComponent) RenderManifest() (string, error)
  • func (zc *ZipkinComponent) Run() error
• type ZookeeperComponent
  • func (zc *ZookeeperComponent) RenderManifest() (string, error)
  • func (zc *ZookeeperComponent) Run() error

Variables

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

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