event

Documentation

Index

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

Types

type AvroProducer

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

func NewAvroProducer

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

NewAvroProducer returns a new instance of AvroProducer.

func (*AvroProducer) InteractiveUploaded

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

InteractiveUploaded produces a new InteractiveUploaded event.

type InteractiveUploaded

type InteractiveUploaded struct {
	FilePath     string `avro:"path"`
	ID           string `avro:"id"`
	Title        string `avro:"title"`
	CollectionID string `avro:"collection_id"`
}

type Marshaller

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

Marshaller marshals events into messages.