pubsub

package
v1.13.2 Latest Latest
Warning

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

Go to latest
Published: Apr 3, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExtractCloudEventProperty

func ExtractCloudEventProperty(cloudEvent map[string]any, property string) string

func New

func New(opts Options) *pubsub

Types

type Options

type Options struct {
	ID            string
	Namespace     string
	IsHTTP        bool
	PodName       string
	Mode          modes.DaprMode
	ResourcesPath []string

	Registry       *comppubsub.Registry
	ComponentStore *compstore.ComponentStore
	Resiliency     resiliency.Provider
	Meta           *meta.Meta
	TracingSpec    *config.TracingSpec
	GRPC           *manager.Manager
	Channels       *channels.Channels
	OperatorClient operatorv1.OperatorClient
}

Jump to

Keyboard shortcuts

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