report

Documentation

Index

• func ActionError(ctx context.Context, t types.BaseObject, ac *v1.Action, s rulex.Status, ...)
• func ActionStatus(ctx context.Context, t types.BaseObject, ac *v1.Action, s rulex.Status)
• func InitReportSink(sink xstream.Sink)
• func NewMessage(data interface{}) (xstream.Message, error)
• func Report(ctx context.Context, status *rulex.RulexStatus) error
• func TaskError(ctx context.Context, t types.BaseObject, s rulex.Status, err error)
• func TaskStatus(ctx context.Context, t types.BaseObject, status rulex.Status)

Functions

func ActionError

func ActionError(ctx context.Context, t types.BaseObject, ac *v1.Action, s rulex.Status, err error)

func ActionStatus

func ActionStatus(ctx context.Context, t types.BaseObject, ac *v1.Action, s rulex.Status)

func InitReportSink

func InitReportSink(sink xstream.Sink)

func NewMessage

func NewMessage(data interface{}) (xstream.Message, error)

func Report

func Report(ctx context.Context, status *rulex.RulexStatus) error

func TaskError

func TaskError(ctx context.Context, t types.BaseObject, s rulex.Status, err error)

func TaskStatus

func TaskStatus(ctx context.Context, t types.BaseObject, status rulex.Status)