migrations

Documentation

Index

• func Clone(data []byte, depMapping map[uuids.UUID]uuids.UUID) ([]byte, error)
• func MigrateToLatest(data []byte, config *Config) ([]byte, error)
• func MigrateToVersion(data []byte, to *semver.Version, config *Config) ([]byte, error)
• func Registered() map[*semver.Version]MigrationFunc
• type Action
  • func (a Action) Type() string
• type Config
• type Flow
  • func Migrate13_1(f Flow) (Flow, error)
  • func (f Flow) Nodes() []Node
• type Header13
• type MigrationFunc
• type Node
  • func (n Node) Actions() []Action
  • func (n Node) Router() Router
• type Router
  • func (r Router) Type() string

Functions

func Clone

func Clone(data []byte, depMapping map[uuids.UUID]uuids.UUID) ([]byte, error)

Clone clones the given flow definition by replacing all UUIDs using the provided mapping and generating new random UUIDs if they aren't in the mapping

func MigrateToLatest

func MigrateToLatest(data []byte, config *Config) ([]byte, error)

MigrateToLatest migrates the given flow definition to the latest version

func MigrateToVersion

func MigrateToVersion(data []byte, to *semver.Version, config *Config) ([]byte, error)

MigrateToVersion migrates the given flow definition to the given version

func Registered

func Registered() map[*semver.Version]MigrationFunc

Registered gets all registered migrations

Types

type Action

type Action map[string]interface{}

func (Action) Type

func (a Action) Type() string

type Config

type Config struct {
	BaseMediaURL string
}

Config configures how flow migrations are handled

type Flow

type Flow map[string]interface{}

func Migrate13_1

func Migrate13_1(f Flow) (Flow, error)

Migrate13_1 adds UUID to send_msg templating

func (Flow) Nodes

func (f Flow) Nodes() []Node

type Header13

type Header13 struct {
	UUID        assets.FlowUUID `json:"uuid" validate:"required,uuid4"`
	Name        string          `json:"name"`
	SpecVersion *semver.Version `json:"spec_version" validate:"required"`
}

Header13 is the set of fields common to all 13+ flow spec versions

type MigrationFunc

type MigrationFunc func(Flow) (Flow, error)

MigrationFunc is a function that can migrate a flow definition from one version to another

type Node

type Node map[string]interface{}

func (Node) Actions

func (n Node) Actions() []Action

func (Node) Router

func (n Node) Router() Router

type Router

type Router map[string]interface{}

func (Router) Type

func (r Router) Type() string