stages

Documentation

Index

• Constants
• Variables
• type Chain
  • func CreateChain() *Chain
  • func (ch *Chain) Add(fn ChainStageFunction) *Chain
  • func (ch *Chain) Clear() *Chain
  • func (ch *Chain) Process(data *Data) *Chain
• type ChainStageFunction
  • func Filler(skipPrintLogs bool) ChainStageFunction
  • func Import(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction
  • func Persist(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction
  • func Provision(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction
  • func ServiceIdentifier(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction
  • func Validator(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction
• type ChainStageNextFunction
• type ChainStages
• type CompConfigPair
• type Data
• type ServiceActionProvider
• type ServiceInfoProvider

Constants

const FillerPattern = `\$\(#ref\..+\)`

const ImportPattern = `\$\(#use\s.+\)`

const ProvisionSuffixKey = ".isProvisioned"

const UpdateSuffixKey = ".isUpdate"

Variables

var FillerRegex *regexp.Regexp

var ImportRegex *regexp.Regexp

Types

type Chain

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

Chain allows to add any number of stages to be added to itself allowing "chaining" all of those functions

func CreateChain

func CreateChain() *Chain

CreateChain returns a pointer to the chain object

func (*Chain) Add

func (ch *Chain) Add(fn ChainStageFunction) *Chain

Add adds a function to the chain and returns a pointer to the Chain object

func (*Chain) Clear

func (ch *Chain) Clear() *Chain

Clear clears the chain and returns a pointer to the chain object

func (*Chain) Process

func (ch *Chain) Process(data *Data) *Chain

Process takes in a plan and starts the chain of the functions

Returns a pointer to the Chain object

type ChainStageFunction

type ChainStageFunction func(data *Data, err error, next ChainStageNextFunction)

ChainStageFunction is the type for function that will be invoked on each stage of the chain

func Filler

func Filler(skipPrintLogs bool) ChainStageFunction

Filler - filler stage processes the pattern to subsitute Pattern

func Import

func Import(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction

func Persist

func Persist(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction

func Provision

func Provision(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction

func ServiceIdentifier

func ServiceIdentifier(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction

ServiceIdentifier takes in a service identity provider and returns a ChainStageFunction

func Validator

func Validator(prov ServiceInfoProvider, act ServiceActionProvider) ChainStageFunction

type ChainStageNextFunction

type ChainStageNextFunction func(data *Data, err error)

type ChainStages

type ChainStages []ChainStageNextFunction

ChainStages type represents a slice of ChainStageFunction

type CompConfigPair

type CompConfigPair struct {
	Component     v1alpha1.Component
	Configuration v1alpha1.Configuration
	Hosts         map[string]bool
}

type Data

type Data struct {
	Pattern                        *core.Pattern
	PatternSvcWorkloadCapabilities map[string]core.WorkloadCapability
	PatternSvcTraitCapabilities    map[string][]core.TraitCapability

	// Other is for passing metadata across different stages
	Lock  sync.Mutex
	Other map[string]interface{}
}

Data is the struct that will be passed on each stage

type ServiceActionProvider

type ServiceActionProvider interface {
	Terminate(error)
	Provision(CompConfigPair) (string, error)
	Persist(string, core.Service, bool) error
}

type ServiceInfoProvider

type ServiceInfoProvider interface {
	GetMesheryPatternResource(
		name string,
		namespace string,
		typ string,
		oamType string,
	) (ID *uuid.UUID, err error)
	GetServiceMesh() (name string, version string)
	GetAPIVersionForKind(kind string) string
	IsDelete() bool
}