events

type EndpointCreated struct {
	Ts      time.Time
	Payload *m.EndpointDTO
}

type EndpointDeleted struct {
	Ts      time.Time
	Payload *m.EndpointDTO
}

type EndpointUpdated struct {
	Ts      time.Time
	Payload struct {
		Last    *m.EndpointDTO `json:"last"`
		Current *m.EndpointDTO `json:"current"`
	}
}

type Event interface {
	Type() string
	Timestamp() time.Time
	Body() ([]byte, error)
	Id() string
}

type Handlers struct {
	sync.Mutex
	Listeners map[string][]chan<- RawEvent
}

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

type Message struct {
	Id      string
	Payload []byte
}

type ProbeCreated struct {
	Ts      time.Time
	Payload *m.ProbeDTO
}

type ProbeDeleted struct {
	Ts      time.Time
	Payload *m.ProbeDTO
}

type ProbeOffline struct {
	Ts      time.Time
	Payload *m.ProbeDTO
}

type ProbeOnline struct {
	Ts      time.Time
	Payload *m.ProbeDTO
}

type ProbeSessionCreated struct {
	Ts      time.Time
	Payload *m.ProbeSession
}

type ProbeSessionDeleted struct {
	Ts      time.Time
	Payload *m.ProbeSession
}

type ProbeUpdated struct {
	Ts      time.Time
	Payload struct {
		Last    *m.ProbeDTO `json:"last"`
		Current *m.ProbeDTO `json:"current"`
	}
}

type RawEvent struct {
	Id        string          `json:"id"`
	Type      string          `json:"type"`
	Timestamp time.Time       `json:"timestamp"`
	Body      json.RawMessage `json:"payload"`
	Source    string          `json:"source"`
	Attempts  int             `json:"attempts"`
}