event

Documentation

Index

• type AvroProducer
  • func NewAvroProducer(outputChannel chan []byte, marshaller Marshaller) *AvroProducer
  • func (producer *AvroProducer) ImagePublished(event *ImagePublished) error
  • func (producer *AvroProducer) ImageUploaded(event *ImageUploaded) error
• type ImagePublished
• type ImageUploaded
• type Marshaller

Types

type AvroProducer

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

AvroProducer of output events.

func NewAvroProducer

func NewAvroProducer(outputChannel chan []byte, marshaller Marshaller) *AvroProducer

NewAvroProducer returns a new instance of AvroProducer.

func (*AvroProducer) ImagePublished

func (producer *AvroProducer) ImagePublished(event *ImagePublished) error

ImagePublished produces a new ImagePublished event.

func (*AvroProducer) ImageUploaded

func (producer *AvroProducer) ImageUploaded(event *ImageUploaded) error

ImageUploaded produces a new ImageUploaded event.

type ImagePublished

type ImagePublished struct {
	ImageID string `avro:"image_id"`
}

ImagePublished provides an avro structure for an image published event

type ImageUploaded

type ImageUploaded struct {
	Path    string `avro:"path"`
	ImageID string `avro:"image_id"`
}

ImageUploaded provides an avro structure for an image uploaded event

type Marshaller

type Marshaller interface {
	Marshal(s interface{}) ([]byte, error)
}

Marshaller marshals events into messages.