example_word_materialise

Documentation

Index

• Constants
• func Register(m flows.Main)
• func Registrar(ci inverse.Container) flows.Prebuilt
• type FlowsMaterialised
  • func FlowsMaterialisedMap(c context.Context, m flow.Message[string, string]) ([]FlowsMaterialised, error)

Constants

const (
	Instance = "flows-word-materialise"
)

Functions

func Register

func Register(m flows.Main)

func Registrar

func Registrar(ci inverse.Container) flows.Prebuilt

Types

type FlowsMaterialised

type FlowsMaterialised struct {
	bun.BaseModel `bun:"table:flows_materialised"`
	Id            string `bun:",pk"`
	KeyContent    string
	ValueContent  string
	TimestampMs   int64
}

func FlowsMaterialisedMap

func FlowsMaterialisedMap(c context.Context, m flow.Message[string, string]) ([]FlowsMaterialised, error)