pubsub

Documentation

Index

• Constants
• func NewComponent(ctx api.Context, _ map[string]interface{}) (api.Component, error)
• type Component
  • func (c *Component) Endpoint(config api.Parameters) (api.Endpoint, error)
• type Config
• type Consumer
  • func (c *Consumer) Endpoint() camel.Endpoint
  • func (c *Consumer) Receive(ctx actor.Context)
  • func (c *Consumer) Start(_ context.Context) error
  • func (c *Consumer) Stop(context.Context) error
• type Endpoint
  • func (e *Endpoint) Consumer(pid *actor.PID) (api.Consumer, error)
  • func (e *Endpoint) Producer() (api.Producer, error)
  • func (e *Endpoint) Start(context.Context) error
  • func (e *Endpoint) Stop(context.Context) error
• type Producer
  • func (p *Producer) Endpoint() api.Endpoint
  • func (p *Producer) Receive(ac actor.Context)
  • func (p *Producer) Start(context.Context) error
  • func (p *Producer) Stop(context.Context) error

Constants

const (
	Scheme           = "dapr-pubsub"
	PropertiesPrefix = "camel.component." + Scheme

	AttributeEventID     = "camel.apache.org/dapr.event.id"
	AttributePubSubName  = "camel.apache.org/dapr.pubsub.name"
	AttributePubSubTopic = "camel.apache.org/dapr.pubsub.topic"
)

Functions

func NewComponent

func NewComponent(ctx api.Context, _ map[string]interface{}) (api.Component, error)

Types

type Component

type Component struct {
	components.DefaultComponent
}

func (*Component) Endpoint

func (c *Component) Endpoint(config api.Parameters) (api.Endpoint, error)

type Config

type Config struct {
	Remaining string `mapstructure:"remaining"`
	Raw       bool   `mapstructure:"raw"`
}

type Consumer

type Consumer struct {
	components.DefaultConsumer
	// contains filtered or unexported fields
}

func (*Consumer) Endpoint

func (c *Consumer) Endpoint() camel.Endpoint

func (*Consumer) Receive

func (c *Consumer) Receive(ctx actor.Context)

func (*Consumer) Start

func (c *Consumer) Start(_ context.Context) error

func (*Consumer) Stop

func (c *Consumer) Stop(context.Context) error

type Endpoint

type Endpoint struct {
	components.DefaultEndpoint
	// contains filtered or unexported fields
}

func (*Endpoint) Consumer

func (e *Endpoint) Consumer(pid *actor.PID) (api.Consumer, error)

func (*Endpoint) Producer

func (e *Endpoint) Producer() (api.Producer, error)

func (*Endpoint) Start

func (e *Endpoint) Start(context.Context) error

func (*Endpoint) Stop

func (e *Endpoint) Stop(context.Context) error

type Producer

type Producer struct {
	components.DefaultProducer
	// contains filtered or unexported fields
}

func (*Producer) Endpoint

func (p *Producer) Endpoint() api.Endpoint

func (*Producer) Receive

func (p *Producer) Receive(ac actor.Context)

func (*Producer) Start

func (p *Producer) Start(context.Context) error

func (*Producer) Stop

func (p *Producer) Stop(context.Context) error