pubsub

Documentation

Index

• func ExtractCloudEventProperty(cloudEvent map[string]any, property string) string
• func New(opts Options) *pubsub
• type Options

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
}