operation

package
v0.4.1-alpha.4 Latest Latest
Warning

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

 Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 30 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	ImplicitRefPrefix = "$kusion_path."
)

Variables

View Source 
var (
	CreateChangeStepFilter   = func(c *ChangeStep) bool { return c.Action == Create }
	UpdateChangeStepFilter   = func(c *ChangeStep) bool { return c.Action == Update }
	DeleteChangeStepFilter   = func(c *ChangeStep) bool { return c.Action == Delete }
	UnChangeChangeStepFilter = func(c *ChangeStep) bool { return c.Action == UnChange }
)
View Source 
var ImplicitReplaceFun = func(resourceIndex map[string]*states.ResourceState, refPath string) (reflect.Value, status.Status) {
	const Sep = "."
	split := strings.Split(refPath, Sep)
	key := split[0]
	priorState := resourceIndex[key]
	if priorState == nil {
		msg := fmt.Sprintf("can't find state by key:%s when replacing %s", key, refPath)
		return reflect.Value{}, status.NewErrorStatusWithMsg(status.IllegalManifest, msg)
	}
	attributes := priorState.Attributes
	if attributes == nil {
		msg := fmt.Sprintf("attributes is nil in resource:%s", key)
		return reflect.Value{}, status.NewErrorStatusWithMsg(status.IllegalManifest, msg)
	}
	var valueMap interface{}
	valueMap = attributes
	if len(split) > 1 {
		split := split[1:]
		for _, k := range split {
			if valueMap.(map[string]interface{})[k] == nil {
				msg := fmt.Sprintf("can't find specified value in resource:%s by ref:%s", key, refPath)
				return reflect.Value{}, status.NewErrorStatusWithMsg(status.IllegalManifest, msg)
			}
			valueMap = valueMap.(map[string]interface{})[k]
		}
	}
	return reflect.ValueOf(valueMap), nil
}

Functions

func Deduplicate 

func Deduplicate(refNodeKeys []string) []string

func DiffReport 

func DiffReport(prior, plan, mode string) (string, error)

func DiffWithRequestResourceAndState 

func DiffWithRequestResourceAndState(plan *manifest.Manifest, latest *states.State) (string, error)

func GetVertex 

func GetVertex(g *dag.AcyclicGraph, nv dag.NamedVertex) interface{}

func LinkRefNodes 

func LinkRefNodes(graph *dag.AcyclicGraph, refNodeKeys []string, resourceIndex map[string]*states.ResourceState,
	rn dag.Vertex, defaultAction ActionType, manifestGraphMap map[string]interface{}) status.Status

func LoadFile 

func LoadFile(yaml, location string) (ytbx.InputFile, error)

LoadFile processes the provided input location to load it as one of the supported document formats, or plain text if nothing else works.

func NewApplyGraph 

func NewApplyGraph(m *manifest.Manifest, priorState *states.State) (*dag.AcyclicGraph, status.Status)

func NewDestroyGraph 

func NewDestroyGraph(resource states.Resources) (*dag.AcyclicGraph, status.Status)

func ParseImplicitRef 

func ParseImplicitRef(v reflect.Value, resourceIndex map[string]*states.ResourceState,
	replaceFun func(resourceIndex map[string]*states.ResourceState, refPath string) (reflect.Value, status.Status),
) ([]string, reflect.Value, status.Status)

Types

type ActionType 

type ActionType int64

ActionType represents the kind of operation performed by a plan. It evaluates to its string label. 

const (
	Undefined ActionType = iota // invalidate value
	UnChange                    // nothing to do.
	Create                      // creating a new resource.
	Update                      // updating an existing resource.
	Delete                      // deleting an existing resource.
)

ActionType values

func (ActionType) Ing 

func (t ActionType) Ing() string

func (ActionType) PrettyString 

func (t ActionType) PrettyString() string

func (ActionType) String 

func (t ActionType) String() string

type ApplyOperation 

type ApplyOperation struct {
	Operation
}

type ApplyRequest 

type ApplyRequest struct {
	Request `json:",inline" yaml:",inline"`
}

type ApplyResponse 

type ApplyResponse struct {
	State *states.State
}

type BaseNode 

type BaseNode struct {
	ID string
}

func (*BaseNode) Hashcode 

func (b *BaseNode) Hashcode() interface{}

func (*BaseNode) Name 

func (b *BaseNode) Name() string

type ChangeOrder added in v0.4.1 

type ChangeOrder struct {
	StepKeys    []string
	ChangeSteps map[string]*ChangeStep
}

func (*ChangeOrder) Diffs added in v0.4.1 

func (o *ChangeOrder) Diffs() string

func (*ChangeOrder) Get added in v0.4.1 

func (o *ChangeOrder) Get(key string) *ChangeStep

func (*ChangeOrder) OutputDiff added in v0.4.1 

func (o *ChangeOrder) OutputDiff(target string)

func (*ChangeOrder) PromptDetails added in v0.4.1 

func (o *ChangeOrder) PromptDetails() (string, error)

func (*ChangeOrder) Values added in v0.4.1 

func (o *ChangeOrder) Values(filters ...ChangeStepFilterFunc) []*ChangeStep

type ChangeStep 

