events

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TaskRetriedExtension    = "taskretried"
	TaskMaxRetriesExtension = "taskmaxretries"
	TaskQueueExtension      = "taskqueue"
	TaskNotBeforeExtension  = "tasknotbefore"
	ScheduledTaskExtension  = "scheduledtask"
)

Task extension keys

View Source
const ApplicationJson = "application/json"
View Source
const Source = "fxfeed"

Variables

This section is empty.

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 Event

type Event struct {
	ID   string
	Kind string
	Args map[string]interface{}
}

type Kinder

type Kinder interface {
	Kind() string
}

type Payloader

type Payloader interface {
	Payload() any
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL