xbflow

Documentation

Index

• type BaseFlow
  • func (flow *BaseFlow) Async(operate Operate, args ...any)
  • func (flow *BaseFlow) Contain(key string) bool
  • func (flow *BaseFlow) Expose(key string, value any)
  • func (flow *BaseFlow) GetError() error
  • func (flow *BaseFlow) GetID() string
  • func (flow *BaseFlow) GetLogger() *xblogger.Entry
  • func (flow *BaseFlow) GetOutcome() any
  • func (flow *BaseFlow) GetStorage() *sync.Map
  • func (flow *BaseFlow) GetTrails() []string
  • func (flow *BaseFlow) HasError() bool
  • func (flow *BaseFlow) Inherit(fore Flow)
  • func (flow *BaseFlow) Initiate()
  • func (flow *BaseFlow) Require(key string) any
  • func (flow *BaseFlow) RequireBool(key string) bool
  • func (flow *BaseFlow) RequireBools(key string) []bool
  • func (flow *BaseFlow) RequireBytes(key string) []byte
  • func (flow *BaseFlow) RequireDuration(key string) time.Duration
  • func (flow *BaseFlow) RequireError(key string) error
  • func (flow *BaseFlow) RequireFloat64(key string) float64
  • func (flow *BaseFlow) RequireFloat64s(key string) []float64
  • func (flow *BaseFlow) RequireInt(key string) int
  • func (flow *BaseFlow) RequireInt64(key string) int64
  • func (flow *BaseFlow) RequireInt64s(key string) []int64
  • func (flow *BaseFlow) RequireIntBoolMap(key string) map[int]bool
  • func (flow *BaseFlow) RequireIntIntMap(key string) map[int]int
  • func (flow *BaseFlow) RequireIntMap(key string) map[int]any
  • func (flow *BaseFlow) RequireIntSet(key string) map[int]struct{}
  • func (flow *BaseFlow) RequireIntStringMap(key string) map[int]string
  • func (flow *BaseFlow) RequireInts(key string) []int
  • func (flow *BaseFlow) RequireRawMessage(key string) xbjson.RawMessage
  • func (flow *BaseFlow) RequireString(key string) string
  • func (flow *BaseFlow) RequireStringBoolMap(key string) map[string]bool
  • func (flow *BaseFlow) RequireStringIntMap(key string) map[string]int
  • func (flow *BaseFlow) RequireStringMap(key string) map[string]any
  • func (flow *BaseFlow) RequireStringSet(key string) map[string]struct{}
  • func (flow *BaseFlow) RequireStringStringMap(key string) map[string]string
  • func (flow *BaseFlow) RequireStrings(key string) []string
  • func (flow *BaseFlow) RequireTime(key string) time.Time
  • func (flow *BaseFlow) RequireUint(key string) uint
  • func (flow *BaseFlow) RequireUint64(key string) uint64
  • func (flow *BaseFlow) SetError(err error)
  • func (flow *BaseFlow) SetOutcome(outcome any)
  • func (flow *BaseFlow) SetStorage(storage *sync.Map)
• type Flow
• type Operate

Types

type BaseFlow

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

func (*BaseFlow) Async

func (flow *BaseFlow) Async(operate Operate, args ...any)

func (*BaseFlow) Contain

func (flow *BaseFlow) Contain(key string) bool

func (*BaseFlow) Expose

func (flow *BaseFlow) Expose(key string, value any)

func (*BaseFlow) GetError

func (flow *BaseFlow) GetError() error

func (*BaseFlow) GetID

func (flow *BaseFlow) GetID() string

func (*BaseFlow) GetLogger

func (flow *BaseFlow) GetLogger() *xblogger.Entry

func (*BaseFlow) GetOutcome

func (flow *BaseFlow) GetOutcome() any

func (*BaseFlow) GetStorage

func (flow *BaseFlow) GetStorage() *sync.Map

func (*BaseFlow) GetTrails

