common

type Event struct {
	Time    time.Time              `json:"time"`
	Channel string                 `json:"channel"`
	Type    string                 `json:"type"`
	Data    interface{}            `json:"data"`
	Via     map[string]interface{} `json:"via,omitempty"`
	// contains filtered or unexported fields
}

type HttpProcessor interface {
	Processor
	HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
}

type Input interface {
	Start(wg *sync.WaitGroup, outputs *Outputs)
}

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

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

type Output interface {
	Send(event *Event)
	Name() string
}

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

type Processor interface {
	EventType() string
	HandleEvent(e *Event) error
}

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