util

Documentation

Index

• Constants
• func BigFloatToInt64(input *big.Float) int64
• func CalculateHash(s, salt string) string
• func GetHost() string
• func NewExecutionID() string
• func NewPipelineExecutionID() string
• func NewProcessID() string
• func NewSessionID() string
• func NewStepExecutionID() string
• func NewUniqueID() string
• func RunSendEmail(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
• 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 GetHost

func GetHost() string

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 RunSendEmail

func RunSendEmail(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

TODO: Sync up with email step - once the variable names are in sync, we can use the same schema

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