util

Documentation

Index

• Constants
• func BigFloatToInt64(input *big.Float) int64
• func CalculateHash(s, salt string) string
• func CreateFlowpipeSalt(filename string, length int) (string, error)
• func EnsureDir(dir string) error
• func GetBaseUrl() string
• func GetGlobalSalt() (string, error)
• func GetHost() string
• func GetModSaltOrDefault() (string, error)
• func GetWebformUrl(execId string, pExecId string, sExecId string) (string, error)
• func NewExecutionID() string
• func NewPipelineExecutionID() string
• func NewProcessID() string
• func NewSessionID() string
• func NewStepExecutionID() string
• func NewUniqueID() string
• func SafeDeref[T any](ptr *T) T
• func ValidateEmailInput(ctx context.Context, i modconfig.Input) error
• type CommandBusMock
  • func (c *CommandBusMock) Send(ctx context.Context, command interface{}) error
  • func (c *CommandBusMock) SendWithLock(ctx context.Context, command interface{}, lock *sync.Mutex) error
• type HclExpressionMock
  • func (*HclExpressionMock) Range() hcl.Range
  • func (*HclExpressionMock) StartRange() hcl.Range
  • func (h *HclExpressionMock) Value(evalCtx *hcl.EvalContext) (cty.Value, hcl.Diagnostics)
  • func (*HclExpressionMock) Variables() []hcl.Traversal

Constants

const RFC3389WithMS = "2006-01-02T15:04:05.000Z07:00"

Functions

func BigFloatToInt64

func BigFloatToInt64(input *big.Float) int64

func CalculateHash

func CalculateHash(s, salt string) string

func CreateFlowpipeSalt

func CreateFlowpipeSalt(filename string, length int) (string, error)

Assumes that the dir exists

The function creates the salt if it does not exist, or it returns the existing salt if it's already there

func EnsureDir

func EnsureDir(dir string) error

func GetBaseUrl

func GetBaseUrl() string

func GetGlobalSalt

func GetGlobalSalt() (string, error)

func GetHost

func GetHost() string

func GetModSaltOrDefault

func GetModSaltOrDefault() (string, error)

Global vs Mod salt behaviour:

- We should only create the salt *automatically* in the "global" location: `~/.flowpipe/internal/salt ` - A user may create a "mod salt" file in the mod manually (`./.flowpipe/internal/salt`)

- If there is a mod salt, it is used for triggers, otherwise use the global salt. *Integrations* always use the global salt - this implies that:

• any new installs will only have global salt (unless a user manually creates one)
• existing installs work and continue to use the same salt as they currently do (unless the user manually deletes the salt)
• the user may decide to use their own custom per-mod salt, but this is an advanced operation

func GetWebformUrl

func GetWebformUrl(execId string, pExecId string, sExecId string) (string, error)

func NewExecutionID

func NewExecutionID() string

func NewPipelineExecutionID

func NewPipelineExecutionID() string

func NewProcessID

func NewProcessID() string

func NewSessionID

func NewSessionID() string

func NewStepExecutionID

func NewStepExecutionID() string

func NewUniqueID

func NewUniqueID() string

func SafeDeref

func SafeDeref[T any](ptr *T) T

func ValidateEmailInput

func ValidateEmailInput(ctx context.Context, i modconfig.Input) error

Types

type CommandBusMock

type CommandBusMock struct {
	SendFunc         func(ctx context.Context, command interface{}) error
	SendWithLockFunc func(ctx context.Context, command interface{}, lock *sync.Mutex) error
}

func (*CommandBusMock) Send

func (c *CommandBusMock) Send(ctx context.Context, command interface{}) error

func (*CommandBusMock) SendWithLock

func (c *CommandBusMock) SendWithLock(ctx context.Context, command interface{}, lock *sync.Mutex) error

type HclExpressionMock

type HclExpressionMock struct {
	ValueFunc func(evalCtx *hcl.EvalContext) (cty.Value, hcl.Diagnostics)
}

func (*HclExpressionMock) Range

func (*HclExpressionMock) Range() hcl.Range

func (*HclExpressionMock) StartRange

func (*HclExpressionMock) StartRange() hcl.Range

func (*HclExpressionMock) Value

func (h *HclExpressionMock) Value(evalCtx *hcl.EvalContext) (cty.Value, hcl.Diagnostics)

func (*HclExpressionMock) Variables

func (*HclExpressionMock) Variables() []hcl.Traversal