propagator

package
v0.19.921 Latest Latest
Warning

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

Go to latest
Published: May 7, 2026 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(params Params) workflow.ContextPropagator

Types

type Params

type Params struct {
	fx.In

	L             *zap.Logger
	DataConverter converter.DataConverter
}

type Payload

type Payload struct {
	OrgID     string         `json:"org_id"`
	AccountID string         `json:"account_id"`
	TraceID   string         `json:"trace_id"`
	LogStream *app.LogStream `json:"log_stream,omitempty"`
}

func FetchPayload

func FetchPayload(ctx cctx.ValueContext) (*Payload, error)

Jump to

Keyboard shortcuts

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