type ChangeStep struct {
	ID     string      // the resource id
	Action ActionType  // the operation performed by this step.
	Old    interface{} // the state of the resource before performing this step.
	New    interface{} // the state of the resource after performing this step.
}

func NewChangeStep 

func NewChangeStep(id string, op ActionType, oldData, newData interface{}) *ChangeStep

func (*ChangeStep) Diff 

func (cs *ChangeStep) Diff() (string, error)

type ChangeStepFilterFunc 

type ChangeStepFilterFunc func(*ChangeStep) bool

type Changes 

type Changes struct {
	*ChangeOrder
	// contains filtered or unexported fields
}

func NewChanges 

func NewChanges(p *projectstack.Project, s *projectstack.Stack, order *ChangeOrder) *Changes

func (*Changes) Project 

func (p *Changes) Project() *projectstack.Project

func (*Changes) Stack 

func (p *Changes) Stack() *projectstack.Stack

func (*Changes) Summary 

func (p *Changes) Summary()

type DeleteResourceParser 

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

func NewDeleteResourceParser 

func NewDeleteResourceParser(resources states.Resources) *DeleteResourceParser

func (*DeleteResourceParser) Parse 

func (d *DeleteResourceParser) Parse(graph *dag.AcyclicGraph) (s status.Status)

type DestroyOperation 

type DestroyOperation struct {
	Operation
}

type DestroyRequest 

type DestroyRequest struct {
	Request `json:",inline" yaml:",inline"`
}

type Diff 

type Diff struct {
	StateStorage states.StateStorage
}

func (*Diff) Diff 

func (d *Diff) Diff(request *DiffRequest) (string, error)

type DiffRequest 

type DiffRequest struct {
	Request
}

type ExecutableNode 

type ExecutableNode interface {
	Execute(operation *Operation) status.Status
}

type ManifestParser 

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

func NewManifestParser 

func NewManifestParser(manifest *manifest.Manifest) *ManifestParser

func (*ManifestParser) Parse 

func (m *ManifestParser) Parse(graph *dag.AcyclicGraph) (s status.Status)

type Message 

type Message struct {
	ResourceID string   // ResourceNode.ID()
	OpResult   OpResult // Success/Failed/Skip
	OpErr      error    // Operate error detail
}

type OpResult 

type OpResult string
const (
	Success OpResult = "Success"
	Failed  OpResult = "Failed"
	Skip    OpResult = "Skip"
)

OpResult values

type Operation 

type Operation struct {
	OperationType Type
	StateStorage  states.StateStorage
	// CtxResourceIndex represents resources updated by func apply
	CtxResourceIndex map[string]*states.ResourceState
	// PriorStateResourceIndex represents prior states.StateStorage state
	PriorStateResourceIndex map[string]*states.ResourceState
	// StateResourceIndex represents resources that will be saved in states.StateStorage
	StateResourceIndex map[string]*states.ResourceState
	// Order contains id to action of resource node in preview order
	Order   *ChangeOrder
	Runtime runtime.Runtime
	MsgCh   chan Message
	// contains filtered or unexported fields
}

func (*Operation) Apply 

func (o *Operation) Apply(request *ApplyRequest) (rsp *ApplyResponse, st status.Status)

func (*Operation) Destroy 

func (o *Operation) Destroy(request *DestroyRequest) (st status.Status)

func (*Operation) Preview 

func (o *Operation) Preview(request *PreviewRequest, operation Type) (rsp *PreviewResponse, s status.Status)

func (*Operation) RefreshResourceIndex 

func (o *Operation) RefreshResourceIndex(resourceKey string, resource *states.ResourceState, actionType ActionType) error

RefreshResourceIndex refresh resources in CtxResourceIndex & StateResourceIndex

func (*Operation) UpdateState 

func (o *Operation) UpdateState(resourceIndex map[string]*states.ResourceState) error

type Parser 

type Parser interface {
	Parse(dag *dag.AcyclicGraph) status.Status
}

type PreviewOperation 

type PreviewOperation struct {
	Operation
}

type PreviewRequest 

type PreviewRequest struct {
	Request `json:",inline" yaml:",inline"`
}

type PreviewResponse 

type PreviewResponse struct {
	Order *ChangeOrder
}

type Request 

type Request struct {
	Tenant   string             `json:"tenant"`
	Stack    string             `json:"stack"`
	Project  string             `json:"project"`
	Operator string             `json:"operator"`
	Manifest *manifest.Manifest `json:"manifest"`
}

type ResourceNode 

type ResourceNode struct {
	BaseNode
	Action ActionType
	// contains filtered or unexported fields
}

func NewResourceNode 

func NewResourceNode(key string, state *states.ResourceState, action ActionType) *ResourceNode

func (*ResourceNode) Execute 

func (rn *ResourceNode) Execute(operation *Operation) status.Status

func (*ResourceNode) State 

func (rn *ResourceNode) State() *states.ResourceState

type RootNode 

type RootNode struct{}

func (*RootNode) Hashcode 

func (r *RootNode) Hashcode() interface{}

func (*RootNode) Name 

func (r *RootNode) Name() string

type Type 

type Type int64
const (
	UndefinedOperation Type = iota // invalidate value
	Apply
	Preview
	Destroy
)

Operation type

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.