event

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

type Event struct {
	Meta    *Meta  `json:"meta"`
	Payload []byte `json:"payload"`
}

type HandlerFunc func(ctx context.Context, e *Event) error

type ID string

type Meta struct {
	UUID      string    `json:"uuid"`
	ID        ID        `json:"id"`
	Version   string    `json:"version"`
	CreatedAt time.Time `json:"created_at"`
}

type PayloadMeta struct {
	Version string `json:"version"`
}

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