log

Documentation

Overview

//go:build components_log || components_all

//go:build components_log || components_all

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 Endpoint
  • 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() camel.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           = "log"
	PropertiesPrefix = "camel.component." + Scheme
)

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"`
}

type Endpoint

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

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() camel.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