func (flow *BaseFlow) GetTrails() []string

func (*BaseFlow) HasError

func (flow *BaseFlow) HasError() bool

func (*BaseFlow) Inherit

func (flow *BaseFlow) Inherit(fore Flow)

func (*BaseFlow) Initiate

func (flow *BaseFlow) Initiate()

func (*BaseFlow) Require

func (flow *BaseFlow) Require(key string) any

func (*BaseFlow) RequireBool

func (flow *BaseFlow) RequireBool(key string) bool

func (*BaseFlow) RequireBools

func (flow *BaseFlow) RequireBools(key string) []bool

func (*BaseFlow) RequireBytes

func (flow *BaseFlow) RequireBytes(key string) []byte

func (*BaseFlow) RequireDuration

func (flow *BaseFlow) RequireDuration(key string) time.Duration

func (*BaseFlow) RequireError

func (flow *BaseFlow) RequireError(key string) error

func (*BaseFlow) RequireFloat64

func (flow *BaseFlow) RequireFloat64(key string) float64

func (*BaseFlow) RequireFloat64s

func (flow *BaseFlow) RequireFloat64s(key string) []float64

func (*BaseFlow) RequireInt

func (flow *BaseFlow) RequireInt(key string) int

func (*BaseFlow) RequireInt64

func (flow *BaseFlow) RequireInt64(key string) int64

func (*BaseFlow) RequireInt64s

func (flow *BaseFlow) RequireInt64s(key string) []int64

func (*BaseFlow) RequireIntBoolMap

func (flow *BaseFlow) RequireIntBoolMap(key string) map[int]bool

func (*BaseFlow) RequireIntIntMap

func (flow *BaseFlow) RequireIntIntMap(key string) map[int]int

func (*BaseFlow) RequireIntMap

func (flow *BaseFlow) RequireIntMap(key string) map[int]any

func (*BaseFlow) RequireIntSet

func (flow *BaseFlow) RequireIntSet(key string) map[int]struct{}

func (*BaseFlow) RequireIntStringMap

func (flow *BaseFlow) RequireIntStringMap(key string) map[int]string

func (*BaseFlow) RequireInts

func (flow *BaseFlow) RequireInts(key string) []int

func (*BaseFlow) RequireRawMessage

func (flow *BaseFlow) RequireRawMessage(key string) xbjson.RawMessage

func (*BaseFlow) RequireString

func (flow *BaseFlow) RequireString(key string) string

func (*BaseFlow) RequireStringBoolMap

func (flow *BaseFlow) RequireStringBoolMap(key string) map[string]bool

func (*BaseFlow) RequireStringIntMap

func (flow *BaseFlow) RequireStringIntMap(key string) map[string]int

func (*BaseFlow) RequireStringMap

func (flow *BaseFlow) RequireStringMap(key string) map[string]any

func (*BaseFlow) RequireStringSet

func (flow *BaseFlow) RequireStringSet(key string) map[string]struct{}

func (*BaseFlow) RequireStringStringMap

func (flow *BaseFlow) RequireStringStringMap(key string) map[string]string

func (*BaseFlow) RequireStrings

func (flow *BaseFlow) RequireStrings(key string) []string

func (*BaseFlow) RequireTime

func (flow *BaseFlow) RequireTime(key string) time.Time

func (*BaseFlow) RequireUint

func (flow *BaseFlow) RequireUint(key string) uint

func (*BaseFlow) RequireUint64

func (flow *BaseFlow) RequireUint64(key string) uint64

func (*BaseFlow) SetError

func (flow *BaseFlow) SetError(err error)

func (*BaseFlow) SetOutcome

func (flow *BaseFlow) SetOutcome(outcome any)

func (*BaseFlow) SetStorage

func (flow *BaseFlow) SetStorage(storage *sync.Map)

type Flow

type Flow interface {
	GetID() string
	GetTrails() []string
}

type Operate

type Operate = func(args ...any) error