events

Documentation

Index

• Constants
• func Deserialize(ce cloudevents.Event, target interface{}) error
• func Serialize(ctx context.Context, args Kinder) (cloudevents.Event, error)
• func SerializeWithExt(ctx context.Context, args Kinder, extKvPairs ...string) (cloudevents.Event, error)
• type Kinder
• type Payloader

Constants

const (
	TaskRetriedExtension     = "taskretried"
	TaskMaxRetriesExtension  = "taskmaxretries"
	TaskQueueExtension       = "taskqueue"
	TaskNotBeforeExtension   = "tasknotbefore"
	ScheduledTaskExtension   = "scheduledtask"
	ScheduleIdExtension      = "scheduleid"
	QstashMessageIdExtension = "qstashmessageid"
)

Task extension keys

const ApplicationJson = "application/json"

const Source = "fxfeed"

Functions

func Deserialize

func Deserialize(ce cloudevents.Event, target interface{}) error

func Serialize

func Serialize(ctx context.Context, args Kinder) (cloudevents.Event, error)

func SerializeWithExt

func SerializeWithExt(ctx context.Context, args Kinder, extKvPairs ...string) (cloudevents.Event, error)

Types

type Kinder

type Kinder interface {
	Kind() string
}

type Payloader

type Payloader interface {
	Payload() any
}