eventing

README

Eventing

Each CRUD operation generates cloudevents from the data layer. Events are sent using an EventManager and a Producer.

To send an event, the data layer first uses the requester's identity and information about the resource to look up a Producer from the EventManager. The Lookup handles any complicated logic about selecting the correct Kafka topic and captures the decision in the Producer. The data layer then uses the Producer to send the event.

This package contains two implementations.

1. stdout dumps json encoded events to stdout
2. kafka sends a cloudevent to a Kafka topic

Documentation

Index

• func New(c CompletedConfig, source string, logger *log.Helper) (api.Manager, error)
• type CompletedConfig
• type Config
  • func NewConfig(o *Options) *Config
  • func (c *Config) Complete() (CompletedConfig, []error)
• type Options
  • func NewOptions() *Options
  • func (o *Options) AddFlags(fs *pflag.FlagSet, prefix string)
  • func (o *Options) Complete() []error
  • func (o *Options) Validate() []error

Functions

func New

func New(c CompletedConfig, source string, logger *log.Helper) (api.Manager, error)

Types

type CompletedConfig

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

type Config

type Config struct {
	Eventer string
	Kafka   *kafka.Config
}

func NewConfig

func NewConfig(o *Options) *Config

func (*Config) Complete

func (c *Config) Complete() (CompletedConfig, []error)

type Options

type Options struct {
	Kafka   *kafka.Options `mapstructure:"kafka"`
	Eventer string         `mapstructure:"eventer"`
}

func NewOptions

func NewOptions() *Options

func (*Options) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet, prefix string)

func (*Options) Complete

func (o *Options) Complete() []error

func (*Options) Validate

func (o *Options) Validate() []error