input

package
v1.18.3-rc.1 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Input

type Input struct {
	// contains filtered or unexported fields
}

func Run

func Run(opts Options) (*Input, error)

func (*Input) Stop

func (i *Input) Stop()

type Options

type Options struct {
	Name    string
	Binding bindings.InputBinding
	Handler func(context.Context, string, []byte, map[string]string) ([]byte, error)

	// DecorateContext, when set, decorates the long-lived read-loop context
	// before Read is invoked on the binding. Dapr uses it to attach the
	// workload's SPIFFE identity so the binding can authenticate to its backing
	// infrastructure service.
	DecorateContext func(context.Context) context.Context
}

Jump to

Keyboard shortcuts

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