pipeline

package

v0.2.0 Latest Latest Go to latest Published: Dec 14, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/layer5io/meshery-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Initialize(client *discovery.Client, broker broker.Handler) *pipeline.Pipeline
type Cluster
- func NewCluster(client *discovery.Client, broker broker.Handler) *Cluster
- func (c *Cluster) Cancel() error
- func (c *Cluster) Exec(request *pipeline.Request) *pipeline.Result
type Deployment
- func NewDeployment(client *discovery.Client, broker broker.Handler) *Deployment
- func (d *Deployment) Cancel() error
- func (d *Deployment) Exec(request *pipeline.Request) *pipeline.Result
type Namespace
- func NewNamespace(client *discovery.Client, broker broker.Handler) *Namespace
- func (n *Namespace) Cancel() error
- func (n *Namespace) Exec(request *pipeline.Request) *pipeline.Result
type Node
- func NewNode(client *discovery.Client, broker broker.Handler) *Node
- func (n *Node) Cancel() error
- func (n *Node) Exec(request *pipeline.Request) *pipeline.Result
type Pod
- func NewPod(client *discovery.Client, broker broker.Handler) *Pod
- func (p *Pod) Cancel() error
- func (p *Pod) Exec(request *pipeline.Request) *pipeline.Result

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	Name                 = "Cluster-Pipeline"
	GlobalDiscoveryStage = &pipeline.Stage{
		Name:       "Global-Resource-Discovery",
		Concurrent: false,
		Steps:      []pipeline.Step{},
	}

	LocalDiscoveryStage = &pipeline.Stage{
		Name:       "Local-Resource-Discovery",
		Concurrent: false,
		Steps:      []pipeline.Step{},
	}
	Subject = "cluster"
)

View Source

var NamespaceName []string

Functions ¶

func Initialize ¶

func Initialize(client *discovery.Client, broker broker.Handler) *pipeline.Pipeline

Types ¶

type Cluster ¶

type Cluster struct {
	pipeline.StepContext
	// contains filtered or unexported fields
}

func NewCluster ¶

func NewCluster(client *discovery.Client, broker broker.Handler) *Cluster

func (*Cluster) Cancel ¶

func (c *Cluster) Cancel() error

Cancel - step interface

func (*Cluster) Exec ¶

func (c *Cluster) Exec(request *pipeline.Request) *pipeline.Result

Exec - step interface

type Deployment ¶

type Deployment struct {
	pipeline.StepContext
	// contains filtered or unexported fields
}

Deployment will implement step interface for Deployments

func NewDeployment ¶

func NewDeployment(client *discovery.Client, broker broker.Handler) *Deployment

NewDeployment - constructor

func (*Deployment) Cancel ¶

func (d *Deployment) Cancel() error

Cancel - step interface

func (*Deployment) Exec ¶

func (d *Deployment) Exec(request *pipeline.Request) *pipeline.Result

Exec - step interface

type Namespace ¶

type Namespace struct {
	pipeline.StepContext
	// contains filtered or unexported fields
}

Namespace will implement step interface for Namespaces

func NewNamespace ¶

func NewNamespace(client *discovery.Client, broker broker.Handler) *Namespace

NewNamespace - constructor

func (*Namespace) Cancel ¶

func (n *Namespace) Cancel() error

Cancel - step interface

func (*Namespace) Exec ¶

func (n *Namespace) Exec(request *pipeline.Request) *pipeline.Result

Exec - step interface

type Node ¶

type Node struct {
	pipeline.StepContext
	// contains filtered or unexported fields
}

Node will implement step interface for Nodes

func NewNode ¶

func NewNode(client *discovery.Client, broker broker.Handler) *Node

NewNode - constructor

func (*Node) Cancel ¶

func (n *Node) Cancel() error

Cancel - step interface

func (*Node) Exec ¶

func (n *Node) Exec(request *pipeline.Request) *pipeline.Result

Exec - step interface

type Pod ¶

type Pod struct {
	pipeline.StepContext
	// contains filtered or unexported fields
}

Pod will implement step interface for Pods

func NewPod ¶

func NewPod(client *discovery.Client, broker broker.Handler) *Pod

NewPod - constructor

func (*Pod) Cancel ¶

func (p *Pod) Cancel() error

Cancel - step interface

func (*Pod) Exec ¶

func (p *Pod) Exec(request *pipeline.Request) *pipeline.Result

Exec - step interface

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL